數據庫: 兩種連接數據庫
??? //通過JDBC獲得數據庫連接
??? Class.forName("oracle.jdbc.driver.OracleDriver");
??? Connection con = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:testdb", "test", "test");
??? con.setAutoCommit(false);
??? Statement st = con.createStatement();
??? //插入一個空對象empty_blob()
??? st.executeUpdate("insert into TESTBLOB (ID, NAME, BLOBATTR) values (1, "thename", empty_blob())");
??? //鎖定數據行進行更新，注意“for update”語句
??? ResultSet rs = st.executeQuery("select BLOBATTR from TESTBLOB where ID=1 for update");
??? if (rs.next())
??? {
??????? //得到java.sql.Blob對象后強制轉換為oracle.sql.BLOB
??????? oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob("BLOBATTR");
??????? OutputStream outStream = blob.getBinaryOutputStream();
??????? //data是傳入的byte數組，定義：byte[] data
??????? outStream.write(data, 0, data.length);
??? }
??? outStream.flush();
??? outStream.close();
??? con.commit();
??? con.close();
（2）JNDI方式
??? //通過JNDI獲得數據庫連接
??? Context context = new InitialContext();
??? ds = (DataSource) context.lookup("ORA_JNDI");
??? Connection con = ds.getConnection();
??? con.setAutoCommit(false);
??? Statement st = con.createStatement();
??? //插入一個空對象empty_blob()
??? st.executeUpdate("insert into TESTBLOB (ID, NAME, BLOBATTR) values (1, "thename", empty_blob())");
??? //鎖定數據行進行更新，注意“for update”語句
??? ResultSet rs = st.executeQuery("select BLOBATTR from TESTBLOB where ID=1 for update");
??? if (rs.next())
??? {
??????? //得到java.sql.Blob對象后強制轉換為weblogic.jdbc.vendor.oracle.OracleThinBlob（不同的App Server對應的可能會不同）
??????? weblogic.jdbc.vendor.oracle.OracleThinBlob blob = (weblogic.jdbc.vendor.oracle.OracleThinBlob) rs.getBlob("BLOBATTR");
??????? OutputStream outStream = blob.getBinaryOutputStream();
??????? //data是傳入的byte數組，定義：byte[] data
??????? outStream.write(data, 0, data.length);
??? }
??? outStream.flush();
??? outStream.close();
??? con.commit();
??? con.close();
zqbchina 發表于: 2007-03-18 18:10:45