JDBC读写Oracle10g的CLOB、BLOB

Rainie999

package lavasoft.oralob.common;　　import oracle.sql.BLOB;
　　import java.io.*;
　　import java.sql.*;
　　/**
　　* JDBC读写Oracle10g的CLOB、BLOB
　　*
　　* @author: leizhimin 2010-5-26 21:12:55
　　*/

　　public>　　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>　　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);
　　}
　　}
　　}