详解jdbc实现对CLOB和BLOB数据类型的操作

详解jdbc实现对CLOB和BLOB数据类型的操作

1、 读取操作

CLOB 

//获得数据库连接    
  Connection con = ConnectionFactory.getConnection();    
  con.setAutoCommit(false);    
  Statement st = con.createStatement();    
  //不需要“for update”    
  ResultSet rs = st.executeQuery("select CLOBATTR from TESTCLOB where ID=1");    
  if (rs.next())    
  {    
    java.sql.Clob clob = rs.getClob("CLOBATTR");    
    Reader inStream = clob.getCharacterStream();    
    char[] c = new char[(int) clob.length()];    
    inStream.read(c);    
    //data是读出并需要返回的数据，类型是String    
    data = new String(c);    
    inStream.close();    
  }    
  inStream.close();    
  con.commit();    
  con.close();   

BLOB

//获得数据库连接    
  Connection con = ConnectionFactory.getConnection();    
  con.setAutoCommit(false);    
  Statement st = con.createStatement();    
  //不需要“for update”    
  ResultSet rs = st.executeQuery("select BLOBATTR from TESTBLOB where ID=1");    
  if (rs.next())    
  {    
    java.sql.Blob blob = rs.getBlob("BLOBATTR");    
    InputStream inStream = blob.getBinaryStream();    
    //data是读出并需要返回的数据，类型是byte[]    
    data = new byte[input.available()];    
    inStream.read(data);    
    inStream.close();    
  }    
  inStream.close();    
  con.commit();    
  con.close();  

2、写入操作

CLOB

//获得数据库连接    
  Connection con = ConnectionFactory.getConnection();    
  con.setAutoCommit(false);    
  Statement st = con.createStatement();    
  //插入一个空对象empty_clob()    
  st.executeUpdate("insert into TESTCLOB (ID, NAME, CLOBATTR) values (1, "thename", empty_clob())");    
  //锁定数据行进行更新，注意“for update”语句    
  ResultSet rs = st.executeQuery("select CLOBATTR from TESTCLOB where ID=1 for update");    
  if (rs.next())    
  {    
    //得到java.sql.Clob对象后强制转换为oracle.sql.CLOB   
    oracle.sql.CLOB clob = (oracle.sql.CLOB) rs.getClob("CLOBATTR");    
    Writer outStream = clob.getCharacterOutputStream();    
    //data是传入的字符串，定义：String data    
    char[] c = data.toCharArray();    
    outStream.write(c, 0, c.length);    
  }    
  outStream.flush();    
  outStream.close();    
  con.commit();    
  con.close();  
  

BLOB

//获得数据库连接    
  Connection con = ConnectionFactory.getConnection();    
  con.setAutoCommit(false);    
  Statement st = con.createStatement();    
  //插入一个空对象empty_blob()    
  st.executeUpdate("insert into TESTBLOB (ID, NAME, BLOBATTR) values (1, "thename", empty_blob())");    
  //锁定数据行进行更新，注意“for update”语句    
  ResultSet rs = st.executeQuery("select BLOBATTR from TESTBLOB where ID=1 for update");    
  if (rs.next())    
  {    
    //得到java.sql.Blob对象后强制转换为oracle.sql.BLOB   
    oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob("BLOBATTR");    
    OutputStream outStream = blob.getBinaryOutputStream();    
    //data是传入的byte数组，定义：byte[] data   
    outStream.write(data, 0, data.length);    
  }    
  outStream.flush();    
  outStream.close();    
  con.commit();    
  con.close();    

3、读写CLOB/BLOB数据到文件

TNS：

# tnsnames.ora Network Configuration File: d:\oracle\product\10.2.0\client_1\NETWORK\ADMIN\tnsnames.ora  
 # Generated by Oracle configuration tools.  
 
 ORADB =  
   (DESCRIPTION =  
     (ADDRESS_LIST =  
       (ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.1.100)(PORT = 1521))  
     )  
     (CONNECT_DATA =  
       (SID = ORCL)  
     )  
   )  
 
 MYORCL =  
   (DESCRIPTION =  
     (ADDRESS_LIST =  
       (ADDRESS = (PROTOCOL = TCP)(HOST = 192.168.1.100)(PORT = 1521))  
     )  
     (CONNECT_DATA =  
       (SERVICE_NAME = myorcl)  
     )  
   )  

Table：

create table TEST_ORALOB  
 (  
   ID     VARCHAR2(20),  
   TSBLOB BLOB not null,  
   TSCLOB CLOB not null  
 ) 

测试代码：

package lavasoft.oralob.common;  
 
import oracle.sql.BLOB;  
 
import java.io.*;  
import java.sql.*;  
 
/**  
 * JDBC读写Oracle10g的CLOB、BLOB  
 *  
 */  
public class TestOraLob {  
 
     public static void main(String[] args) {  
         insertBlob();  
         queryBlob();  
     }  
 
     public static void insertBlob() {  
         Connection conn = DBToolkit.getConnection();  
         PreparedStatement ps = null;  
         try {  
             String sql = "insert into test_oralob (ID, TSBLOB, TSCLOB) values (?, ?, ?)";  
             ps = conn.prepareStatement(sql);  
             ps.setString(1, "100");  
             //设置二进制BLOB参数  
             File file_blob = new File("C:\\a.jpg");  
             InputStream in = new BufferedInputStream(new FileInputStream(file_blob));  
             ps.setBinaryStream(2, in, (int) file_blob.length());  
             //设置二进制CLOB参数  
             File file_clob = new File("c:\\a.txt");  
             InputStreamReader reader = new InputStreamReader(new FileInputStream(file_clob));  
             ps.setCharacterStream(3, reader, (int) file_clob.length());  
             ps.executeUpdate();  
             in.close();  
         } catch (IOException e) {  
             e.printStackTrace();  
         } catch (SQLException e) {  
             e.printStackTrace();  
         } finally {  
             DBToolkit.closeConnection(conn);  
         }  
     }  
 
     public static void queryBlob() {  
         Connection conn = DBToolkit.getConnection();  
         PreparedStatement ps = null;  
         Statement stmt = null;  
         ResultSet rs = null;  
         try {  
             String sql = "select TSBLOB from TEST_ORALOB where id ='100'";  
             stmt = conn.createStatement();  
             rs = stmt.executeQuery(sql);  
             if (rs.next()) {  
                 //读取Oracle的BLOB字段  
                 InputStream in = rs.getBinaryStream(1);  
                 File file = new File("c:\\a1.jpg");  
                 OutputStream out = new BufferedOutputStream(new FileOutputStream(file));  
                 byte[] buff1 = new byte[1024];  
                 for (int i = 0; (i = in.read(buff1)) > 0;) {  
                     out.write(buff1, 0, i);  
                 }  
                 out.flush();  
                 out.close();  
                 in.close();  
                 //读取Oracle的CLOB字段  
                 char[] buff2 = new char[1024];  
                 File file_clob = new File("c:\\a1.txt");  
                 OutputStreamWriter writer = new OutputStreamWriter(new FileOutputStream(file_clob));  
                 Reader reader = rs.getCharacterStream(1);  
                 for (int i = 0; (i = reader.read(buff2)) > 0;) {  
                     writer.write(buff2, 0, i);  
                 }  
                 writer.flush();  
                 writer.close();  
                 reader.close();  
             }  
             rs.close();  
             stmt.close();  
         } catch (IOException e) {  
             e.printStackTrace();  
         } catch (SQLException e) {  
             e.printStackTrace();  
         } finally {  
             DBToolkit.closeConnection(conn);  
         }  
     }  
 } 

注：如果是具体的字符串写入CLOB字段，简化写法：

//设置二进制CLOB参数   
 String xxx = "abcdefg";  
 ps.setCharacterStream(3, new StringReader(xxx), xxx.getBytes("GBK").length);   
 ps.executeUpdate();   
 in.close(); 

感谢阅读，希望能帮助到大家，谢谢大家对本站的支持，如有疑问请留言或者到本站社区交流讨论，感谢阅读，希望能帮助到大家，谢谢大家对本站的支持！

# jdbc实现对CLOB和BLOB数据类型操作  # JDBC  # 操作CLOB与BLOB  # JDBC实现Mysql自动重连机制的方法详解  # Java 使用JdbcTemplate 中的queryForList发生错误解决办法  # Java中JDBC实现动态查询的实例详解  # 基于spring boot 1.5.4 集成 jpa+hibernate+jdbcTemplate(  # BaseJDBC和CRUDDAO的写法实例代码  # 不需要  # 希望能  # 谢谢大家  # 转换为  # 如有  # 疑问请  # thename  # ORADB  # values  # executeUpdate  # insert  # getCharacterOutputStream  # toCharArray  # outStream  # oracle  # Writer  # blob  # getBlob 

相关文章： c++如何打印函数堆栈信息_c++ backtrace函数与符号名解析【方法】  制作ppt免费网站有哪些,有哪些比较好的ppt模板下载网站？  建站之星伪静态规则如何设置？  在线流程图制作网站手机版,谁能推荐几个好的CG原画资源网站么？  如何用搬瓦工VPS快速搭建个人网站？  如何通过.red域名打造高辨识度品牌网站？  微课制作网站有哪些,微课网怎么进？  建站主机助手选型指南：2025年热门推荐与高效部署技巧  已有域名如何快速搭建专属网站？  Python多线程使用规范_线程安全解析【教程】  如何通过主机屋免费建站教程十分钟搭建网站？  如何选择美橙互联多站合一建站方案？  如何通过VPS建站实现广告与增值服务盈利？  完全自定义免费建站平台：主题模板在线生成一站式服务  如何通过VPS建站无需域名直接访问？  如何制作算命网站,怎么注册算命网站？  建站之星2.7模板：企业网站建设与h5定制设计专题  c# F# 的 MailboxProcessor 和 C# 的 Actor 模型  济南网站建设制作公司,室内设计网站一般都有哪些功能？  python的本地网站制作,如何创建本地站点？  建站主机CVM配置优化、SEO策略与性能提升指南  如何快速搭建虚拟主机网站？新手必看指南  定制建站流程步骤详解：一站式方案设计与开发指南  详解jQuery停止动画——stop()方法的使用  网站制作培训多少钱一个月,网站优化seo培训课程有哪些？  黑客入侵网站服务器的常见手法有哪些？  淘宝制作网站有哪些,淘宝网官网主页？  网站制作外包价格怎么算,招聘网站上写的“外包”是什么意思？  如何在Golang中处理模块冲突_解决依赖版本不兼容问题  建站之星导航配置指南：自助建站与SEO优化全解析  重庆网站制作公司哪家好,重庆中考招生办官方网站？  图片制作网站免费软件,有没有免费的网站或软件可以将图片批量转为A4大小的pdf？  如何快速搭建FTP站点实现文件共享？  ppt制作免费网站有哪些,ppt模板免费下载网站？  IOS倒计时设置UIButton标题title的抖动问题  5种Android数据存储方式汇总  如何选择PHP开源工具快速搭建网站？  建站之星体验版：智能建站系统+响应式设计，多端适配快速建站  如何选择长沙网站建站模板？H5响应式与品牌定制哪个更优？  建站之星北京办公室：智能建站系统与小程序生成方案解析  如何用好域名打造高点击率的自主建站？  北京网站制作网页,网站升级改版需要多久？  建站ABC备案流程中有哪些关键注意事项？  高端建站三要素：定制模板、企业官网与响应式设计优化  怀化网站制作公司,怀化新生儿上户网上办理流程？  微网站制作教程,不会写代码，不会编程，怎么样建自己的网站？  网站app免费制作软件,能免费看各大网站视频的手机app？  如何快速生成橙子建站落地页链接？  制作表格网站有哪些,线上表格怎么弄？  大型企业网站制作流程,做网站需要注册公司吗？