Java中byte[]存入PostgreSQL bit(64)类型报错问题

问题场景 #

在PostgreSQL和MySQL中均创建了如下表：

CREATE TABLE IF NOT EXISTS FOO_bit_64(
    PK bigint primary key,
    x bit(64));

通过Java代码持久化数据时，bit(64)类型的数据以byte[]形式获取，在MySQL中使用以下代码可正常工作：

ByteBuffer buf = ByteBuffer.wrap((byte[]) data);
Object xVal = precision <= 32 ? buf.getInt() : buf.getLong();

但相同逻辑在PostgreSQL中失效，生成的插入语句为：

INSERT INTO FOO_bit_64 (PK, X) VALUES (1,-8523372036854775808)

报错信息：

org.postgresql.util.PSQLException: ERROR: column "x" is of type bit but expression is of type bigint
Hint: You will need to rewrite or cast the expression.

原因分析 #

MySQL对bit类型的数值插入支持隐式类型转换，但PostgreSQL的类型校验更严格，bit(64)列无法直接接收bigint类型的数值，必须显式转换或使用PostgreSQL认可的类型格式。

解决方案 #

1. 显式类型转换（SQL层面） #

在插入SQL中对数值进行类型转换，将bigint转为bit(64)：

INSERT INTO FOO_bit_64 (PK, X) VALUES (1, CAST(-8523372036854775808 AS bit(64)))

如果使用PreparedStatement，可以在SQL中指定转换逻辑：

String sql = "INSERT INTO FOO_bit_64 (PK, X) VALUES (?, CAST(? AS bit(64)))";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setLong(1, 1L);
ByteBuffer buf = ByteBuffer.wrap((byte[]) data);
long xVal = buf.getLong();
pstmt.setLong(2, xVal);
pstmt.executeUpdate();

2. 使用PostgreSQL专属的BitString类型 #

PostgreSQL的JDBC驱动提供了org.postgresql.util.BitString类，可以直接将byte[]转换为该类型后插入：

import org.postgresql.util.BitString;

// ...

byte[] data = ...;
BitString bitStr = BitString.bitString(data, 64); // 第二个参数指定bit长度为64

String sql = "INSERT INTO FOO_bit_64 (PK, X) VALUES (?, ?)";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setLong(1, 1L);
pstmt.setObject(2, bitStr);
pstmt.executeUpdate();

3. 转换为bit字符串格式 #

将byte[]转换为由0和1组成的64位字符串，PostgreSQL的bit类型可以直接接收这种格式的字面量：

public static String byteArrayToBitString(byte[] bytes, int bitLength) {
    StringBuilder sb = new StringBuilder(bitLength);
    for (int i = 0; i < bitLength; i++) {
        // 按位提取每一位的0/1值
        int byteIndex = i / 8;
        int bitPosition = 7 - (i % 8);
        int bit = (bytes[byteIndex] >> bitPosition) & 1;
        sb.append(bit);
    }
    return sb.toString();
}

// 使用示例
byte[] data = ...;
String bitStr = byteArrayToBitString(data, 64);

String sql = "INSERT INTO FOO_bit_64 (PK, X) VALUES (?, ?)";
PreparedStatement pstmt = conn.prepareStatement(sql);
pstmt.setLong(1, 1L);
pstmt.setString(2, bitStr);
pstmt.executeUpdate();

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