[大数据]JDBC四：操作Blob类型字段

操作Blob类型字段

1. 向数据表中插入Blob类型的字段

   Blobl类型的字段是一个文件，文件的传输需要进行IO流操作

    @Test
       public void testBlob() {
           Connection conn = null;
           PreparedStatement ps = null;
           try {
               // 1.创建连接
               conn = JdbcUtils.getConnection();
               // 2.预编译sql
               String sql = "insert into customers(cust_name, cust_email, cust_birth,photo) values(?,?,?,?)";
               ps = conn.prepareStatement(sql);
               // 3.填充占位符
               ps.setObject(1, "生肖虎");
               ps.setObject(2, "en@126.com");
               ps.setObject(3, "2000-01-01");
               // 3.1 Blob类型字段需要进行流操作
               File file = new File("C:\\Users\\NLC\\Desktop\\虎虎年画.jpg");
               FileInputStream fis = new FileInputStream(file);
               ps.setBlob(4,fis);
               // 4.执行sql
               ps.execute();
           } catch (Exception e) {
               e.printStackTrace();
           } finally {
               // 5.关闭资源
               JdbcUtils.closeResource(conn,ps);
           }
       }
   

2. 从数据表中读取Blob类型字段到本地

   @Test
       public void testBlobQuery() {
           Connection conn = null;
           PreparedStatement ps = null;
           ResultSet rs = null;
           try {
               // 1.创建连接
               conn = JdbcUtils.getConnection();
               // 2.预编译sql
               String sql = "select photo from customers where cust_name = ?";
               ps = conn.prepareStatement(sql);
               // 3.填充占位符
               ps.setObject(1, "生肖虎");
               // 4.执行sql，并返回结果集
               rs = ps.executeQuery();
               // 5.输出结果集
               if (rs.next()) {
                   // 5.1 读取Blob类型的字段
                   Blob blob = rs.getBlob("photo");
                   // 5.2 获取该文件的输入流is
                   InputStream is = blob.getBinaryStream();
                   // 5.3 创建输出流，指明输出后的文件
                   FileOutputStream fos = new FileOutputStream(new File("2022年画.jpg"));
                   // 5.4 文件读取及的写入操作
                   int len = 0;
                   byte[] bytes = new byte[1024];
                   while ((len = is.read(bytes)) != -1) {
                       fos.write(bytes,0,len);
                   }
               }
           } catch (Exception e) {
               e.printStackTrace();
           } finally {
               // 6.关闭资源
               JdbcUtils.closeResource(conn,ps,rs);
           }
       }
   

3. 关于 ”max_allowed_packet “ 的设置

   3.1 传输大于4M的文件时，会有如下报错

   

   3.2 在MySQL数据目录中的my.ini文件中进行配置

   

   参考博文：MySQL5.7及以上版本的my.ini所在目录

   3.3 重启MySQL服务