Java -- JDBC 学习--处理Blob

Posted 2020-09-21 西北野狼

Oracle LOB

LOB，即Large Objects（大对象），是用来存储大量的二进制和文本数据的一种数据类型（一个LOB字段可存储可多达4GB的数据）。
LOB 分为两种类型：内部LOB和外部LOB。
内部LOB将数据以字节流的形式存储在数据库的内部。因而，内部LOB的许多操作都可以参与事务，也可以像处理普通数据一样对其进行备份和恢复操作。Oracle支持三种类型的内部LOB：

1. BLOB（二进制数据）  
2. CLOB（单字节字符数据） 
3. NCLOB（多字节字符数据）。

CLOB和NCLOB类型适用于存储超长的文本数据，BLOB字段适用于存储大量的二进制数据，如图像、视频、音频，文件等。
目前只支持一种外部LOB类型，即BFILE类型。在数据库内，该类型仅存储数据在操作系统中的位置信息，而数据的实体以外部文件的形式存在于操作系统的文件系统中。因而，该类型所表示的数据是只读的，不参与事务。该类型可帮助用户管理大量的由外部程序访问的文件。

mysql BLOB

MySQL中，BLOB是一个二进制大型对象，是一个可以存储大量数据的容器，它能容纳不同大小的数据。
MySQL的四种BLOB类型(除了在存储的最大信息量上不同外，他们是等同的)。

 

实际使用中根据需要存入的数据大小定义不同的BLOB类型。需要注意的是：如果存储的文件过大，数据库的性能会下降。

使用JDBC来写入Blob型数据到Oracle中

1. Oracle的Blob字段比long字段的性能要好，可以用来保存如图片之类的二进制数据。
2. Oracle的BLOB字段由两部分组成：数据（值）和指向数据的指针（定位器）。尽管值与表自身一起存储，但是一个BLOB列并不包含值，仅有它的定位指针。为了使用大对象，程序必须声明定位器类型的本地变量。
3. 当Oracle内部LOB被创建时，定位器被存放在列中，值被存放在LOB段中，LOB段是在数据库内部表的一部分。
4. 因为Blob自身有一个cursor，当写入Blob字段必须使用指针（定位器）对Blob进行操作，因而在写入Blob之前，必须获得指针（定位器）才能进行写入
5. 如何获得Blob的指针（定位器） ：需要先插入一个empty的blob，这将创建一个blob的指针，然后再把这个empty的blob的指针查询出来，这样通过两步操作，就获得了blob的指针，可以真正的写入blob数据了。

步骤

1. 插入空blob insert into javatest(name,content) values(?,empty_blob());
2. 获得blob的cursor select content from javatest where name= ? for update; 注意: 须加for update，锁定该行，直至该行被修改完毕，保证不产生并发冲突。 
3. 利用 io，和获取到的cursor往数据库写数据流 。



 

插入 BLOB 类型的数据必须使用 PreparedStatement：因为 BLOB 类型的数据时无法使用字符串拼写的。

举个例子：

public void testInsertBlob(){
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        
        try {
            connection = JDBCTools.getConnection();
            String sql = "INSERT INTO customers(name, email, birth, picture)" 
                    + "VALUES(?,?,?,?)";
            preparedStatement = connection.prepareStatement(sql);
            
            preparedStatement.setString(1, "ABCDE");
            preparedStatement.setString(2, "[e-mail]");
            preparedStatement.setDate(3, 
                    new Date(new java.util.Date().getTime()));
            
            InputStream inputStream = new FileInputStream("Hydrangeas.jpg");
            preparedStatement.setBlob(4, inputStream);
            
            preparedStatement.executeUpdate();
        } catch (Exception e) {
            e.printStackTrace();
        } finally{
            JDBCTools.releaseDB(null, preparedStatement, connection);
        }
    }

读取 blob 数据:
　　1. 使用 getBlob 方法读取到 Blob 对象
　　2. 调用 Blob 的 getBinaryStream() 方法得到输入流。再使用 IO 操作即可.

举个例子：

@Test
    public void readBlob(){
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        ResultSet resultSet = null;
        
        try {
            connection = JDBCTools.getConnection();
            String sql = "SELECT id, name customerName, email, birth, picture " 
                    + "FROM customers WHERE id = 13";
            preparedStatement = connection.prepareStatement(sql);
            resultSet = preparedStatement.executeQuery();
            
            if(resultSet.next()){
                int id = resultSet.getInt(1);
                String name = resultSet.getString(2);
                String email = resultSet.getString(3);
                
                System.out.println(id + ", " + name  + ", " + email);
                Blob picture = resultSet.getBlob(5);
                
                InputStream in = picture.getBinaryStream();
                System.out.println(in.available()); 
                
                OutputStream out = new FileOutputStream("flower.jpg");
                
                byte [] buffer = new byte[1024];
                int len = 0;
                while((len = in.read(buffer)) != -1){
                    out.write(buffer, 0, len);
                }
                
                in.close();
                out.close();
            }
            
        } catch (Exception e) {
            e.printStackTrace();
        } finally{
            JDBCTools.releaseDB(resultSet, preparedStatement, connection);
        }
    }