JDBC之Blob类型使用的实现

create table `movie` (
 `movieid` int(11) not null auto_increment,
 `moviename` varchar(30) default null,
 `poster` mediumblob,
 primary key (`movieid`)
) engine=innodb default charset=utf8;

public class BlobTest {
    // 向Movie表中插入数据
    public void insertMovie(String moviename, InputStream is){
        // 声明数据库连接对象，用于与数据库建立连接
        Connection conn = null;
        // 声明预编译语句对象，用于执行 SQL 语句
        PreparedStatement ps = null;
        try{
            // 获取连接
            // 调用 JdbcUtils 工具类的 getConnection 方法获取数据库连接
            conn = JdbcUtils.getConnection();
            // 创建PreparedStatement对象
            // 使用预编译的方式创建 SQL 插入语句，避免 SQL 注入风险
            ps = conn.prepareStatement("insert into movie values(default,?,?)");
            // 绑定参数
            // 为 SQL 语句中的第一个占位符绑定电影名称参数
            ps.setString(1,moviename);
            // 为 SQL 语句中的第二个占位符绑定输入流参数，用于插入二进制数据（如图片）
            ps.setBlob(2,is);
            // 执行SQL
            // 执行插入操作，并返回受影响的行数
            ps.executeUpdate();
        }catch(Exception e){
            // 若发生异常，打印异常堆栈信息，方便调试
            e.printStackTrace();
        }finally{
            // 调用 JdbcUtils 工具类的 closeResource 方法关闭预编译语句和数据库连接，释放资源
            JdbcUtils.closeResource(ps,conn);
        }
    }
    public static void main(String[] args) throws FileNotFoundException {
        // 创建 BlobTest 类的实例对象
        BlobTest bt = new BlobTest();
        // 创建读取文件的IO流
        // 创建一个文件输入流，用于读取指定路径下的图片文件
        InputStream is = new FileInputStream(new File("d:/1.jpg"));
        // 调用 insertMovie 方法，插入电影名称和图片数据到数据库
        bt.insertMovie("战狼",is);
    }
}

public void selectMovieById(int movieid){
     // 声明数据库连接对象，用于与数据库建立连接
     Connection conn =null;
     // 声明预编译语句对象，用于执行 SQL 语句
     PreparedStatement ps = null;
     // 声明结果集对象，用于存储查询结果
     ResultSet rs = null;
     try{
      // 获取连接
       conn =JdbcUtils.getConnection();
       // 创建PreparedStatement对象
       ps = conn.prepareStatement("select * from movie where movieid = ?");
       // 绑定参数
       // 为 SQL 语句中的第一个占位符绑定影片 ID 参数
       ps.setInt(1,movieid);
       // 执行sql
       // 执行查询操作，将查询结果存储在 ResultSet 对象中
       rs = ps.executeQuery();
       // 遍历结果集
       while(rs.next()){
         // 从结果集中获取 movieid 列的值并赋值给变量 id
         int id = rs.getInt("movieid");
         // 从结果集中获取 moviename 列的值并赋值给变量 name
         String name = rs.getString("moviename");
         // 打印影片 ID 和影片名称
         System.out.println(id+" "+name);
         //获取blob类型的数据
         // 从结果集中获取 poster 列的 Blob 类型数据
         Blob blob = rs.getBlob("poster");
         //获取能够从Blob类型的列中读取数据的IO流
         // 从 Blob 对象中获取二进制输入流，用于读取图片数据
         InputStream is = blob.getBinaryStream();
         // 创建文件输出字节流对象
         // 创建一个文件输出流，用于将图片数据写入到本地文件
         OutputStream os = new FileOutputStream(id+"_"+name+".jpg");
         //操作流完成文件的输出处理
         // 定义一个字节数组作为缓冲区，用于存储从输入流读取的数据
         byte[] buff = new byte[1024];
         // 用于存储每次从输入流读取的字节数
         int len;
         // 循环从输入流读取数据到缓冲区，直到读取完所有数据
         while((len = is.read(buff)) != -1){
           // 将缓冲区中的数据写入到输出流
           os.write(buff,0,len);
         }
         // 刷新输出流，确保所有数据都被写入到文件
         os.flush();
         // 关闭输入流，释放资源
         is.close();
         // 关闭输出流，释放资源
         os.close();
       }
     }catch(Exception e){
       // 若发生异常，打印异常堆栈信息，方便调试
       e.printStackTrace();
     }finally{
      // 调用 JdbcUtils 工具类的 closeResource 方法关闭结果集、预编译语句和数据库连接，释放资源
      JdbcUtils.closeResource(rs,ps,conn);
     }
}