DB2 BLOB数据到JSON字符串的Java转换教程

// ... 数据库连接和查询设置 ...

while (res.next()) {
    Blob rawBlob = res.getBlob("COLUMN_NAME");
    if (rawBlob != null) {
        try (InputStream in = rawBlob.getBinaryStream();
             Reader reader = new InputStreamReader(in, StandardCharsets.UTF_8)) {
            // 尝试使用JsonReader和JsonParser解析
            // JsonReader reader2 = new JsonReader(reader);
            // reader2.setLenient(true); // 宽松模式可能有助于处理某些非标准JSON
            // JsonElement out = JsonParser.parseReader(reader2);
            // System.out.println(out);

            // 或者直接读取为字符串，观察原始内容
            StringBuilder sb = new StringBuilder();
            char[] buffer = new char[4096];
            int bytesRead;
            while ((bytesRead = reader.read(buffer)) != -1) {
                sb.append(buffer, 0, bytesRead);
            }
            System.out.println("原始BLOB尝试转换为字符串: " + sb.toString());

        } catch (IOException e) {
            System.err.println("读取BLOB时发生IO错误: " + e.getMessage());
        } catch (com.google.gson.JsonParseException e) {
            System.err.println("解析JSON时发生错误: " + e.getMessage());
        }
    }
}

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.util.Properties;

public class Db2BlobToJsonConverter {

    private static final String JDBC_CLASS_NAME = "com.ibm.db2.jcc.DB2Driver"; // DB2 JDBC驱动类名
    private static final String DB_URL = "jdbc:db2://your_db2_host:port/your_db_name"; // 替换为你的DB2连接URL
    private static final String DB_USER = "******"; // 替换为你的用户名
    private static final String DB_PASSWORD = "*****"; // 替换为你的密码

    public static void main(String[] args) {
        Connection connection = null;
        PreparedStatement pstate = null;
        ResultSet res = null;

        try {
            // 1. 加载DB2 JDBC驱动
            Class.forName(JDBC_CLASS_NAME);
            System.out.println("DB2 driver loaded successfully.");

            // 2. 建立数据库连接
            Properties props = new Properties();
            props.setProperty("user", DB_USER);
            props.setProperty("password", DB_PASSWORD);
            // 根据需要添加其他连接属性，例如：
            // props.setProperty("useJDBC4ColumnNameAndLabelSemantics", "2"); 
            connection = DriverManager.getConnection(DB_URL, props);
            System.out.println("Connected to DB2 successfully.");

            // 3. 准备SQL查询语句，使用SYSTOOLS.BSON2JSON函数
            String sqlQuery = "select SYSTOOLS.BSON2JSON(COLUMN_NAME) as JSON_DATA from TABLE_TEST";
            pstate = connection.prepareStatement(sqlQuery);

            // 4. 执行查询
            res = pstate.executeQuery();

            // 5. 遍历结果集，获取JSON字符串
            while (res.next()) {
                String jsonOutput = res.getString("JSON_DATA"); // 直接获取JSON字符串
                System.out.println("成功转换的JSON数据: " + jsonOutput);
                // 此时，jsonOutput已经是标准的JSON字符串，你可以使用任何JSON库进一步处理
                // 例如：
                // JsonElement jsonElement = JsonParser.parseString(jsonOutput);
                // System.out.println("解析后的JSON元素: " + jsonElement.getAsJsonObject().get("EMPLOYEE_NAME"));
            }

        } catch (ClassNotFoundException e) {
            System.err.println("DB2 JDBC驱动未找到: " + e.getMessage());
            e.printStackTrace();
        } catch (SQLException e) {
            System.err.println("数据库操作失败: " + e.getMessage());
            e.printStackTrace();
        } finally {
            // 6. 关闭资源
            try {
                if (res != null) res.close();
                if (pstate != null) pstate.close();
                if (connection != null) connection.close();
                System.out.println("数据库资源已关闭。");
            } catch (SQLException e) {
                System.err.println("关闭数据库资源时发生错误: " + e.getMessage());
                e.printStackTrace();
            }
        }
    }
}