加载中…
个人资料
寒影
寒影
  • 博客等级:
  • 博客积分:0
  • 博客访问:1,200
  • 关注人气:4
  • 获赠金笔:0支
  • 赠出金笔:0支
  • 荣誉徽章:
正文 字体大小:

使用Spring JdbcTemplate实现CLOB和BLOB的存取

(2016-09-02 18:22:48)

所谓CLOB 可以看成是文本文,所谓BLOB可以看成是图片文件

假设在mysql数据库上有以下表:

http://images.csdn.net/syntaxhighlighting/OutliningIndicators/None.gifJdbcTemplate实现CLOB和BLOB的存取" />create table test(id int primary key,txt TEXT,image BLOB);

 假设现在分别读取一个文字文件和二进制文件,并想将之存储到数据库中,则可以使用JdbcTemplate 如:

http://images.csdn.net/syntaxhighlighting/OutliningIndicators/None.gifJdbcTemplate实现CLOB和BLOB的存取" />
[java] view plain copy
 print?
  1. final File binaryFile=new File("wish.jpg");  
  2. final File txtFile=new File("test.txt");  
  3. final InputStream is=new FileInputStream(binaryFile);  
  4. final Reader reader=new FileReader(txtFile);  
  5. JdbcTemplate jdbcTemplate=new JdbcTemplate(dataSource);  
  6. final LobHandler lobHandler=new DefaultLobHandler();  
  7. jdbcTemplate.execute("insert into test (txt,image) values (?,?)" 
  8.                                       new AbstractLobCreatingPreparedStatementCallBack(lobHandler){   
  9.                                               protected void setValues(PreoparedStatement pstmt,LobCreator lobCreator){  
  10.                                                      lobCreator.setClobAsCharactoerStream(pstmt,1,reader,(int)textFile.length());  
  11.                                                      lobCreator.setBlobAsBinaryStream(pstmt,2,is,(int)binaryFile.length());  
  12.                                                 
  13.                                       });  
  14. reader.close();  
  15. is.close();  
 

在建立AbstractLobCreatingPreparedStatementCallBack对象时候,需要一个lobHandler实例, 对于一般的数据库,采用DefaultLobHandler足以,对于Oracle特定的lob处理,可以使用OracleLobHandler

如果是讲数据从数据库中读取出来并另存在未见,可以使用下面的程序

[c-sharp] view plain copy
 print?
  1. final Writer writer=new FileWriter("test_back.txt");  
  2. final OutputStream os=new FileOutputStream(new File("wish_bak.jpg"));  
  3. jdbcTemplate.query("select txt,image from test where id=?,new AbstractLobStreamingResultSetExtractor(){  
  4.                                             protected void streamData(ResultSet rs) throws SQLException,IOException,DataAccessException{  
  5.                                                   FileCopyUtils.copy(lobHandler.getClobAsCharacterStream(rs,1),writer);  
  6.                                                   FileCopyUtils.copy(lobHandler.getBlobAsBinaryStream(rs,2),os);  
  7.                                              
  8.                                 });  
  9. writer.close();  
  10. os.close();  
 

这里使用FileCopyUtils的copy方法,将lobHandler取得的串流直接转接给文件输出FileWriter,FileOutputStream对象

0

阅读 收藏 喜欢 打印举报/Report
  

新浪BLOG意见反馈留言板 欢迎批评指正

新浪简介 | About Sina | 广告服务 | 联系我们 | 招聘信息 | 网站律师 | SINA English | 产品答疑

新浪公司 版权所有