Oracle中BLOB、CLOB的读取和写入

在Oracle数据库中，大范例字段（也称为大对象或LOB，Large Object）用于存储大量的数据，如文本、图像、视频等。Oracle 提供了几种差异的大范例字段，主要包括：

• CLOB（Character Large Object）：
  
  
  
  • 存储大量的字符数据，可以存储多达4 GB的文本。
    
  • 适用于需要存储大段文本信息的场景，如文档、日志记录等。
    
  
  
• BLOB（Binary Large Object）：
  
  
  
  • 存储大量的二进制数据，可以存储多达4 GB的二进制信息。
    
  • 常用于存储图片、音频、视频等媒体文件。
    
  
  
• NCLOB（National Character Large Object）：
  
  
  
  • 雷同于CLOB，但用于存储多字节字符集（如Unicode字符集）的数据。
    
  • 适用于需要存储多国语言文本的应用。
    
  
  
• BFILE（Binary File）：
  
  
  
  • 存储外部文件的引用，而不是将文件内容直接存储在数据库中。
    
  • BFILE可以存储在数据库外部文件系统中，数据库只存储其路径和文件名。
    
  
  

基于SQL和Java的方式实现读取和插入这些大范例字段，同时将读取的数据转换为字符串范例。
一、基于SQL 的方式实现 CLOB、BLOB 的插入与读取

1. 插入大范例数据

插入 CLOB 数据

CLOB用于存储大段文本，可以通过简单的SQL插入语句来插入数据：

1. INSERT INTO my_table (id, clob_column)
2. VALUES (1, 'This is a large text that can go up to 4 GB');

复制代码

插入 BLOB 数据

BLOB用于存储二进制数据。由于直接通过SQL插入BLOB数据较为复杂，通常会通过文件或其他方法插入数据。
假设我们要插入一段十六进制字符串代表的二进制数据：

1. INSERT INTO my_table (id, blob_column)
2. VALUES (1, hextoraw('48656C6C6F20576F726C64')); -- 'Hello World' in hexadecimal

复制代码

2. 读取大范例数据并转换为字符串

读取 CLOB 数据并转换为字符串

CLOB字段中的数据可以直接读取并视为字符串：

1. SELECT clob_column
2. FROM my_table
3. WHERE id = 1;

复制代码

读取 BLOB 数据并转换为字符串 (UTL_RAW.CAST_TO_VARCHAR2)

BLOB数据通常是二进制的，如果需要将其转换为字符串，可以使用SQL中的UTL_RAW.CAST_TO_VARCHAR2函数，将其转换为VARCHAR2范例（留意BLOB巨细不能超过VARCHAR2的限定[2000]）：

1. SELECT UTL_RAW.CAST_TO_VARCHAR2(dbms_lob.substr(blob_column, 4000, 1))
2. FROM my_table
3. WHERE id = 1;

复制代码

这里dbms_lob.substr用于提取BLOB中的数据，最大可提取4000字节。
也可以先使用dbms_lob.substr(blob_column) 来判断BLOB范例字段的数据长度，如果不超过 2000,可以直接使用UTL_RAW.CAST_TO_VARCHAR2(blob_column)来将BLOB范例数据转为字符范例。

1. SELECT UTL_RAW.CAST_TO_VARCHAR2(blob_column)
2. FROM my_table
3. WHERE id = 1;

复制代码

二、基于Java 方式实现 CLOB 和 BLOB 的插入与读取

在Java中，通过PreparedStatement举行插入，通过ResultSet举行读取。
1. Java 中插入 CLOB 和 BLOB 数据

插入 CLOB 数据

使用Java的PreparedStatement将字符串数据插入到CLOB字段：

1. import java.sql.Connection;
2. import java.sql.DriverManager;
3. import java.sql.PreparedStatement;
5. public class ClobInsertExample {
6.     public static void main(String[] args) {
7.         Connection conn = null;
8.         PreparedStatement pstmt = null;
9.         try {
10.             conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl", "username", "password");
12.             String sql = "INSERT INTO my_table (id, clob_column) VALUES (?, ?)";
13.             pstmt = conn.prepareStatement(sql);
14.             pstmt.setInt(1, 1);
15.             pstmt.setString(2, "This is a large text for CLOB field.");
17.             pstmt.executeUpdate();
18.         } catch (Exception e) {
19.             e.printStackTrace();
20.         } finally {
21.             try {
22.                 if (pstmt != null) pstmt.close();
23.                 if (conn != null) conn.close();
24.             } catch (Exception e) {
25.                 e.printStackTrace();
26.             }
27.         }
28.     }
29. }

复制代码

插入 BLOB 数据

BLOB通常用于存储二进制数据，如图像或文件。通过Java的PreparedStatement插入二进制数据：

1. import java.io.FileInputStream;
2. import java.sql.Connection;
3. import java.sql.DriverManager;
4. import java.sql.PreparedStatement;
6. public class BlobInsertExample {
7.     public static void main(String[] args) {
8.         Connection conn = null;
9.         PreparedStatement pstmt = null;
10.         try {
11.             conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl", "username", "password");
13.             String sql = "INSERT INTO my_table (id, blob_column) VALUES (?, ?)";
14.             pstmt = conn.prepareStatement(sql);
15.             pstmt.setInt(1, 1);
17.             FileInputStream inputStream = new FileInputStream("path/to/your/file.jpg");
18.             pstmt.setBinaryStream(2, inputStream, inputStream.available());
20.             pstmt.executeUpdate();
21.             inputStream.close();
22.         } catch (Exception e) {
23.             e.printStackTrace();
24.         } finally {
25.             try {
26.                 if (pstmt != null) pstmt.close();
27.                 if (conn != null) conn.close();
28.             } catch (Exception e) {
29.                 e.printStackTrace();
30.             }
31.         }
32.     }
33. }

复制代码

2. Java 中读取 CLOB 和 BLOB 数据并转换为字符串

读取 CLOB 数据并转换为字符串

读取CLOB数据并将其转换为字符串非常简单：

1. import java.sql.Connection;
2. import java.sql.DriverManager;
3. import java.sql.PreparedStatement;
4. import java.sql.ResultSet;
6. public class ClobReadExample {
7.     public static void main(String[] args) {
8.         Connection conn = null;
9.         PreparedStatement pstmt = null;
10.         ResultSet rs = null;
11.         try {
12.             conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl", "username", "password");
14.             String sql = "SELECT clob_column FROM my_table WHERE id = ?";
15.             pstmt = conn.prepareStatement(sql);
16.             pstmt.setInt(1, 1);
17.             rs = pstmt.executeQuery();
19.             if (rs.next()) {
20.                 String clobData = rs.getString("clob_column");
21.                 System.out.println(clobData);
22.             }
23.         } catch (Exception e) {
24.             e.printStackTrace();
25.         } finally {
26.             try {
27.                 if (rs != null) rs.close();
28.                 if (pstmt != null) pstmt.close();
29.                 if (conn != null) conn.close();
30.             } catch (Exception e) {
31.                 e.printStackTrace();
32.             }
33.         }
34.     }
35. }

复制代码

读取 BLOB 数据并转换为字符串

由于BLOB是二进制数据，需要先读取为字节数组，然后将其转换为字符串

1. import java.io.ByteArrayOutputStream;
2. import java.io.InputStream;
3. import java.sql.Connection;
4. import java.sql.DriverManager;
5. import java.sql.PreparedStatement;
6. import java.sql.ResultSet;
8. public class BlobReadExample {
9.     public static void main(String[] args) {
10.         Connection conn = null;
11.         PreparedStatement pstmt = null;
12.         ResultSet rs = null;
13.         try {
14.             conn = DriverManager.getConnection("jdbc:oracle:thin:@localhost:1521:orcl", "username", "password");
16.             String sql = "SELECT blob_column FROM my_table WHERE id = ?";
17.             pstmt = conn.prepareStatement(sql);
18.             pstmt.setInt(1, 1);
19.             rs = pstmt.executeQuery();
21.             if (rs.next()) {
22.                 InputStream inputStream = rs.getBinaryStream("blob_column");
23.                 ByteArrayOutputStream outputStream = new ByteArrayOutputStream();
25.                 byte[] buffer = new byte[4096];
26.                 int bytesRead = -1;
28.                 while ((bytesRead = inputStream.read(buffer)) != -1) {
29.                     outputStream.write(buffer, 0, bytesRead);
30.                 }
32.                 byte[] imageBytes = outputStream.toByteArray();
33.                 String blobAsString = new String(imageBytes, "UTF-8");
34.                 System.out.println(blobAsString);
36.                 inputStream.close();
37.                 outputStream.close();
38.             }
39.         } catch (Exception e) {
40.             e.printStackTrace();
41.         } finally {
42.             try {
43.                 if (rs != null) rs.close();
44.                 if (pstmt != null) pstmt.close();
45.                 if (conn != null) conn.close();
46.             } catch (Exception e) {
47.                 e.printStackTrace();
48.             }
49.         }
50.     }
51. }

复制代码

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。