java oracle blob_java操作oracle中blob

package com.chinacreator.oraclelob;

import java.io.File;

import java.io.FileInputStream;

import java.io.FileNotFoundException;

import java.io.FileOutputStream;

import java.io.IOException;

import java.io.InputStream;

import java.io.OutputStream;

import java.io.UnsupportedEncodingException;

import java.sql.Connection;

import java.sql.DriverManager;

import java.sql.PreparedStatement;

import java.sql.ResultSet;

import java.sql.SQLException;

import oracle.sql.BLOB;

import com.creator.util.Constants;

public class TestBLOB {

public static void main(String[] args) {  //insertBlob();  //readBlob(); }   public static void insertBlob() {  String sql = "insert into mytest(id, images) values(1, EMPTY_BLOB())" ;  Connection conn = null;  PreparedStatement pstmt = null;  ResultSet rs = null;  int count = 0 ;  try {   Class.forName(Constants.DRIVER);   conn = DriverManager.getConnection(Constants.URL, Constants.DB_USER, Constants.DB_PSW);   //設定自動送出   conn.setAutoCommit(false);   pstmt = conn.prepareStatement(sql);   //pstmt.setString(1, "張三");      count = pstmt.executeUpdate();   //   conn.commit();      // 悲觀鎖鎖定需要更新行   //sql = "SELECT * FROM register ORDER BY ID FOR UPDATE";   sql = "select images from mytest where id=1 for update";   rs = conn.createStatement().executeQuery(sql);   //rs = conn.createStatement(ResultSet.TYPE_SCROLL_SENSITIVE,ResultSet.CONCUR_UPDATABLE).executeQuery(sql);      if(rs.next()){    //boolean toLast = rs.last();    //CLOB content = (CLOB)rs.getClob("content");                BLOB images = (BLOB)rs.getBlob("images");    //輸出流    OutputStream os = images.getBinaryOutputStream();    //輸入流    FileInputStream fis = new FileInputStream("E:\\temp\\a.jpg");    //入庫    byte[] temp = new byte[1024] ;     while((count=fis.read(temp)) != -1) {      os.write(temp, 0, count) ;      os.flush();     }     os.close();     fis.close();   }   conn.commit();   System.out.println("success!");  } catch (SQLException e) {   e.printStackTrace();  } catch(FileNotFoundException e){   e.printStackTrace();  } catch (UnsupportedEncodingException e) {   e.printStackTrace();  } catch (ClassNotFoundException e) {   e.printStackTrace();  }catch (IOException e) {   e.printStackTrace();  }finally {   if(rs != null) {    try {     rs.close();    } catch (SQLException e) {     e.printStackTrace();    } finally {     if(pstmt != null) {      try {       pstmt.close();      } catch (SQLException e) {       e.printStackTrace();      } finally {       if(conn != null) {        try {         conn.close();        } catch (SQLException e) {         e.printStackTrace();        }        }      }     }    }   }  } }   public static void readBlob() {  Connection conn = null;  PreparedStatement pstmt = null;  ResultSet rs = null;  String sql = "select images from mytest where id=3";  int count = 0 ;    try {   Class.forName(Constants.DRIVER);   conn = DriverManager.getConnection(Constants.URL, Constants.DB_USER, Constants.DB_PSW);   //設定自動送出   conn.setAutoCommit(false);   pstmt = conn.prepareStatement(sql);   rs = pstmt.executeQuery() ;      if(rs != null) {    while(rs.next()) {     //資料庫-->本地檔案     BLOB images = (BLOB)rs.getBlob("images");     //得到一個輸入流     InputStream is = images.getBinaryStream();     //得到一個輸出流     FileOutputStream fos = new FileOutputStream(new File("e:\\temp\\temp.txt"));     byte[] temp = new byte[1024] ;     while((count = is.read(temp)) != -1) {      fos.write(temp, 0, count);      fos.flush();     }     //fos.flush();     fos.close();     is.close();    }   }   conn.commit();   System.out.println("success!");  } catch (ClassNotFoundException e) {   e.printStackTrace();  } catch (SQLException e) {   e.printStackTrace();  }catch(FileNotFoundException e){   e.printStackTrace();  } catch (IOException e) {   e.printStackTrace();  } finally {   if(rs != null) {    try {     rs.close();    } catch (SQLException e) {     e.printStackTrace();    } finally {     if(pstmt != null) {      try {       pstmt.close();      } catch (SQLException e) {       e.printStackTrace();      } finally {       if(conn != null) {        try {         conn.close();        } catch (SQLException e) {         e.printStackTrace();        }        }      }     }    }   }  } }}