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 block e.printStackTrace(); } catch (SQLException e) { // TODO Auto-generated catch block e.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"); }}

商人和应用程序图标