使用存儲過程實現oracle存圖片的方法

Oracle存圖片是我們經常需要實現的功能，下面就教您一個使用存儲過程實現Oracle存圖片的方法，如果您在Oracle存圖片方面遇到過問題，不妨一看。

要在Oracle存圖片 用blob類型，首先在數據庫裡建立：

--連接到管理員

conn sys/tbsoft as sysdba; 

--為scott用戶授權

grant create any directory to scott; 

--回到scott用戶

conn scott/tiger; 

--創建存儲圖片的表

CREATE TABLE IMAGE_LOB (T_ID VARCHAR2 (5) NOT NULL,T_IMAGE BLOB NOT NULL); 

--創建存儲圖片的目錄

CREATE OR REPLACE DIRECTORY IMAGES AS 'C:\picture'; 

--在c：下自己建一個叫picture的文件夾

CREATE OR REPLACE PROCEDURE IMG_INSERT (TID VARCHAR2,FILENAME VARCHAR2) AS 

F_LOB BFILE;--文件類型

B_LOB BLOB;

BEGIN     
iNSERT INTO IMAGE_LOB (T_ID, T_IMAGE)     
VALUES (TID,EMPTY_BLOB ()) RETURN T_IMAGE INTO B_LOB    

--插入空的blob

F_LOB:= BFILENAME ('IMAGES', FILENAME); 

--獲取指定目錄下的文件

DBMS_LOB.FILEOPEN(F_LOB, DBMS_LOB.FILE_READONLY); 

--以只讀的方式打開文件

DBMS_LOB.LOADFROMFILE (B_LOB, F_LOB,DBMS_LOB.GETLENGTH (F_LOB)); 

--傳遞對象

DBMS_LOB.FILECLOSE (F_LOB); 

--關閉原始文件

COMMIT;  
END;  
/  

--在C:\picture下放一張圖片1.gif

--將該圖片存入表

call IMG_INSERT('1','1.gif'); 

然後創建一個web項目 連接數據庫後 創建一個BlobDAO類 用來取出表中的blob類型圖片

public class BlobDAO {  
    private static final BlobDAO instance = new BlobDAO();  
    private Connection conn = null;  
    private BlobDAO() {  
    }  
    public static BlobDAO getInstance() {  
        return instance;  
    }  
    private void initConn() {  
        conn = DBAccess.getInstance().getConn();  
    }  
    public byte[] getImage(String imgname) {  
        BufferedInputStream ins;//取得BLOB的IO流  
        byte[] bt = null;  
        initConn();  
        Blob bo = null;  
        PreparedStatement ps = null;  
        ResultSet rs = null;  
        String sql = "select T_IMAGE from IMAGE_LOB where t_id=?";  
        try {  
              ps = conn.prepareStatement(sql);  
              ps.setString(1, imgname);  
              rs = ps.executeQuery();  
              if (rs.next()) {  
                  bo = rs.getBlob("T_IMAGE");  
                  try {  
                      ins = new BufferedInputStream(bo.getBinaryStream());  
                      int bufferSize = (int) bo.length();//取得BLOB的長度  
                      bt = new byte[bufferSize];  
                      try {  
                            ins.read(bt, 0, bufferSize);  
                      } catch (IOException e) {  
                            // TODO Auto-generated catch block  
                            e.printStackTrace();  
                      }  
                      //建立字節緩存  
                  } catch (SQLException e) {  
                      // TODO Auto-generated catch block  
                      e.printStackTrace();  
                  }  
              }  
        } catch (SQLException e) {  
              // TODO Auto-generated catch block  
              e.printStackTrace();  
        } finally {  
              try {  
                  rs.close();  
                  ps.close();  
                  conn.close();  
              } catch (SQLException e) {  
                  // TODO Auto-generated catch block  
                  e.printStackTrace();  
              }  
        }  
        return bt;  
    }  
}  
 

在action裡面調用getImage()方法並顯示圖片在頁面上

public ActionForward execute(ActionMapping mapping, ActionForm form,  
              HttpServletRequest request, HttpServletResponse response) {  
        // TODO Auto-generated method stub  
             BlobDAO blobDAO = BlobDAO.getInstance();  
        byte[] bs = blobDAO.getImage("1");  
 
        try {  
 
              response.getOutputStream().write(bs);  
        } catch (IOException e) {  
              // TODO Auto-generated catch block  
              e.printStackTrace();  
        }  
        return null;  
    }  

添加圖片到數據庫

請在c盤下放入圖片--c:\\4.gif

public void savaImg(String imgId) {  
           //傳的是存入數據庫圖片的id  
           initConn();  
           Statement st = null;  
           BLOB blob = null; //圖片類型  
           OutputStream outputStream = null; //輸出流  
           File file = null; //文件  
           InputStream inputStream = null; //輸入流  
           ResultSet rs = null;  
           try {  
                 conn.setAutoCommit(false); //事物由程序員操作  
                 st = conn.createStatement();  
                 st.executeQuery("insert into IMAGE_LOB values('"+ imgId +"',empty_blob())");  
                 rs = st.executeQuery("select T_IMAGE from IMAGE_LOB where t_id='"+ imgId +"' for update");  
                 if (rs.next()) {  
                       blob = (BLOB) rs.getBlob(1);  
                       outputStream = blob.getBinaryOutputStream();  
                       file = new File("c:\\4.gif");  
                       inputStream = new FileInputStream(file);  
                       byte[] b = new byte[blob.getBufferSize()];  
                       int len = 0;  
                       while ((len = inputStream.read(b)) != -1) {  
                             System.out.println(len);  
                             outputStream.write(b, 0, len);  
                       }  
                 }  
           } catch (SQLException e) {  
                 // TODO Auto-generated catch block  
                 e.printStackTrace();  
           } catch (FileNotFoundException e) {  
                 // TODO Auto-generated catch block  
                 e.printStackTrace();  
           } catch (IOException e) {  
                 // TODO Auto-generated catch block  
                 e.printStackTrace();  
           } finally {  
                 try {  
                       inputStream.close();  
                       outputStream.flush();  
                       outputStream.close();  
                       rs.close();  
                       st.close();  
                       conn.commit();  
                       conn.close();  
                 } catch (IOException e) {  
                       // TODO Auto-generated catch block  
                       e.printStackTrace();  
                 } catch (SQLException e) {  
                       // TODO Auto-generated catch block  
                       e.printStackTrace();  
                 }  
           }  
     }