插入oracle blob

package db;

import java.io.BufferedInputStream;    
import java.io.FileInputStream;    
import java.io.PrintStream;    
import java.sql.Connection;    
import java.sql.DriverManager;    
import java.sql.ResultSet;    
import java.sql.SQLException;    
import java.sql.Statement;    
   
public class Test {    
    private Connection conn;    
   
    /**   
     * 得到一个数据库的连接   
     *    
     * @return 返加Connection对象   
     */   
    public Connection getConnection() {    
        try {    
            Class.forName("oracle.jdbc.driver.OracleDriver");    
            conn = DriverManager.getConnection(    
                    "jdbc:oracle:thin:@IP地址:1521:实例", "用户名", "密码");    
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {    
            e.printStackTrace();
        }    
        return conn;    
    }    
   
    /**   
     * 向表中插入二进制数据
     * @param path数据所在的路径   
     * @return 成功或失败   
     */   
    public int insertImage(String path) throws Exception {    
        int i = 0;    
        Statement st = null;
        ResultSet rs = null;
        conn=this.getConnection();
            
        conn.setAutoCommit(false);//设置数据库为不自动提交，必须   
        st = conn.createStatement();    
        //先插入一个空对象，这里插入Empty_BLOB()函数    stuid text
        i = st.executeUpdate("insert into testbo(stuid,text) values(1,Empty_BLOB())");    
        //进行行级锁
        rs = st.executeQuery("select text from testbo where stuid=1 for update");    
        if (rs.next()) {
            //得到流
            oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob(1);    
            //从得到的低级流构造一个高级流    
            PrintStream ps = new PrintStream(blob.getBinaryOutputStream());    
            BufferedInputStream bis = new BufferedInputStream(    
                    new FileInputStream(path));
            byte[] buff = new byte[512];
            int n = 0;
            //从输入到输出    
            while ((n = bis.read(buff)) != -1) {
                ps.write(buff, 0, n);
            }    
            //清空流的缓存
            ps.flush();    
            //关闭流，注意一定要关
            ps.close();
            bis.close();
        }
        rs.close();
        st.close();
        conn.close();
        return i;
    }
   
    public static void main(String[] args) throws Exception {    
        Test test=new Test();    
        test.insertImage("C:/MyDocuments/kettledemo/ANKG.SN.2008309124211.00.BHZ");
        System.out.println("YES");    
    }    
}