Oracle中的Blob字段的处理

淳静3424

　　
　Oracle中的Bloc字段的处理较其他字段来说，会有一些特殊性。现就对在java和pl/sql下，Blob字段的处理和大家做一些交流。
　　下面，简单介绍一下Blob在以下两种环境中的写入处理，
　　u java环境
　　u PL/SQL环境
　　一、java环境
　　1、 Blob的插入操作
　　1) 插入一空的Blob。
　　2) 更新该纪录的Blob。
　　例子：
　　比如表结构如下：
　　CREATE TABLE Student (
　　Name VARCHAR2(30)，
　　Age Int，
　　Picture Blob);
　　i.插入一空的Blob。
　　String command=”INSERT INTO Student VALUES(？，？，？)”;
　　Connection conn=null;
　　PreparedStatement ps=null;
　　try
　　{
　　conn=…;
　　ps=conn. prepareStatement(command);
　　ps.setString(1，”ZhangSan”);
　　ps.setInt(2，20);
　　ps.setBlob(3， BLOB.empty_lob());
　　ps.executeUpdate();
　　…
　　ii.更新该纪录
　　…
　　byte[] data=null;
　　Connection conn=null;
　　Try
　　{
　　data=… //图片信息
　　conn=。。
　　ByteArrayInputStream in=new ByteArrayInputStream(data);
　　updateBlob(in， conn， “Student”，”Picture”，”Name”，”zhangsan”);
　　…
　　public static void updateBlob( InputStream instream，
　　Connection conn，
　　String table，
　　String blobColumn，
　　String keyColumn，
　　String keyValue)
　　throws SQLException， IOException
　　{
　　Statement stmt = null;
　　OracleResultSet rs = null;
　　BLOB blob = null;
　　boolean oldAutoCommit = conn.getAutoCommit();
　　StringBuffer sqlBuffer = new StringBuffer();
　　try {
　　conn.setAutoCommit(false);
　　sqlBuffer.append(“select ”);
　　sqlBuffer.append(blobColumn);
　　sqlBuffer.append(“ from ”);
　　sqlBuffer.append(table);
　　sqlBuffer.append(“ where ”);
　　sqlBuffer.append(keyColumn);
　　sqlBuffer.append(“=‘”);
　　sqlBuffer.append(keyValue);
　　//注意这里的”for update”
　　sqlBuffer.append(“’ for update ”);
　　stmt = conn.createStatement();
　　rs = (OracleResultSet) stmt.executeQuery(sqlBuffer.toString());
　　if (!rs.next())
　　{
　　rs.close();
　　stmt.close();
　　throw new IllegalArgumentException(
　　“no record found for keyValue： ‘” + keyValue + “’”);
　　}
　　blob = rs.getBLOB(1);
　　OutputStream outstream = blob.getBinaryOutputStream();
　　int bufferSize = blob.getChunkSize();
　　byte[] buffer = new byte[bufferSize];
　　int bytesRead = -1;
　　while ((bytesRead = instream.read(buffer)) != -1)
　　{
　　outstream.write(buffer， 0， bytesRead);
　　}
　　instream.close();
　　outstream.close();
　　rs.close();
　　stmt.close();
　　}
　　catch (SQLException e)
　　{
　　throw e;
　　}
　　catch (IOException e)
　　{
　　throw e;
　　}
　　finally {
　　conn.setAutoCommit(oldAutoCommit);
　　}
　　}
　　二、PL/SQL下
　　(例子表结构如一所示)
　　i.插入一空的Blob。
　　…
　　declare
　　bufferBlob BLOB;
　　data RAW(…)
　　…
　　INSERT INTO Student VALUES(‘zhangsan’， 20 ， empty_blob() );
　　…
　　ii.更新该纪录的Blob。
　　…
　　SELECT Picture INTO bufferBlob FROM Student WHERE Name=’zhangsan’ FOR UPDATE;
　　DBMS_LOB.OPEN(bufferBlob ， dbms_lob.lob_readwrite);
　　dbms_lob.write(bufferBlob ， utl_raw.length(data) ， data);