Java oracle (BLOB)文件操作

package com.able.demo;
import java.io.FileNotFoundException;
import java.io.IOException;
import java.io.InputStream;
import java.io.OutputStream;
import java.sql.Connection;
import java.sql.SQLException;
import com.able.dao.JdbcOracleUtil;
  
  
/*  
 * 建数据表 
create table ZIPDATA  
(  
  DATATYPE VARCHAR2(20),  
  DATACONTENT  BLOB  
)  
*/  
  
/**   
 *  
 * @author 刘勋  
 */  
public class TestZip {   
     Connection conn = null;   
        
   public TestZip(){   
    JdbcOracleUtil util = JdbcOracleUtil.getInstance();
    conn=util.getConnection();
   }   
   /**
    * 写入
    * @param file
    * @throws SQLException
    * @throws IOException
    */
   public void write(String file) throws SQLException, IOException{   
       java.sql.Statement stmt = null;    
         java.sql.Statement stmt2 = null;    
         java.sql.ResultSet rs = null;   
       conn.setAutoCommit(false);   
       String sql = "insert into ZIPDATA(DATATYPE,DATACONTENT) values('1',empty_blob())";   
       stmt = conn.createStatement();   
       stmt.executeUpdate(sql);   
          
       String sql2 = "select DATACONTENT from ZIPDATA where DATATYPE = '1' for update";   
       stmt2 = conn.createStatement();   
       rs = stmt2.executeQuery(sql2);   
       if(rs.next()){
        oracle.sql.BLOB b = (oracle.sql.BLOB)rs.getBlob(1);   
        java.io.OutputStream os = b.getBinaryOutputStream();   
        java.io.InputStream is = new java.io.FileInputStream(file);   
        int i = 0;
           while((i = is.read()) != -1){   
             os.write(i);   
           }   
       if(is!=null){   
           is.close();      
       }   
       if(os!=null){   
           os.close();      
       }   
       conn.commit();      
       System.out.println("写数据成功!");   
       }   
   }   
      
   /**
    * 读取
    * @param file
    * @throws SQLException
    * @throws IOException
    */
   private void read(String file) throws SQLException, IOException {   
         
      java.sql.Statement stmt = null;    
      java.sql.ResultSet rs = null;   
          
       String sql = "select * from mms_send_content where id=22321";   
       stmt = conn.createStatement();   
       rs = stmt.executeQuery(sql);   
       if(rs.next()){   
           oracle.sql.BLOB b = (oracle.sql.BLOB)rs.getBlob(5);   
           java.io.InputStream is = b.getBinaryStream();
           java.io.FileOutputStream fos = new java.io.FileOutputStream(file);
           int i = 0;   
           while((i = is.read())!= -1){   
            fos.write(i);   
           }   
           if(fos!=null){   
               fos.close();   
           }   
           if(is!=null){   
               is.close();      
           }   
              
       }  
       System.out.println("读取数据成功!"); 
    }   
      /**
       * 修改
       * @param file
       */
   private void update(String file) {   
       java.sql.Statement stmt = null;    
         java.sql.ResultSet rs = null;   
         OutputStream os=null;   
         InputStream is=null;   
         try {   
           conn.setAutoCommit(false);   
          stmt=conn.createStatement();   
          rs=stmt.executeQuery("select DATACONTENT from ZIPDATA where DATATYPE = '1' for update");   
            
           if(rs.next()){   
                oracle.sql.BLOB b = (oracle.sql.BLOB)rs.getBlob(1); 
                 os = b.getBinaryOutputStream();   
                 is = new java.io.FileInputStream(file);   
                int i = 0;   
                   while((i = is.read()) != -1){   
                     os.write(i);   
                   }   
               System.out.println("写数据成功!");   
               }   
            conn.commit();      
            } catch (SQLException e) {   
                e.printStackTrace();   
            } catch (FileNotFoundException e) {   
                e.printStackTrace();   
            } catch (IOException e) {   
                e.printStackTrace();   
            }finally{   
                 try {   
                   if(is!=null){   
                        is.close();   
                    }    
                   if(os!=null){   
                       os.close();      
                   }   
                  }catch (IOException e) {   
                        e.printStackTrace();   
                    }   
                   }   
                      
            }   
      
      
   public static void main(String args[]) throws SQLException, IOException{   
    TestZip er=new TestZip();
//       er.write("D:\\1.zip");//读取文件系统，写blob   
         er.read("D:\\2.zip");//读取blob，写文件系统   
//       er.update("D:\\wulihai\\写给亲爱的猪.doc");//读取文件系统，更新blob   
   }   
}