如何使用Phoenix JDBC写入BINARY类型序列化对象数组？

针对你在Phoenix Query Server客户端写入BINARY(800)[]列时遇到的NullPointerException，结合堆栈信息和Phoenix 4.14.3的源码实现，问题根源主要有两个可能：

1. 数组中存在null元素，序列化后得到null的byte[]，Phoenix在处理时尝试获取null数组的长度抛出NPE；
2. Phoenix Query Server的Avatica层对JDBC Array类型的BINARY数组支持存在兼容性缺陷。

以下是具体的解决办法：

解决办法1：手动序列化BINARY数组（推荐） #

绕过JDBC Array的处理逻辑，直接按照Phoenix的数组序列化格式构造字节流，完全可控且适配Query Server环境：

String SQL = "UPSERT INTO myTable VALUES(?,?,?,?,?,?,?)";
Connection connection = getNewConnection();
PreparedStatement pstmt = connection.prepareStatement(SQL);

// ...其他参数设置

// 手动序列化数组为Phoenix兼容格式
ByteArrayOutputStream baos = new ByteArrayOutputStream();
try (DataOutputStream dos = new DataOutputStream(baos)) {
    byte[][] elements = Arrays.stream(myObjectArray)
            .map(obj -> obj != null ? SerializationUtils.serialize(obj) : null)
            .toArray(byte[][]::new);
    
    // 写入数组总长度
    dos.writeInt(elements.length);
    for (byte[] elem : elements) {
        if (elem == null) {
            // Phoenix用-1标识null元素的长度
            dos.writeInt(-1);
        } else {
            dos.writeInt(elem.length);
            dos.write(elem);
        }
    }
} catch (IOException e) {
    throw new RuntimeException("Failed to serialize array", e);
}

// 直接设置序列化后的字节数组
pstmt.setBytes(5, baos.toByteArray());

pstmt.executeUpdate();
connection.commit();

解决办法2：过滤或处理null元素 #

如果数组中的null对象属于无效数据，可以直接过滤后再使用原逻辑：

byte[][] binaryElements = Arrays.stream(myObjectArray)
        .filter(Objects::nonNull) // 过滤null对象
        .map(obj -> SerializationUtils.serialize(obj))
        .toArray(byte[][]::new);

pstmt.setArray(5, connection.createArrayOf("BINARY", binaryElements));

解决办法3：使用Phoenix原生Array实现（需依赖Phoenix客户端） #

如果允许引入Phoenix JDBC依赖，可以直接构造Phoenix原生的PhoenixArray，绕过Avatica的中间处理：

import org.apache.phoenix.jdbc.PhoenixArray;
import org.apache.phoenix.schema.types.PBinary;

// ...其他代码

byte[][] binaryElements = Arrays.stream(myObjectArray)
        .map(obj -> SerializationUtils.serialize(obj))
        .toArray(byte[][]::new);

// 构造Phoenix特定的Array对象
PhoenixArray phoenixArray = new PhoenixArray(PBinary.INSTANCE, binaryElements);
pstmt.setArray(5, phoenixArray);

以上方法均适配你的Phoenix 4.14.3 + HBase 1.4环境，且能兼容Phoenix Query Server的轻量客户端场景。

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