PostgreSQL大对象InputStream是否独立于数据库连接与结果集状态?
首先明确回答:对于PostgreSQL的LargeObject生成的InputStream来说,它完全不独立于数据库连接和ResultSet的状态——这也是你遇到invalid large-object descriptor: 0异常的核心原因。而Oracle的BLOB流实现逻辑不同,所以能在连接关闭后正常工作,这是两种数据库驱动实现的差异。
为什么PostgreSQL会抛出这个异常?
PostgreSQL的LargeObject API是与数据库连接强绑定的:
- 你通过
LargeObjectManager.open()获取的LargeObject实例,本质上是数据库端的一个句柄,这个句柄完全依赖当前的数据库连接存活。 - 调用
lObj.getInputStream()得到的输入流,是直接基于这个数据库端句柄的包装流——一旦连接关闭,或者LargeObject实例被关闭,这个句柄就会被数据库销毁,流自然无法继续读取,抛出无效描述符的异常。
另外,你的读取代码还有一个潜在问题:你在获取InputStream后立刻调用了lObj.close(),这会直接导致流失效,哪怕连接还没关闭——因为流的底层依赖LargeObject实例的句柄,实例关闭后流也无法工作。
怎么解决这个问题?
根据你的需求,有两种常见的处理方案:
方案1:保持连接和LargeObject实例直到流读取完成
如果你的业务逻辑可以保证在读取流的过程中数据库连接不关闭,那么需要调整代码,延迟关闭LargeObject实例:
LargeObjectManager lLOManager = ((org.postgresql.PGConnection) aDatabaseConnection).getLargeObjectAPI(); long lOid = aRs.getLong(aIndex); LargeObject lObj = null; try { if (lOid != 0) { lObj = lLOManager.open(lOid, LargeObjectManager.READ); inputStream = lObj.getInputStream(); // 在这里读取inputStream的内容,比如写入文件或者处理业务逻辑 // ... } } finally { // 读完流之后再关闭LargeObject if (lObj != null) { lObj.close(); } // 注意:数据库连接需要在所有流操作完成后再关闭 }
方案2:将大对象数据缓存到本地,生成独立的流
如果需要让流完全独立于数据库连接(比如要在连接关闭后异步处理数据),可以把LargeObject的内容提前读取到内存或者临时文件中,生成不依赖数据库的流:
LargeObjectManager lLOManager = ((org.postgresql.PGConnection) aDatabaseConnection).getLargeObjectAPI(); long lOid = aRs.getLong(aIndex); if (lOid != 0) { LargeObject lObj = null; try { lObj = lLOManager.open(lOid, LargeObjectManager.READ); // 读取全部内容到字节数组,生成ByteArrayInputStream byte[] blobData = new byte[(int) lObj.size()]; lObj.read(blobData); inputStream = new ByteArrayInputStream(blobData); } finally { if (lObj != null) { lObj.close(); } // 现在可以安全关闭数据库连接,inputStream不受影响 } }
如果大对象体积很大,不适合放在内存中,可以换成写入临时文件,用FileInputStream来替代ByteArrayInputStream。
关于版本差异的补充
你提到之前PostgreSQL中这段代码可用,现在失效——这可能是驱动版本更新带来的行为变化。旧版本的PostgreSQL驱动可能对LargeObject的句柄做了额外的缓存或者延迟回收,但新版本(比如你测试的42.1.4)严格遵循了PostgreSQL的LargeObject生命周期规则,句柄会在连接关闭或LargeObject实例关闭后立刻失效。
内容的提问来源于stack exchange,提问作者flixe

