JDBC处理大数据-蒲公英云

JDBC处理大数据

使用Mysql数据库也可以处理大数据，在实际开发中需要把大文本或者二进制数据保存到数据库中去。clob是用来存储大文本的,mysql数据库不支持。bclob用于存储二进制数据，例如：图像、声音、二进制文件等。

对于Mysql的Text类型，可调用如下方法设置：

preparedStatment.setCharacterStatment(index,reader,length);

对于MYSQL中的Text类型，可调用如下方法获取：

reader = result.getCharacterStreate(i);

reader = result.getClob(i).getCharacterStream();

String s = result.getString();

首先应在编译器src文件夹下创建一个text文档，用于存储数据，写进数据库。

1.text实现写入的数据如下：

70 1

然后编写代码进行写大数据到数据库。代码如下

代码：

@Test
public void insert(){
Connection connection = null;
PreparedStatement st = null;
ResultSet rs = null;
try {
connection = JDBCUtil.getConnection();
String sql = “insert into testclob(id,resume) values(?,?)”;
st =(PreparedStatement) connection.prepareStatement(sql);
st.setString(1,”1”);
File file = new File(“src/1.text”);
FileReader reader = new FileReader(file);
st.setCharacterStream(2, reader, (int)file.length());
int num = st.executeUpdate();
if(num > 0){
System.out.println(“插入成功！”);
}
} catch (Exception e) {
e.printStackTrace();
}finally {
JDBCUtil.close(rs, st, connection);
}

}

查询数据库中的表，是否成功插入到数据库中。

写大文本数据到数据库结束，在从数据库中读取大文本数据。到计算机的D盘路径下。

代码如下：

@Test
public void read(){
Connection connection = null;
PreparedStatement st = null;
ResultSet rs = null;
try {
connection = JDBCUtil.getConnection();
String sql = “select id,resume from testclob where id = ‘1’ “;
st = (PreparedStatement)connection.prepareStatement(sql);
rs = st.executeQuery();
if(rs.next()){
//String str = rs.getString(“reume”); 适用于小文本
Reader reader = rs.getCharacterStream(“resume”);
FileWriter writer = new FileWriter(“D:\\testclob.text”);
try{
int len = 0;
char buffer[] = new char[1024];
while((len = reader.read(buffer)) > 0){
writer.write(buffer,0,len);
}
}finally{
if(reader!=null){
reader.close();
}
writer.close();
}
}

} catch (Exception e) {
e.printStackTrace();
}finally {
JDBCUtil.close(rs, st, connection);
}

}

运行成功，到D盘查看生成的text文本。

文本内容如下：