oracle存储大文本clob、blob

package cn.itcast.web.oracle.util;

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.Statement;

public class JdbcUtil {
    private static String driver = "oracle.jdbc.driver.OracleDriver";
    //1521是主端口，也可能是其它端口去连接oracle数据库
    private static String url = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
    private static String username = "scott";
    private static String password = "friends";
    private static Connection conn;
    private static Statement stmt;
    private static ResultSet rs;
    //注册数据库驱动
    static{
        try {
            Class.forName(driver);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException("oracle驱动注册失败");
        }
    }
    //获取数据库连接
    public static Connection getConnection(){
        Connection conn = null;
        try {
            conn = DriverManager.getConnection(url,username,password);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException("oracle连接获取失败");
        }
        return conn;
    }
    //关闭连接对象
        public static void close(Connection conn){
            if(conn!=null){
                try {
                    conn.close();
                } catch (Exception e) {
                    e.printStackTrace();
                    throw new RuntimeException("oracle连接关闭失败");
                }
            }
        }
        public static void close(Statement stmt){
            if(stmt!=null){
                try {
                    stmt.close();
                } catch (Exception e) {
                    e.printStackTrace();
                    throw new RuntimeException("oracle连接关闭失败");
                }
            }
        }
        public static void close(ResultSet rs){
            if(rs!=null){
                try {
                    rs.close();
                } catch (Exception e) {
                    e.printStackTrace();
                    throw new RuntimeException("oracle连接关闭失败");
                }
            }
        }
}

package cn.itcast.web.oracle.dao;

import java.io.File;
import java.io.FileInputStream;
import java.io.FileOutputStream;
import java.io.FileReader;
import java.io.FileWriter;
import java.io.InputStream;
import java.io.OutputStream;
import java.io.Reader;
import java.io.Writer;
import java.net.URL;
import java.sql.Connection;
import java.sql.PreparedStatement;
import java.sql.ResultSet;

import org.junit.Test;

import cn.itcast.web.oracle.util.JdbcUtil;

//Java测试oracle数据库存取大对象
/*
create table test_clob(
    id number primary key,
    content clob not null
);
create table test_blob(
    id number primary key,
    content blob not null 
);
*/
public class LobDao {
    //测试clob对象（存）
    @Test
    public void saveClobToOracle() throws Exception{
        Connection conn = JdbcUtil.getConnection();
        String sql = "insert into test_clob(id,content) values(?,?)";
        PreparedStatement pstmt = conn.prepareStatement(sql);
        pstmt.setInt(1,1);
        //加载文件
        URL url = LobDao.class.getClassLoader().getResource("cn/itcast/web/oracle/db/xx.txt");
        String path = url.getPath();
        File file = new File(path);
        //获取文件的reader字符流对象
        Reader reader = new FileReader(file);
        //为第二个?占位符设置值
        pstmt.setCharacterStream(2,reader,(int)file.length());
        int i = pstmt.executeUpdate();
        System.out.println(i>0?"操作成功":"操作失败");
        reader.close();
        JdbcUtil.close(pstmt);
        JdbcUtil.close(conn);
    }
    //测试clob对象（取）
    @Test
    public void getClobFormOracle() throws Exception{
        Connection conn = JdbcUtil.getConnection();
        String sql = "select content from test_clob where id = 1";
        PreparedStatement pstmt = conn.prepareStatement(sql);
        ResultSet rs = pstmt.executeQuery();
        Reader reader = null;
        Writer writer = null;
        while(rs.next()){
            reader = rs.getCharacterStream("content");
            writer = new FileWriter("d:/copy_xx.txt");
            int len = 0;
            char[] cuf = new char[1024];
            while((len = reader.read(cuf))>0){
                writer.write(cuf,0,len);
            }
        }
        reader.close();
        writer.close();
        JdbcUtil.close(rs);
        JdbcUtil.close(pstmt);
        JdbcUtil.close(conn);
    }
    //测试blob对象（存）
    @Test
    public void saveBlobToOracle() throws Exception{
        Connection conn = JdbcUtil.getConnection();
        String sql = "insert into test_blob(id,content) values(?,?)";
        PreparedStatement pstmt = conn.prepareStatement(sql);
        pstmt.setInt(1,1);
        
        URL url = LobDao.class.getClassLoader().getResource("cn/itcast/web/oracle/db/image.jpg");
        String path = url.getPath();
        File file = new File(path);
        InputStream inputStream = new FileInputStream(file);
        pstmt.setBinaryStream(2,inputStream,(int)file.length());
        
        int i = pstmt.executeUpdate();
        System.out.println(i>0?"操作成功":"操作失败");
        
        inputStream.close();
        JdbcUtil.close(pstmt);
        JdbcUtil.close(conn);
    } 
    //测试blob对象（取）
    @Test
    public void getBlobFromOracle() throws Exception{
        Connection conn = JdbcUtil.getConnection();
        String sql = "select content from test_blob where id = 1";
        PreparedStatement pstmt = conn.prepareStatement(sql);
        ResultSet rs = pstmt.executeQuery();
        InputStream is = null;
        OutputStream os = null;
        while(rs.next()){
            is = rs.getBinaryStream("content");
            os = new FileOutputStream("d:/copy_image.jpg");
            byte[] buf = new byte[1024];
            int len = 0;
            while((len=is.read(buf))>0){
                os.write(buf,0,len);
            }
        }    
        is.close();
        os.close();
        JdbcUtil.close(rs);
        JdbcUtil.close(pstmt);
        JdbcUtil.close(conn);
    } 
}

文本：CLOB(Character)
多媒体：BLOB(Binary)