Oracle—使用JDBC导入Clob类型数据

╰半夏微凉° 2023-05-22 08:54 4阅读 0赞

package nio;
    
    import java.io.Writer;
    import java.sql.Connection;
    import java.sql.PreparedStatement;
    import java.sql.ResultSet;
    
    public class Test2 {
        public static Connection conn = ConnectionUntils.getInstance();
        public static PreparedStatement pst =null;
    
    	public static PreparedStatement pst2 =null;//用于插入Clob类型数据
        public static ResultSet rs = null;
           
    
    	public boolean save(Patient pat){
            boolean result = true;
    
            String sql = "insert into temp values(?,?,empty_clob())";
            //锁住该列，防止并发写入时候该字段同时被多次写入造成错误
            String sqlClob = "select temp_clob from temp t where t.name=? for update";
    
    		Writer writer = null;	
    
    		conn.setAutoCommit(false);//设置不自动提交，开启事务
    
    		pst = conn.prepareStatement(sql);
    
    		pst2= conn.prepareStatement(sqlClob);
    
            try {
                pst.setString(1,pat.getName());
                pst.setString(2,pat.getAge());
                pst.executeUpdate();
    
                
                pst2.setInt(1, pat.getName());
    
                rs = pst2.executeQuery();
    
                CLOB clob = null;
                if(rs.next()){
                    try {
                        clob = (CLOB) rs.getClob(1);
                        writer = clob.getCharacterOutputStream(); //拿到clob的字符输入流
                        writer.write(article.getContent());
                        writer.flush();
                        writer.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
                conn.commit();
            } catch (SQLException e) {
                result = false;
                try {
                    conn.rollback();
                } catch (SQLException e1) {
                    e1.printStackTrace();
                }
                e.printStackTrace();
            } finally {
                conn.setAutoCommit(true);//还原
                ConnectionUntils.close(rs, pst, conn);
            }
            return result;
        }
    
    }