|
import java.io.*;
import java.sql.*;
import oracle.jdbc.driver.*;
public class BOLUpdate {
public static void main(String args[]) throws SQLException {
Connection con = null;
Statement stm = null;
ResultSet rs = null;
try {
DriverManager.registerDriver(new oracle.jdbc.OracleDriver());
con = DriverManager.getConnection(
"jdbc:oracle:thin:@127.0.0.1:1521:ORCL","test","test");
// 自動コミットを無効にする。
con.setAutoCommit(false);
stm = con.createStatement();
// 新規レコードをinsert。blod_dataは、empty_blob()を使用して初期化する。
stm.executeUpdate("insert into blob_sample values('B01',empty_blob())");
// insertしたレコードをselectする。ロックを掛けるので、for updateを使用する。
rs = stm.executeQuery(
"select blob_id,blob_data from blob_sample where blob_id = 'B01' for update");
rs.next();
// 列「blob_data」のロケータからOutputStreamを取得する。
oracle.sql.BLOB bmp = ((OracleResultSet)rs).getBLOB("blob_data");
OutputStream outStream = bmp.getBinaryOutputStream();
// バイナリデータサイズを取得する
int size = bmp.getBufferSize(); char [] buffer = new char[size];
// DBにinsertするバイナリファイル「TEST.BMP」をオープン
File f = new File("TEST.BMP");
FileInputStream inStream = new FileInputStream(f);
int length = -1;
while ((length = inStream.read(buffer)) != -1) {
// 読み込んだバイナリファイルを列「blob_data」に書き込む
outStream.write(buffer,0,length);
}
inStream.close();
outStream.close();
// コミット
con.commit();
} catch (Exception ex) {
// 例外発生時はロールバック
con.rollback();
} finally {
if ( rs != null ) rs.close();
if ( stm != null ) stm.close();
if ( con != null ) con.close();
}
}
} |