org.hibernate.HibernateException：无法访问 lob 流

Posted 2023-02-26

【中文标题】org.hibernate.HibernateException：无法访问 lob 流

【英文标题】：org.hibernate.HibernateException: Unable to access lob stream

【发布时间】：2012-02-19 21:11:25

【问题描述】：

我正在使用 hibernate 3.6.7 将我的类映射到 oracle 表。 我通常不会得到这个异常：

org.hibernate.HibernateException: Unable to access lob stream
    at java.util.concurrent.FutureTask$Sync.innerGet(FutureTask.java:222)
    at java.util.concurrent.FutureTask.get(FutureTask.java:83)
    at com.mycompany.TransferFiles.TransferFilesToHadoop(TransferFiles.java:85)
    at com.mycompany.TransferJob.execute(TransferJob.java:25)
    at org.quartz.core.JobRunShell.run(JobRunShell.java:202)
    at org.quartz.simpl.SimpleThreadPool$WorkerThread.run(SimpleThreadPool.java:525)
 Caused by: org.hibernate.HibernateException: Unable to access lob stream
       at org.hibernate.type.descriptor.java.ClobTypeDescriptor.unwrap(ClobTypeDescriptor.java:117)
    at org.hibernate.type.descriptor.java.ClobTypeDescriptor.unwrap(ClobTypeDescriptor.java:46)
    at org.hibernate.type.descriptor.sql.ClobTypeDescriptor$3$1.doBind(ClobTypeDescriptor.java:83)
    at org.hibernate.type.descriptor.sql.BasicBinder.bind(BasicBinder.java:91)
    at org.hibernate.type.AbstractStandardBasicType.nullSafeSet(AbstractStandardBasicType.java:283)
    at org.hibernate.type.AbstractStandardBasicType.nullSafeSet(AbstractStandardBasicType.java:278)
    at org.hibernate.type.AbstractSingleColumnStandardBasicType.nullSafeSet(AbstractSingleColumnStandardBasicType.java:89)
    at org.hibernate.persister.entity.AbstractEntityPersister.dehydrate(AbstractEntityPersister.java:2184)
    at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2558)
    at org.hibernate.persister.entity.AbstractEntityPersister.updateOrInsert(AbstractEntityPersister.java:2494)
    at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2821)
    at org.hibernate.action.EntityUpdateAction.execute(EntityUpdateAction.java:113)
    at org.hibernate.engine.ActionQueue.execute(ActionQueue.java:273)
    at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:265)
    at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:185)
    at org.hibernate.event.def.AbstractFlushingEventListener.performExecutions(AbstractFlushingEventListener.java:321)
    at org.hibernate.event.def.DefaultFlushEventListener.onFlush(DefaultFlushEventListener.java:51)
    at org.hibernate.impl.SessionImpl.flush(SessionImpl.java:1216)
    at com.mycompany.HibernateUtil.getSession(HibernateUtil.java:36)
    at com.mycompany.BasicDaoImpl.saveOrUpdate(BasicDaoImpl.java:34)
    at com.mycompany.FileCopyRoutine.call(TransferFiles.java:297)
    at com.mycompany..FileCopyRoutine.call(TransferFiles.java:225)
    at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
    at java.util.concurrent.FutureTask.run(FutureTask.java:138)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
    at java.lang.Thread.run(Thread.java:662)
 Caused by: java.sql.SQLException: Closed Connection
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:112)
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:146)
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:208)
    at oracle.sql.CLOB.getDBAccess(CLOB.java:1196)
    at oracle.sql.CLOB.getCharacterStream(CLOB.java:278)
    at sun.reflect.GeneratedMethodAccessor29.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    at java.lang.reflect.Method.invoke(Method.java:597)
    at org.hibernate.engine.jdbc.SerializableClobProxy.invoke(SerializableClobProxy.java:74)
    at $Proxy2.getCharacterStream(Unknown Source)
    at org.hibernate.type.descriptor.java.ClobTypeDescriptor.unwrap(ClobTypeDescriptor.java:114)

当我调用 saveOrUpdate 方法时。

谁能给我一些建议？

public static synchronized Session getSession() throws DBConnectionException

    Session session = threadSession.get();

    if(session==null||!session.isOpen()||!session.isConnected())
        if(sessionFactory==null||sessionFactory.isClosed())initHibernate();
        try
            session = sessionFactory.openSession();
        catch(Exception e)
            throw new DBConnectionException("Exception caught when trying to generate Hibernate session.");
        
        threadSession.set(session);
    
    if(session.isDirty())
        session.flush();(36 line of HibernateUtil)
    
    session.clear();
    return session;

我都用了很久。

现在我正在并行传输文件，然后使用 saveOrUpdate 方法更新数据库。虽然有很多线程，但我在我的代码中同步了这部分。 我认为我们一直都连接到数据库，但它给出了关闭连接的异常。 谁能给我一些关于这个异常的建议。问题应该是什么？

我认为可能是因为使用了saveOrUpdate，所以我改用merge，但同样有同样的问题。

Caused by: org.hibernate.HibernateException: Unable to access lob stream
    at org.hibernate.type.descriptor.java.ClobTypeDescriptor.unwrap(ClobTypeDescriptor.java:117)
    at org.hibernate.type.descriptor.java.ClobTypeDescriptor.unwrap(ClobTypeDescriptor.java:46)
    at org.hibernate.type.descriptor.sql.ClobTypeDescriptor$3$1.doBind(ClobTypeDescriptor.java:83)
    at org.hibernate.type.descriptor.sql.BasicBinder.bind(BasicBinder.java:91)
    at org.hibernate.type.AbstractStandardBasicType.nullSafeSet(AbstractStandardBasicType.java:283)
    at org.hibernate.type.AbstractStandardBasicType.nullSafeSet(AbstractStandardBasicType.java:278)
    at org.hibernate.type.AbstractSingleColumnStandardBasicType.nullSafeSet(AbstractSingleColumnStandardBasicType.java:89)
    at org.hibernate.persister.entity.AbstractEntityPersister.dehydrate(AbstractEntityPersister.java:2184)
    at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2558)
    at org.hibernate.persister.entity.AbstractEntityPersister.updateOrInsert(AbstractEntityPersister.java:2494)
    at org.hibernate.persister.entity.AbstractEntityPersister.update(AbstractEntityPersister.java:2821)
    at org.hibernate.action.EntityUpdateAction.execute(EntityUpdateAction.java:113)
    at org.hibernate.engine.ActionQueue.execute(ActionQueue.java:273)
    at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:265)
    at org.hibernate.engine.ActionQueue.executeActions(ActionQueue.java:185)
    at org.hibernate.event.def.AbstractFlushingEventListener.performExecutions(AbstractFlushingEventListener.java:321)
    at org.hibernate.event.def.DefaultFlushEventListener.onFlush(DefaultFlushEventListener.java:51)
    at org.hibernate.impl.SessionImpl.flush(SessionImpl.java:1216)
    at org.hibernate.impl.SessionImpl.managedFlush(SessionImpl.java:383)
    at org.hibernate.transaction.JDBCTransaction.commit(JDBCTransaction.java:133)
    at mycompany.jobsrc.BasicDaoImpl.merge(BasicDaoImpl.java:52)
    at mycompany.FileCopyRoutine.call(TransferFiles.java:301)
    at mycompany.FileCopyRoutine.call(TransferFiles.java:226)
    at java.util.concurrent.FutureTask$Sync.innerRun(FutureTask.java:303)
    at java.util.concurrent.FutureTask.run(FutureTask.java:138)
    at java.util.concurrent.ThreadPoolExecutor$Worker.runTask(ThreadPoolExecutor.java:886)
    at java.util.concurrent.ThreadPoolExecutor$Worker.run(ThreadPoolExecutor.java:908)
    at java.lang.Thread.run(Thread.java:662)
   Caused by: java.sql.SQLException: Closed Connection
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:112)
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:146)
    at oracle.jdbc.driver.DatabaseError.throwSqlException(DatabaseError.java:208)
    at oracle.sql.CLOB.getDBAccess(CLOB.java:1196)
    at oracle.sql.CLOB.getCharacterStream(CLOB.java:278)
    at sun.reflect.GeneratedMethodAccessor36.invoke(Unknown Source)
    at sun.reflect.DelegatingMethodAccessorImpl.invoke(DelegatingMethodAccessorImpl.java:25)
    at java.lang.reflect.Method.invoke(Method.java:597)
    at org.hibernate.engine.jdbc.SerializableClobProxy.invoke(SerializableClobProxy.java:74)
    at $Proxy2.getCharacterStream(Unknown Source)
    at org.hibernate.type.descriptor.java.ClobTypeDescriptor.unwrap(ClobTypeDescriptor.java:114)
    ... 27 more

我的合并代码：

public void merge(T t) throws DBConnectionException
    Session session = HibernateUtil.getSession();
    Transaction transaction = session.beginTransaction();
    session.merge(t);
    transaction.commit();

【问题讨论】：

一个可能的原因是“lob 对象”不存在。我有类似问题的经验，但使用 PSQL，当我们移动到新数据库时迁移团队没有复制“blob 对象”。不确定它是否适用于 Oracle

【参考方案1】：

我的猜测是你有一些非常大的字段，所以它被映射到 sql lob。我怀疑映射本身是不正确的。但只有当您尝试使用非空值保存实体时才会发生这种情况。尝试将所有具有非空字段的实体一一保存在应用程序中。这将隔离问题。

【参考方案2】：

这可能与thread 中讨论的 JDBC 驱动程序有关。你能把你在项目中使用的Oracle版本和ojdbc jar版本发布出来吗？

【参考方案3】：

当您使用多线程时，我的猜测是您可能会遇到一些事务问题。这可能是因为在您对对象进行必要的更改之前以某种方式提交了某些事务。或者您正试图访问从不同线程保存的对象，这意味着该对象不在事务范围内。

【参考方案4】：

我相信我以前有过这个。

当从 Oracle 加载大对象（CLOB、BLOB）时，它会作为对流的引用返回。如果记录映射到休眠状态并且在加载对象后关闭会话（因此对象变得分离），则映射到的 java 字段 blob 尚不包含数据；因此，当您尝试将其保存回来时，它无法使用它，因为 clob/blob 流已消失。

首先，尝试在同一个会话中继续加载和保存。

如果我没记错的话，另一种解决方法是在加载会话仍处于打开状态时“触摸”clob/bloc java 字段。然后将从数据库中读取数据。但它的效率非常低（它是 LOB 是有原因的，即它是 big）。

另一种选择是将小数据和 lob 拆分到两个不同的表中，并仅在需要时加载 lob。

希望对您的方向有所帮助。

【讨论】：

Caused by: java.sql.SQLException: Closed Connection 在堆栈跟踪中暗示...

关闭的连接我相信与属于用于加载记录的会话的连接有关。那个，是的，在尝试合并对象时已经关闭。

如果在尝试保存或更新时发生它不能与延迟初始化有关吗？我认为的问题是保存或更新正在关闭会话......

BLOB 在驱动程序级别是惰性初始化的。取而代之的是一个特殊的代理对象——对 BLOB 的引用。该对象具有对连接的引用。当您尝试访问数据时（例如，在合并时），它将使用连接来检索数据。但是此时连接已经关闭。所以你是对的，问题是关闭的会话（和连接）。至少我相信。

【参考方案5】：

我很可能认为这是由于Session 管理不善。但是如果不查看大量代码，我无法告诉您当前实现的确切问题是什么。

我相信threadSession 是一个ThreadLocal。而不是手动执行此操作，请使用

sessionFactory.getCurrentSession();

并在休眠配置文件中设置线程。

让您的 HibernateUtil 变得简单，无需所有这些检查。我个人觉得这些检查会掩盖 Session 管理不善和其他错误......但那可能只是我......

【参考方案6】：

尝试在您尝试访问 lob 字段对象的服务方法上添加 @Transactional。 它对我有用。

【讨论】：

感谢@RahuL Sharma，您的解决方案运行良好，拯救了我的一天。

【参考方案7】：

如果使用 spring，添加以下应用程序属性使其适用于我们：

spring.datasource.hikari.auto-commit