热门标签 | HotTags
当前位置:  开发笔记 > 数据库 > 正文

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

这篇文章主要介绍了详解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(); 

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


推荐阅读
  • 本文详细介绍了如何使用libpq库与PostgreSQL后端建立连接。通过探讨PQconnectdb()函数的工作原理及其在实际应用中的使用方法,帮助读者理解并掌握建立高效、稳定的数据库连接的关键步骤。 ... [详细]
  • Windows服务与数据库交互问题解析
    本文探讨了在Windows 10(64位)环境下开发的Windows服务,旨在定期向本地MS SQL Server (v.11)插入记录。尽管服务已成功安装并运行,但记录并未正确插入。我们将详细分析可能的原因及解决方案。 ... [详细]
  • 数据库内核开发入门 | 搭建研发环境的初步指南
    本课程将带你从零开始,逐步掌握数据库内核开发的基础知识和实践技能,重点介绍如何搭建OceanBase的开发环境。 ... [详细]
  • 本文深入探讨 MyBatis 中动态 SQL 的使用方法,包括 if/where、trim 自定义字符串截取规则、choose 分支选择、封装查询和修改条件的 where/set 标签、批量处理的 foreach 标签以及内置参数和 bind 的用法。 ... [详细]
  • 使用C#开发SQL Server存储过程的指南
    本文介绍如何利用C#在SQL Server中创建存储过程,涵盖背景、步骤和应用场景,旨在帮助开发者更好地理解和应用这一技术。 ... [详细]
  • 本文探讨了适用于Spring Boot应用程序的Web版SQL管理工具,这些工具不仅支持H2数据库,还能够处理MySQL和Oracle等主流数据库的表结构修改。 ... [详细]
  • 本文详细介绍了如何通过多种编程语言(如PHP、JSP)实现网站与MySQL数据库的连接,包括创建数据库、表的基本操作,以及数据的读取和写入方法。 ... [详细]
  • 在当前众多持久层框架中,MyBatis(前身为iBatis)凭借其轻量级、易用性和对SQL的直接支持,成为许多开发者的首选。本文将详细探讨MyBatis的核心概念、设计理念及其优势。 ... [详细]
  • 在使用 DataGridView 时,如果在当前单元格中输入内容但光标未移开,点击保存按钮后,输入的内容可能无法保存。只有当光标离开单元格后,才能成功保存数据。本文将探讨如何通过调用 DataGridView 的内置方法解决此问题。 ... [详细]
  • 本文详细介绍了如何在 Linux 平台上安装和配置 PostgreSQL 数据库。通过访问官方资源并遵循特定的操作步骤,用户可以在不同发行版(如 Ubuntu 和 Red Hat)上顺利完成 PostgreSQL 的安装。 ... [详细]
  • 如何在PostgreSQL中查看数据表
    本文将指导您使用pgAdmin工具连接到PostgreSQL数据库,并展示如何浏览和查找其中的数据表。通过简单的步骤,您可以轻松访问所需的表结构和数据。 ... [详细]
  • 利用存储过程构建年度日历表的详细指南
    本文将介绍如何使用SQL存储过程创建一个完整的年度日历表。通过实例演示,帮助读者掌握存储过程的应用技巧,并提供详细的代码解析和执行步骤。 ... [详细]
  • 本文介绍了如何通过 Maven 依赖引入 SQLiteJDBC 和 HikariCP 包,从而在 Java 应用中高效地连接和操作 SQLite 数据库。文章提供了详细的代码示例,并解释了每个步骤的实现细节。 ... [详细]
  • 在使用SQL Server进行动态SQL查询时,如果遇到LIKE语句无法正确返回预期结果的情况,通常是因为参数传递方式不当。本文将详细探讨这一问题,并提供解决方案及相关的技术背景。 ... [详细]
  • 本文介绍如何通过创建替代插入触发器,使对视图的插入操作能够正确更新相关的基本表。涉及的表包括:飞机(Aircraft)、员工(Employee)和认证(Certification)。 ... [详细]
author-avatar
一介山夫1986_878
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有