java读写oracle的blob字段示例

本文将介绍如何在Java中通过JDBC API读写Oracle数据库的BLOB字段。以下是完整的攻略流程：

准备工作

在开始之前，请确保你已经安装了Oracle数据库，并配置好了JDBC驱动程序。此外，你需要使用一个连接字符串来打开数据库连接。

读取BLOB字段

以下是读取Oracle数据库中BLOB字段的示例代码：

import java.io.IOException;
import java.io.InputStream;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;

public class ReadBlobExample {

    public static void main(String[] args) {

        String url = "jdbc:oracle:thin:@localhost:1521:orcl";
        String username = "username";
        String password = "password";
        String sql = "SELECT blob_data FROM my_table WHERE id = ?";

        try (Connection conn = DriverManager.getConnection(url, username, password);
             PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.setInt(1, 1);
            ResultSet rs = pstmt.executeQuery();
            rs.next();
            InputStream is = rs.getBinaryStream(1);
            ByteArrayOutputStream baos = new ByteArrayOutputStream();
            byte[] buffer = new byte[1024];
            int bytesRead = 0;
            while ((bytesRead = is.read(buffer)) != -1) {
                baos.write(buffer, 0, bytesRead);
            }
            byte[] blobData = baos.toByteArray();
            is.close();
            baos.close();
        } catch (SQLException | IOException ex) {
            ex.printStackTrace();
        }
    }
}

该示例中，我们使用了JDBC API连接到Oracle数据库，然后通过向PreparedStatement对象中设置参数，调用executeQuery方法查询指定的数据行。ResultSet对象的getBinaryStream方法将返回一个InputStream对象，从而允许我们逐字节读取BLOB数据。

插入BLOB字段

以下是向Oracle数据库中插入BLOB字段的示例代码：

import java.io.File;
import java.io.FileInputStream;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;

public class WriteBlobExample {

    public static void main(String[] args) {

        String url = "jdbc:oracle:thin:@localhost:1521:orcl";
        String username = "username";
        String password = "password";
        String sql = "INSERT INTO my_table (id, blob_data) VALUES (?, ?)";

        try (Connection conn = DriverManager.getConnection(url, username, password);
             PreparedStatement pstmt = conn.prepareStatement(sql)) {
            pstmt.setInt(1, 1);
            File blobFile = new File("path/to/your/file");
            FileInputStream fis = new FileInputStream(blobFile);
            pstmt.setBinaryStream(2, fis, (int) blobFile.length());
            pstmt.executeUpdate();
            fis.close();
        } catch (SQLException | IOException ex) {
            ex.printStackTrace();
        }
    }
}

在该示例中，我们使用PreparedStatement对象向Oracle数据库插入一个BLOB字段。为此，我们需要打开一个FileInputStream对象来读取BLOB数据，然后将其绑定到PreparedStatement对象的第二个参数中，并通过调用executeUpdate方法将其插入数据库。

希望这些示例能够帮助你在Java中读写Oracle数据库的BLOB字段。