如何通过Java JDBC获取AWS Athena中结构体类型字段的数据

别担心，JDBC完全支持读取Athena中的嵌套数据类型，不管是结构体数组还是嵌套的结构体，都有对应的处理方式。下面给你两种实用的解决思路，你可以根据自己的需求选择：

方法一：在Java代码中直接解析嵌套结构 #

Athena的JDBC驱动会把数组类型映射为java.sql.Array，结构体映射为java.sql.Struct，我们可以通过这两个类逐层解析嵌套数据。

替换你代码中的TODO部分，示例如下：

while (rs.next()) {
    // 获取外层的result数组字段
    Array outerResultArray = rs.getArray("result");
    if (outerResultArray != null) {
        // 将Array转换为Java对象数组，每个元素是一个Struct（对应hop和result的结构体）
        Object[] hopStructs = (Object[]) outerResultArray.getArray();
        
        for (Object hopObj : hopStructs) {
            Struct hopStruct = (Struct) hopObj;
            // 获取hop字段值
            int hopNumber = (int) hopStruct.get("hop");
            System.out.println("当前跳数: " + hopNumber);
            
            // 获取嵌套的result数组（每个hop对应的rtt结构体数组）
            Array innerRttArray = (Array) hopStruct.get("result");
            if (innerRttArray != null) {
                Object[] rttStructs = (Object[]) innerRttArray.getArray();
                
                for (Object rttObj : rttStructs) {
                    Struct rttStruct = (Struct) rttObj;
                    // 获取rtt值，注意可能为null，所以用Integer接收更安全
                    Integer rttValue = (Integer) rttStruct.get("rtt");
                    System.out.println("  往返时间: " + (rttValue != null ? rttValue + "ms" : "无数据"));
                }
            }
        }
    }
}

注意事项： #

• 确保你使用的是最新版本的Athena JDBC驱动（推荐2.x及以上），旧版本对复杂类型的支持可能不完善。
• 字段名要和建表语句中的结构体字段完全一致（比如建表时的hop、rtt，JDBC中也要用相同的名称）。
• 一定要处理null值，避免空指针异常（比如数组可能为空，结构体字段也可能为null）。

方法二：在SQL中扁平化嵌套数据 #

如果不需要保留原有的嵌套结构，也可以通过Athena的UNNEST函数把数组展开，让查询结果变成扁平化的行，这样JDBC读取起来更简单，不需要处理复杂的Struct和Array。

示例SQL如下：

SELECT 
    af, 
    dst_addr, 
    hop_struct.hop AS hop, 
    rtt_struct.rtt AS rtt
FROM "sampledb"."traceroute"
-- 展开外层的result数组
CROSS JOIN UNNEST(result) AS t(hop_struct)
-- 展开每个hop对应的result数组
CROSS JOIN UNNEST(hop_struct.result) AS t2(rtt_struct)
LIMIT 10

此时JDBC读取代码就和普通表一样简单：

while (rs.next()) {
    int af = rs.getInt("af");
    String dstAddr = rs.getString("dst_addr");
    int hop = rs.getInt("hop");
    Integer rtt = (Integer) rs.getObject("rtt"); // 避免rtt为null时抛出异常
    
    System.out.printf("AF: %d, 目标地址: %s, 跳数: %d, RTT: %s%n", 
                      af, dstAddr, hop, (rtt != null ? rtt + "ms" : "无数据"));
}

这种方式适合只需要获取嵌套字段具体值，不需要保留数组结构的场景，代码逻辑更简洁。

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