如何在Java中读取BigQuery Bytes类型并原样写入PostgreSQL？

核心问题原因 #

BigQuery的Bytes类型在TableRow中是以Base64编码的字符串形式存储的，并非直接的byte[]数组。你之前的两种尝试都没正确处理原始二进制数据：

• toString().getBytes()是把Base64字符串本身转成字节，而非解码原始二进制内容
• 强制转(byte[])属于类型错误（实际值是String），会直接导致数据乱码或结构损坏

正确解决方案 #

使用BigQuery API配套的Google Base64工具类解码Base64字符串，得到原始二进制数组后再写入PostgreSQL：

1. 从TableRow中取出BigQuery Bytes列对应的Base64字符串
2. 用官方工具类解码得到原始二进制数组
3. 将解码后的byte[]传入setBytes方法

示例代码：

// 从TableRow获取BigQuery Bytes列的值（实际为Base64编码字符串）
Object bytesValue = row.get("bytes_type_column");
String base64Str = (String) bytesValue;

// 解码得到原始二进制数组
byte[] rawBytes = com.google.api.client.util.Base64.decodeBase64(base64Str);

// 写入PostgreSQL的Bytea列
insertQuery.setBytes(3, rawBytes);

验证说明 #

解码后的rawBytes完全对应BigQuery中存储的原始pickle序列化二进制数据，写入PostgreSQL后，Python应用读取Bytea列时可直接反序列化，不会出现结构损坏问题。

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