JDBC跨事务读取PostgreSQL BLOB报invalid large-object descriptor: 0问询

报错根因 #

PostgreSQL 的大对象（LOB）资源生命周期严格绑定所属事务：

• 首次在事务内获取Blob实例时，PG底层会生成一个大对象描述符，该描述符仅在当前事务存活期间有效
• 事务提交或回滚后，描述符会被自动释放，复用之前的Blob实例访问大对象时，就会触发invalid large-object descriptor: 0错误
• 这是PostgreSQL的内置机制，和Hibernate/JDBC封装无关，同一个Blob实例确实无法跨多个事务使用。

正确实现方案 #

方案1：JDBC标准兼容实现（可移植性高） #

不需要绑定PostgreSQL原生能力，每次开启新事务后主动重新查询对应记录获取新的有效Blob实例即可，示例代码如下：

// 提前存储待读取Blob对应业务记录的主键，假设为fileId
final Long fileId = yourBusinessRecordId;
final int blobReadChunkLength = 4 * 1024 * 1024; // 块大小建议设为2-8MB，可按需调整
final ByteArrayOutputStream baos = new ByteArrayOutputStream();
long pos = 0;
byte[] chunk;
do {
    Transaction tx = beginTransaction();
    // 每次事务重新查询记录，拿到新的有效Blob实例
    YourBusinessEntity record = entityManager.find(YourBusinessEntity.class, fileId);
    Blob blob = record.getContent();
    chunk = blob.getBytes(pos, blobReadChunkLength);
    if (chunk.length > 0) {
        baos.write(chunk);
    }
    tx.commit();
    pos += chunk.length;
    // 可按需添加短休眠，进一步让出连接资源给高优先级短事务
    // Thread.sleep(10);
} while (chunk.length > 0);

该方案优势是完全兼容JDBC标准，无需修改现有字段映射逻辑，仅多一次主键查询开销，对性能影响极小。

方案2：PostgreSQL原生实现（性能更优） #

如果可以接受牺牲可移植性，使用PG原生大对象函数实现分块读取性能更高，不需要每次查询完整业务记录。

第一步：获取大对象ID（loid）

如果你的实体字段直接映射为OID类型，直接将字段定义为Long类型即可直接拿到loid；如果是标准Blob映射，可以通过拆代理获取原生PG Blob实例读取loid：

Blob hibernateProxyBlob = record.getContent();
// unwrap拿到PG原生Blob实现
org.postgresql.largeobject.Blob pgBlob = (org.postgresql.largeobject.Blob) hibernateProxyBlob.unwrap(Blob.class);
long loid = pgBlob.getLongOID();

拿到loid后可以持久化存储，后续任意事务都可以直接用该ID读取大对象。

第二步：分块读取实现

PostgreSQL 9.4+提供了lo_get函数，可以直接读取指定偏移、指定长度的大对象块，无需手动管理大对象描述符：

final Long loid = yourLoid;
final int chunkSize = 4 * 1024 * 1024;
ByteArrayOutputStream baos = new ByteArrayOutputStream();
long pos = 0;
byte[] chunk;
do {
    Transaction tx = beginTransaction();
    Query query = entityManager.createNativeQuery("SELECT lo_get(:loid, :pos, :chunkSize)");
    query.setParameter("loid", loid);
    query.setParameter("pos", pos);
    query.setParameter("chunkSize", chunkSize);
    chunk = (byte[]) query.getSingleResult();
    if (chunk != null && chunk.length > 0) {
        baos.write(chunk);
    }
    tx.commit();
    pos += chunk != null ? chunk.length : 0;
} while (chunk != null && chunk.length > 0);

额外优化建议 #

可以在pg_bouncer侧为大Blob读取请求配置独立的连接池、单独设置更高的query_wait_timeout阈值，和普通短事务的连接池物理隔离，避免相互影响。

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