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

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。 例程中全部使用了缓冲操作类。