pstmt =
conn.prepareStatement(
"INSERT INTO comp_adjunct_info(ADJUNCT_ID,ADJUNCT_NAME,BEWRITE,CREATE_TIME,CONTENT,ID) VALUES (?,?,?,sysdate, EMPTY_BLOB(),?)");
pstmt.setLong(1, sequence);
pstmt.setString(2, bib.getAdjunct_name());
pstmt.setString(3, bib.getBewrite());
pstmt.setLong(4, bib.getId());
pstmt.executeUpdate(); pstmt = conn.prepareStatement("SELECT CONTENT FROM comp_adjunct_info WHERE ADJUNCT_ID=? FOR UPDATE");
pstmt.setLong(1, sequence);
rs = pstmt.executeQuery();
while (rs.next()) {
oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob("CONTENT");
ByteArrayInputStream bin = new ByteArrayInputStream(bib.getB_content());
BufferedOutputStream out = new BufferedOutputStream(blob.getBinaryOutputStream(), 51200);
BufferedInputStream in = new BufferedInputStream(bin, 51200); while ((c = in.read()) != -1) {
out.write(c);
}
in.close();
out.close();
bin.close();
}