hadoop与mysql数据库的那点事(1)
5星 · 超过95%的资源 116 浏览量
2020-12-14
23:21:05
上传
评论
收藏 46KB PDF 举报 
hadoop与与mysql数据库的那点事数据库的那点事(1)
转眼间已经接触了hadoop两周了，从之前的极力排斥到如今的有点喜欢，刚开始被搭建hadoop开发环境搞得几乎要放
弃，如今学会了编写小程序，每天都在成长一点挺好的，好好努力，为自己的装备库再填一件武器挺好的，学习在于坚持不
懈，加油！！！
马上要过年了，在后的上班时间内完成了hadoop如何去连接mysql数据库，自己感到很满足，下面把自己编写的源码贡献
给大家，希望能够帮到你们，如存在优化的地方还请大牛们指出，也希望有hadoop的大牛能够给点学习建议，一个来个HA初
学者的心声。第一次发布竟然被退回，也不知道为什么，瞬间心情都不好了，但我还是坚持写自己的博客…
StudentRecord类:
package com.simope.mr.db;
import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.io.Writable;
import org.apache.hadoop.mapred.lib.db.DBWritable;
public class StudentRecord implements Writable， DBWritable{
int id;
String name;
int age;
int departmentID;
@Override
public void readFields(DataInput in) throws IOException {
this.id = in.readInt();
this.name = Text.readString(in);
this.age = in.readInt();
this.departmentID = in.readInt();
}
@Override
public void write(DataOutput out) throws IOException {
out.write(this.id);
Text.writeString(out， this.name);
out.write(this.age);
out.write(this.departmentID);
}
public void readFields(ResultSet rs) throws SQLException {
this.id = rs.getInt(1);
this.name = rs.getString(2);
this.age = rs.getInt(3);
this.departmentID = rs.getInt(4);
}
public void write(PreparedStatement ps) throws SQLException {
ps.setInt(1， this.id);
ps.setString(2， this.name);
ps.setInt(3， this.age);
ps.setInt(4， this.departmentID);
}
@Override
public String toString() {
return new String(this.name + " " + this.age + " " + this.departmentID);
}
}
TeacherRecord类:
package com.simope.mr.db;
import java.io.DataInput;
import java.io.DataOutput;
import java.io.IOException;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import org.apache.hadoop.io.Text;
import org.apache.hadoop.io.Writable;
import org.apache.hadoop.mapred.lib.db.DBWritable;
public class TeacherRecord implements Writable， DBWritable{
weixin_38520046
- 粉丝: 8
- 资源: 932
最新资源
- 基于串口通信的光通信上位机，包括运动控制和通信协议
- 串口与以太网文件传送协议(或自定义控制协议)
- Qt开发windows系统安装教程与代码实例.txt
- QT6实现的附带文件传输协议的串口终端
- 一个串口通讯类和调用Demo 通过设置串口、设置串口自定义协议，可方便对串口发送数据与接收数据
- 华为OD模拟题及参考答案.仅供学习和模拟考试使用
- stm32f103c8t6基于modbus协议和使用串口读取温湿度
- 英雄联盟LOL金克斯4K电脑壁纸
- Microbrain道闸产品上位机，以MahApps库为基础搭建界面，集成了串口（UART）、CAN、WIFI通信，十六进制协议
- Android串口通讯, 支持发送数据回调, 支持并发处理, 自定义协议, CRC校验, 自动粘包, 自动去除冗余的干扰数据
资源上传下载、课程学习等过程中有任何疑问或建议，欢迎提出宝贵意见哦~我们会及时处理！
点击此处反馈
评论10