详解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(); 

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

(0)

相关推荐

  • 基于spring boot 1.5.4 集成 jpa+hibernate+jdbcTemplate(详解)

    1.pom添加依赖 <!-- spring data jpa,会注入tomcat jdbc pool/hibernate等 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jpa</artifactId> </dependency> <dependency> <

  • Java 使用JdbcTemplate 中的queryForList发生错误解决办法

    Java 使用JdbcTemplate 中的queryForList发生错误解决办法          在开发项目中遇到JdbcTemplate 中的queryForList发生错误,很是头疼,在网上找了相关资料,可以帮忙解决,这里记录下, 一.问题描述:  查询时使用JdbcTemplate 中的queryForList发生错误,如下: 查询方法如下: jdbcTemplate.queryForList(selectSql.toString(), entityClass) 查询sql如下: s

  • BaseJDBC和CRUDDAO的写法实例代码

    我们首先看下BASEJDBC的写法实例: package com.dao; import java.sql.Connection; import java.sql.DriverManager; import java.sql.ResultSet; import java.sql.SQLException; import java.sql.Statement; import com.mysql.jdbc.Driver; public class BaseJDBC { // 表示你要操作的是哪种类型

  • Java中JDBC实现动态查询的实例详解

    一 概述 1.什么是动态查询? 从多个查询条件中随机选择若干个组合成一个DQL语句进行查询,这一过程叫做动态查询. 2.动态查询的难点 可供选择的查询条件多,组合情况多,难以一一列举. 3.最终查询语句的构成 一旦用户向查询条件中输入数据,该查询条件就成为最终条件的一部分. 二 基本原理 1.SQL基本框架 无论查询条件如何,查询字段与数据库是固定不变的,这些固定不变的内容构成SQL语句的基本框架,如 select column... from table. 2.StringBuilder形成D

  • JDBC实现Mysql自动重连机制的方法详解

    前言 本文主要给大家介绍的是关于JDBC实现Mysql自动重连机制的相关内容,分享出来供大家参考学习,下面来一起看看详细的介绍: 日志:using the Connector/J connection property 'autoReconnect=true' to avoid this problem com.mysql.jdbc.CommunicationsException: The last packet successfully received from the server was

  • 详解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 TES

  • 详解JDBC数据库链接及相关方法的封装

    详解JDBC数据库链接及相关方法的封装 使用的是MySQL数据库,首先导入驱动类,然后根据数据库URL和用户名密码获得数据的链接.由于使用的是MySQL数据库,它的URL一般为,jdbc:mysql://主机地址:端口号/库名. 下面是封装的具体类,用到了泛型和反射,不过还存在些问题,就是对使用的泛型对象有些限制,只能用于泛型类对象属性名与数据库表中列名相同的对象,而且初始化对象的方法必须为set+属性名的方法.本来想通过返回值类型,参数列表来确定该属性初始化方法的,然而可能是目前学到的还是太少

  • 详解如何实现在Vue中导入Excel文件

    目录 一.安装依赖 二.template中 三.script中js代码 以将此Excel导出为json数据为例 一.安装依赖 npm install file-saver --save npm install xlsx --save npm install script-loader --save-dev 二.template中 <span>导入表格</span> <input id="upload" type="file" @chan

  • 详解JDBC的概念及获取数据库连接的5种方式

    目录 一.JDBC概念 二.JDBC获取数据库连接的5种方式 方式一 方式二 方式三 方式四 方式五 一.JDBC概念 Java DataBase Connectivity(Java数据库连接技术) 它是将Java与SQL结合且独立于特定的数据库系统的应用程序编程接口(API-它是一种可用于执行SQL语句的JavaAPI,即由一组用Java语言编写的类与接口所组成) JDBC的设计目的: 它是一种规范,设计出来的主要目的是为了让各个数据库开发商为Java程序员提供标准的数据访问类和接口,使得独立

  • PHP实现对xml的增删改查操作案例分析

    本文实例讲述了PHP实现对xml的增删改查操作.分享给大家供大家参考,具体如下: 案例: index.php <?php header("content-type:text/html;charset=utf-8"); $xmldom = new DOMDocument(); $xmldom->load("demo2.xml"); //查询学生信息 $stus = $xmldom->getElementsByTagName("学生"

  • 详解pytest+Allure搭建方法以及生成报告常用操作

    目录 一.Allure搭建 1.下载Allure安装包 2.安装allure-pytest库 3.配置allure环境变量 4.检验allure安装成功 二.allure生成报告代码 1.allure指定用例严重等级: 2.allure指定标记的测试用例执行 3.生成报告代码 一.Allure搭建 1.下载Allure安装包 链接:https://github.com/allure-framework/allure2/releases 2.安装allure-pytest库 cmd命令行输入命令:

  • 一文详解Java中的Stream的汇总和分组操作

    目录 前言 一.查找流中的最大值和最小值 二.汇总 三.连接字符串 四.分组 1.分组 2.多级分组 3.按子组数据进行划分 后记 前言 在前面的文章中其实大家也已经看到我使用过collect(Collectors.toList()) 将数据最后汇总成一个 List 集合. 但其实还可以转换成Integer.Map.Set 集合等. 一.查找流中的最大值和最小值 static List<Student> students = new ArrayList<>(); ​ static

  • 详解Python开发语言中的基本数据类型

    目录 1.Python的基本数据类型 2.整数类型的概念以及使用 2.1.整数类型的概念 2.2.使用Python操作整数类型 3.浮点数类型的概念以及使用 4.布尔类型的概念以及使用 1.Python的基本数据类型 数据类型想必大家都知道是什么含义,指的是输入数据的类型,任何数据都有明确的数据类型,例如我们输入100,这个数据就是整数类型,输入7.7这个数据就是浮点数类型,输入字母.汉字.字母加汉字的数据都是字符串类型. Python基本数据类型有三种: 整数类型:数字 浮点数类型:带小数点的

  • 详解spring boot jpa整合QueryDSL来简化复杂操作

    前言 使用过spring data jpa的同学,都很清楚,对于复杂的sql查询,处理起来还是比较复杂的,而本文中的QueryDSL就是用来简化JPA操作的. Querydsl定义了一种常用的静态类型语法,用于在持久域模型数据之上进行查询.JDO和JPA是Querydsl的主要集成技术.本文旨在介绍如何使用Querydsl与JPA组合使用.JPA的Querydsl是JPQL和Criteria查询的替代方法.QueryDSL仅仅是一个通用的查询框架,专注于通过Java API构建类型安全的SQL查

  • 详解python执行shell脚本创建用户及相关操作

    用户发送请求,返回帐号和密码 ###利用框架flask 整体思路: # 目的:实现简单的登录的逻辑 # 1需要get和post请求方式 需要判断请求方式 # 2获取参数 # 3执行shell # 4如果判断都没问题,就返回结果 导包 ... 给模版传递消息 用flash --需要对内容加密,因此需要设置 secret_key , 做加密消息的混淆 app = Flask(__name__) app.secret_key = 'kingdomai' 使用wtf实现表单,需要自定义一个表单类 #va

随机推荐