向oracle中插入图片和读取图片

秒速五厘米 2021-09-28 06:26 332阅读 0赞

# 向oracle中插入图片和读取图片 #

代码如下：

package demo;
    
    import java.io.BufferedInputStream;
    import java.io.BufferedOutputStream;
    import java.io.File;
    import java.io.FileInputStream;
    import java.io.FileOutputStream;
    import java.io.InputStream;
    import java.io.OutputStream;
    import java.io.PrintStream;
    import java.sql.Blob;
    import java.sql.Connection;
    import java.sql.DriverManager;
    import java.sql.ResultSet;
    import java.sql.SQLException;
    import java.sql.Statement;
    
    import com.mysql.fabric.xmlrpc.base.Data;
    
    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:mldn", "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 {
    	    	System.out.println("----insertPhoto");
    	        Connection conn = null;
    	    	int i = 0;
    	        Statement st = null;
    	        ResultSet rs = null;
    	        conn=this.getConnection();
    	         
    	        conn.setAutoCommit(false);//设置数据库为不自动提交，必须的一步
    	        st = conn.createStatement();//获取一个可以执行sql语句的对象
    	        
    	        i = st
    	                .executeUpdate("insert into IMAGE1 (\"id\",\"image\") values (2,'1')");
    	        
    	        rs = st
    	                .executeQuery("select \"image\" from IMAGE1 where \"id\"=(select max(\"id\") from IMAGE1) 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;
    	    }
    	
    	    /**
    	     * 从oracle中读取图片
    	     * 
    	     * @param path图片所在的路径
    	     * @return 整形 判断成功或失败
    	     */
    	    public int getImage(String path) throws Exception {
    	    	System.out.println("----getPhoto");
    	    	int j = 0;
    	        Statement  st = null;
    	        ResultSet rs = null;
    	        conn=this.getConnection();
    	        conn.setAutoCommit(false);//设置数据库为不自动提交，必须的一步
    	        st = conn.createStatement();//获取一个可以执行sql语句的对象
    	        rs =  st
    	                .executeQuery("select \"image\" from IMAGE1 where \"id\"=(select max(\"id\") from IMAGE1) ");
    	       if (rs.next()) {
    	    	   java.sql.Blob blob = rs.getBlob(1);
    	    	    InputStream ins = blob.getBinaryStream();
    	    	     //用文件模拟输出流
    	    	File file = new File("d:\\output.txt");
    	    	    OutputStream fout = new FileOutputStream(file);
    	    	     //下面将BLOB数据写入文件
    	    	     byte[] b = new byte[1024];
    	    	     int len = 0;
    	    	         while ( (len = ins.read(b)) != -1) {
    	    	           fout.write(b, 0, len);
    		} 
    	    	         //依次关闭
    	    	         j=2;
    	    	         fout.close();
    	    	         ins.close();
    	    	         conn.commit();
    	    	         conn.close();                
    	        }
    	        rs.close();
    	        st.close();
    	        return j;
    	    }
    
    	    public static void main(String[] args) throws Exception {
    	    	int out;
    	    	int out2;
    	        Test test=new Test();
    	       out= test.insertImage("e://psb.jpg");
    	       System.out.println(out);
    	       System.out.println("上传图片成功！");
    	       out2=test.getImage("e://psb.jpg");
    	       System.out.println(out2);
    	       System.out.println("读取图片成功！");
    	 
    	 
    	    }
    	 
    }

执行后如下图所示：

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hxeTE3MTkyMzkzMzc_size_16_color_FFFFFF_t_70][]

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hxeTE3MTkyMzkzMzc_size_16_color_FFFFFF_t_70 1][]

用画板打开下载的output.txt，就可以看到你下载的图片了

![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hxeTE3MTkyMzkzMzc_size_16_color_FFFFFF_t_70 2][]

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hxeTE3MTkyMzkzMzc_size_16_color_FFFFFF_t_70]: /images/20210923/6db848c789ac4f92985afb7922fba489.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hxeTE3MTkyMzkzMzc_size_16_color_FFFFFF_t_70 1]: /images/20210923/6a69b3b1640a4991bfd9d5b609d31ce2.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L2hxeTE3MTkyMzkzMzc_size_16_color_FFFFFF_t_70 2]: /images/20210923/8aab3c2099024987a2d2527a21a0797f.png