码迷,mamicode.com
首页 > 数据库 > 详细

JDBC 复习3 存取Oracle大数据 clob blob

时间:2017-11-29 12:07:08      阅读:196      评论:0      收藏:0      [点我收藏+]

标签:ack   inpu   sql   param   back   cti   for   错误   方法   

1 目录结构记得导包咯 mysql oracle
技术分享图片

2 代码,DBUtil工具类见前面的随笔博文


package dbex.mysql;

import java.io.BufferedReader;
import java.io.BufferedWriter;
import java.io.File;
import java.io.FileReader;
import java.io.FileWriter;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

import dbex.DBUtil;

/**
 * 
 * @ClassName: OrcClob 
 * @Description: Oracle 字符clob大数据练习
 * @author penny
 * @date 2017年11月29日 上午10:30:37 
 *
 */
public class OrcClob {

    
    Connection conn=null;
    PreparedStatement ppst = null;
    ResultSet rs= null;
    /**
     * @throws SQLException 
     * @Title: insertClob 
     * @Description: 插入 
     * @param     
     * @throws
     */
    void insertClob() throws Exception{
        
        conn = DBUtil.getConnection();//获取到连接对象,DBUtil 前面博文有
        boolean defaultCommit = conn.getAutoCommit();
        conn.setAutoCommit(false);//设置不自动提交
        String path =OrcClob.class.getClassLoader().getResource("big.txt").getPath();
        path =path.replace("%20", " ");//用20%替换空格 
        
        try {
            ppst = conn.prepareStatement("insert into clob values(?,empty_clob())");
            ppst.setInt(1, 125);
            ppst.execute();
            ppst = conn.prepareStatement("select clobcol from clob where id=? for update");
            ppst.setInt(1, 125);
            rs=ppst.executeQuery();
            if(rs.next()){
                oracle.sql.CLOB clob= (oracle.sql.CLOB)rs.getClob("clobcol");
                BufferedWriter bw = new BufferedWriter(clob.getCharacterOutputStream());
                BufferedReader br = new BufferedReader(new FileReader(new File(path)));
                int len;
                while((len=br.read())!=-1){
                    System.out.println("写入中");
                    bw.write(len);
                }
                br.close();
                bw.close();
            }
            //真正提交
            conn.commit();
            
        } catch (SQLException e) {
            e.printStackTrace();
            conn.rollback();
        }finally{
            conn.setAutoCommit(defaultCommit);
            DBUtil.closeAll(conn, ppst, rs);
        }
    }
    /**
     * @throws Exception 
     * 
     * @Title: readClob 
     * @Description: 读取大数据
     * @param     
     * @throws
     */
    void readClob() throws Exception{
        Connection conn = DBUtil.getConnection();
        PreparedStatement ppst =null;
        ResultSet rs= null;
        boolean defaultCommit = conn.getAutoCommit();
        try {
            ppst = conn.prepareStatement("select clobcol from clob where id =?");
            ppst.setInt(1, 125);
            rs=ppst.executeQuery();
            if(rs.next()){
                oracle.sql.CLOB clob= (oracle.sql.CLOB)rs.getClob("clobcol");
                BufferedReader br = new BufferedReader(clob.getCharacterStream());
                BufferedWriter bw = new BufferedWriter(new FileWriter("2.txt"));
                int len;
                while((len=br.read())!=-1){
                    System.out.println("读取中");
                    bw.write(len);
                }
                br.close();
                bw.close();
            }
            conn.commit();
        } catch (Exception e) {
            conn.rollback();
            throw(e);
        }finally{
            conn.setAutoCommit(defaultCommit);
            DBUtil.closeAll(conn, ppst, rs);
        }
    }
    
    public static void main(String[] args) throws Exception {
//      new OrcClob().insertClob();
        new OrcClob().readClob();
    }
}

3效果
技术分享图片
技术分享图片
技术分享图片

4总结:
通过JDBC操纵Oracle数据库的LOB字段,不外乎插入、修改、替换、读取四种方式,掌握起来并不难。观察上述程序对LOB类型字段的存取,我们可以看出,较之其它类型字段,有下面几个显著不同的特点:

  1、必须取消自动提交。

  存取操作开始前,必须用setAutoCommit(false)取消自动提交。其它类型字段则无此特殊要求。这是因为存取LOB类型字段时,通常要进行多次操作可以完成。不这样的话,Oracle将抛出“读取违反顺序”的错误。

  2、插入方式不同。

  LOB数据不能象其它类型数据一样直接插入(INSERT)。插入前必须先插入一个空的LOB对象,CLOB类型 的空对象为EMPTY_CLOB(),BLOB类型的空对象为EMPTY_BLOB()。之后通过SELECT命令查询得到先前插入的记录并锁定,继而将 空对象修改为所要插入的LOB对象。

  3、修改方式不同。

  其它类型的字段修改时,用UPDATE … SET…命令即可。而LOB类型字段,则只能用SELECT … FOR UPDATE命令将记录查询出来并锁定,然后才能修改。且修改也有两种改法:一是在原数据基础上的修改(即覆盖式修改),执行SELECT … FOR UPDATE后再改数据;二是替换(先将原数据清掉,再修改),先执行UPDATE命令将LOB字段之值设为空的LOB对象,然后进行第一种改法。建议使 用替换的方法,以实现与其它字段UPDATE操作后一样的效果。

  4、存取时应使用由数据库JDBC驱动程序提供的LOB操作类。

  对于Oracle数据库,应使用oracle.sql.CLOB和oracle.sql.BLOB。不使用由数据库JDBC驱动程序提供的LOB类时,程序运行时易于出现“抽象方法调用”的错误,这是因为JDBC所定义的java.sql.Clob与 java.sql.Blob接口,其中的一些方法并未在数据库厂家提供的驱动程序中真正实现。

  5、存取手段与文件操作相仿。

  对于BLOB类型,应用InputStream/OutputStream类,此类不进行编码转换,逐个字节存取。oracle.sql.BLOB类相应提供了getBinaryStream()和getBinaryOutputStream()两个方法,前一个 方法用于读取Oracle的BLOB字段,后一个方法用于将数据写入Oracle的BLOB字段。

  对于CLOB类型,应用Reader/Writer类,此类进行编码转换。oracle.sql.CLOB类相应 提供了getCharacterStream()和getCharacterOutputStream()两个方法,前一个方法用于读取Oracle的 CLOB字段,后一个方法用于将数据写入Oracle的CLOB字段。

  需要说明的是,为了大幅提高程序执行效率,对BLOB/CLOB字段的读写操作,应该使用缓冲操作类(带 Buffered前缀),即:BufferedInputStream,BufferedOutputStream,BufferedReader,BufferedWriter。 例程中全部使用了缓冲操作类。

JDBC 复习3 存取Oracle大数据 clob blob

标签:ack   inpu   sql   param   back   cti   for   错误   方法   

原文地址:http://www.cnblogs.com/humi/p/7919594.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!