import oracle.jdbc.driver.oracleresultset;
import oracle.sql.blob;
import java.sql.drivermanager;
import java.sql.connection;
import java.sql.resultset;
import java.io.*;
import java.sql.statement;
public class testblob {
public static void main(string args[]) {
try {
drivermanager.registerdriver(new oracle.jdbc.driver.oracledriver());
connection conn = drivermanager.getconnection("jdbc:oracle:thin:@java:1521:eteda", "system", "manager");
conn.setautocommit(false);
statement stmt = conn.createstatement();
stmt.execute("insert into testblob values (empty_blob())");
resultset rset = stmt.executequery("select tt from testblob for update");
blob blob = null;
while (rset.next()) {
blob = ((oracleresultset) rset).getblob(1);
system.out.println(blob.length());
}
file binaryfile = new file("c:\\meilin.xml");
system.out.println("meilin.xml length = " + binaryfile.length());
fileinputstream instream = new fileinputstream(binaryfile);
outputstream outstream = blob.getbinaryoutputstream();
int chunk = blob.getchunksize();
system.out.println("chunk size = " + chunk);
byte[] buffer = new byte[chunk];
int length = -1;
while ((length = instream.read(buffer)) != -1)
outstream.write(buffer, 0, length);
instream.close();
outstream.close();
conn.commit();
} catch (exception e) {
system.out.println(e.tostring());
}
}
}
