JDBC读写MySQL的BLOB和CLOB类型数据（带代码）

慧9建

JDBC对LOB的读写
在JDBC中提供了java.sql.Blob和java.sql.Clob两个类分别代表BLOB和CLOB数据
·BLOB（Binary Large Object）：用于存储大量的二进制数据
·CLOB（Character Large Object）：用于存储大量的文本数据
本文以MySQL为例，通过最基本的JDBC技术来处理大字段的插入、读取操作。
环境： MySQL5  JDK1.6
1)首先创建一张数据表：
create table stuinfo(
id int(11) not null auto_increment,
name varchar(20)default null,
content mediumtext ,
image blob,
primary key (id)
);
2）先数据库中插入BLOB和CLOB类型的数据
package cn.wjz.jdbc;
import java.io.BufferedInputStream;
import java.io.File;
import java.io.FileInputStream;
import java.io.FileNotFoundException;
import java.io.InputStream;
import java.io.InputStreamReader;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.SQLException;
import cn.wjz.db.ConnectionFactory;
import cn.wjz.db.DbClose;
public class LobWrite {
public void LobW(){
Connection conn = ConnectionFactory.getConnection() ;
PreparedStatement pstmt = null ;
String sql =
"insert into stuinfo(name,content,image) values(?,?,?)" ;
try{
pstmt = conn.prepareStatement(sql) ;
pstmt.setString(1, "test") ;
/从文件中获取输入流———读取文本
File file = new File("D:\\wjz.gif");
try{
InputStreamReader reader = new InputStreamReader
(new FileInputStream("D:\\test.txt"));
pstmt.setCharacterStream
(2, reader, (int) file.length());
}catch(Exception e){
e.printStackTrace() ;
}
File file1 = new File("D:\\wjz.gif");
InputStream in;
try {
in = new BufferedInputStream
(new FileInputStream(file1));
pstmt.setBinaryStream
(3, in, (int) file1.length());
} catch (FileNotFoundException e) {
e.printStackTrace();
}
if(pstmt.executeUpdate() == 1){
System.out.println("恭喜您成功添加记录！！");
}else{
System.out.println("对不起您添加记录失败！！");
}
}catch(SQLException e){
e.printStackTrace();
DbClose.close(pstmt , conn ) ;
}
}
public static void main(String args[]){
LobWrite lobtest = new LobWrite() ;
lobtest.LobW() ;
}
}
3)从MySql数据库中读取BLOB和CLOB类型数据：
package cn.wjz.jdbc;
import java.io.BufferedInputStream;
import java.io.BufferedOutputStream;
import java.io.BufferedReader;
import java.io.FileOutputStream;
import java.io.IOException;
import java.io.Reader;
import java.sql.Blob;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import cn.wjz.db.ConnectionFactory;
import cn.wjz.db.DbClose;
public class LobRead {
public void lobread(){
Connection conn = ConnectionFactory.getConnection();
PreparedStatement pstmt = null;
String sql =
"SELECT id,name,content,image FROM stuinfo WHERE name=?";
ResultSet rs = null;
BufferedReader br =null;
try {
pstmt = conn.prepareStatement(sql);
pstmt.setString(1, "test");
rs = pstmt.executeQuery();
while (rs.next()) {
Reader rd = rs.getCharacterStream(3);
br = new BufferedReader(rd);
String str = null;
while((str = br.readLine()) != null){
System.out.println(str);
}
Blob blob = rs.getBlob(4);
BufferedInputStream bis =
new BufferedInputStream(blob.getBinaryStream());
BufferedOutputStream bos = new BufferedOutputStream
(new FileOutputStream("d:/wjz.gif"));
byte[] buffer = new byte[1024];
int count = -1;
while ((count = bis.read(buffer, 0, 1024)) != -1) {
bos.write(buffer, 0, count);
}
bos.flush();
bos.close();
System.out.println("\n------->图片写好了!");
}
} catch (SQLException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} finally {
DbClose.close(pstmt, conn);
}
}
public static void main(String[] args) {
LobRead lobread = new LobRead();
lobread.lobread();
}
}

在处理blob字段时候，由于直接处理的是二进制流，所以没啥问题。在处理clob字段的时候，由于数据库对clob是以字符的形式进行存储，这就有一个编码问题。本文虽然成功的插入读取了clob字段，但是还没有解决乱码问题，因为JDBC在获取到clob的时候，已经对其进行了编码，Reader reader = rs.getCharacterStream(1); 这就导致了编码的混乱，如果要彻底解决，还需要看看MySQL驱动的实现。通过非常规手段来解决。为了绕开此问题，可以将clob的数据存储为blog来操作，可以避免此问题。