Java中如何将Amazon QLDB查询返回的IonStruct转换为JSON格式

解决方案 #

要实现IonStruct到标准JSON的转换，推荐使用jackson-dataformat-ion工具完成，步骤如下：

1. 引入依赖 #

在项目pom.xml中添加如下Maven依赖（Gradle项目对应调整依赖声明即可）：

<dependency>
    <groupId>com.fasterxml.jackson.dataformat</groupId>
    <artifactId>jackson-dataformat-ion</artifactId>
    <version>2.15.2</version>
</dependency>
<dependency>
    <groupId>com.amazon.ion</groupId>
    <artifactId>ion-java</artifactId>
    <version>1.9.5</version>
</dependency>

注意依赖版本和你项目现有Jackson版本保持一致即可。

2. 代码实现 #

首先优化你现有代码的不合理点：IonSystem是重量级实例，全局初始化一次即可，不要在每次查询的lambda中重复创建。
完整实现示例：

// 全局初始化公共实例
private static final IonSystem ION_SYSTEM = IonSystemBuilder.standard().build();
private static final ObjectMapper ION_OBJECT_MAPPER = new ObjectMapper(new IonFactory(ION_SYSTEM));

public String queryWalletById(String id) throws JsonProcessingException {
    return qldbDriver.execute(txn -> {
        Result result = txn.execute("SELECT * FROM _ql_committed_WALLET WHERE metadata.id = ?", ION_SYSTEM.newString(id));
        // 判空处理，避免无查询结果时报错
        if(!result.iterator().hasNext()){
            return null;
        }
        IonStruct committedStruct = (IonStruct) result.iterator().next();
        IonStruct dataStruct = (IonStruct) committedStruct.get("data");
        // 转换为标准格式化JSON字符串
        return ION_OBJECT_MAPPER.writerWithDefaultPrettyPrinter().writeValueAsString(dataStruct);
    });
}

3. 可选扩展 #

如果需要直接转换为业务实体类，不需要手动解析JSON，调整转换逻辑即可：

// 示例Wallet为你自定义的业务实体类
Wallet wallet = ION_OBJECT_MAPPER.treeToValue(dataStruct, Wallet.class);

注意事项 #

不要直接使用Ion自带的toPrettyString()方法，该方法输出的是Ion格式文本，遇到时间、二进制等Ion独有类型时会生成JSON不兼容的语法，前端无法正常解析。

内容的提问来源于stack exchange，提问作者Dasun