日期:2014-05-16 浏览次数:20550 次
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) {