Oracle Blob （二进制文件的读写）
import java.io.FileNotFoundException;import java.io.IOException;import java.io.InputStream;import java.io.OutputStream;import java.sql.Connection;import java.sql.SQLException;/* * 建数据表create table IMAGE_TAB(IMG_ID VARCHAR2(2),IMAGEBLOB)*//*** * @author wulihai */public class test { Connection conn = null; public test(){ conn=DBUtil.getConn(); } 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 image_tab(img_id,image) values(1,empty_blob())"; stmt = conn.createStatement(); stmt.executeUpdate(sql); String sql2 = "select image from image_tab where img_id = 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); } conn.commit(); if(is!=null){ is.close(); } if(os!=null){ os.close(); } System.out.println("写数据成功!"); } } private void read(String file) throws SQLException, IOException { java.sql.Statement stmt = null; java.sql.ResultSet rs = null; String sql = "select image from image_tab where img_id=1 "; stmt = conn.createStatement(); rs = stmt.executeQuery(sql); if(rs.next()){ oracle.sql.BLOB b = (oracle.sql.BLOB)rs.getBlob(1); 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(); } } } 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 image from image_tab where img_id=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{ test er=new test(); er.write("D:\\wulihai\\合影.jpg");//读取文件系统，写blob er.read("D:\\wulihai\\合影2.jpg");//读取blob，写文件系统 er.update("D:\\wulihai\\写给亲爱的猪.doc");//读取文件系统，更新blob er.read("D:\\wulihai\\写给亲爱的猪2.doc");//再次读取blob，写文件系统 } }
页:
[1]