package test;import java.io.BufferedInputStream;
import java.io.FileInputStream;
import java.io.PrintStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;public class Test {private Connection conn;/*** 得到一个数据库的连接* * @return 返加Connection对象*/public Connection getConnection() {try {Class.forName("oracle.jdbc.driver.OracleDriver");conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:lyx", "scott", "tiger");} catch (ClassNotFoundException e) {// TODO Auto-generated catch blocke.printStackTrace();} catch (SQLException e) {// TODO Auto-generated catch blocke.printStackTrace();}return conn;}/*** 向表中插入图片* * @param path图片所在的路径* @return 整形 判断成功或失败*/public int insertImage(String path) throws Exception {int i = 0;Statement st = null;ResultSet rs = null;conn=this.getConnection();conn.setAutoCommit(false);//设置数据库为不自动提交，必须的一步st = conn.createStatement();//先插入一个空对象，这里我调用了Empty_BLOB()函数i = st.executeUpdate("insert into image (id,image) values (seq1.nextval,Empty_BLOB())");//以行的方式锁定rs = st.executeQuery("select image from image where id=(select max(id) from image) for update");if (rs.next()) {//得到流oracle.sql.BLOB blob = (oracle.sql.BLOB) rs.getBlob(1);//从得到的低级流构造一个高级流PrintStream ps = new PrintStream(blob.getBinaryOutputStream());BufferedInputStream bis = new BufferedInputStream(new FileInputStream(path));byte[] buff = new byte[1024];int n = 0;//从输入到输出while ((n = bis.read(buff)) != -1) {ps.write(buff, 0, n);}//清空流的缓存ps.flush();//关闭流，注意一定要关ps.close();bis.close();}rs.close();st.close();conn.close();return i;}public static void main(String[] args) throws Exception {Test test=new Test();test.insertImage("e:\\3.jpg");System.out.println("OK");}}