org.hibernate.HibernateException: невозможно получить доступ к потоку объектов.

Question

Я использую hibernate 3.6.7 для сопоставления классов и таблиц оракула. Я обычно не получаю это исключение:

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, поэтому я переключился на слияние, но у меня та же проблема.

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();
}

Answer 1

Попробуйте добавить @ Transactional к методу службы, где вы пытаетесь получить доступ к объекту поля lob. У меня это сработало.

Answer 2

Я полагаю, у меня было это раньше.

Когда большой объект (CLOB, BLOB) загружается из Oracle, он возвращается как ссылка на поток.Если запись отображается в спящий режим и сеанс закрывается после загрузки объекта (таким образом, объект становится отсоединенным), то сопоставляемый BLOB-объект поля Java еще не содержит данных;поэтому, когда вы пытаетесь сохранить его обратно, он не может работать с ним, потому что поток clob / blob пропал.

Для начала попробуйте продолжить загрузку и сохранение в одном сеансе.

Если я правильно помню, другой обходной путь - это "прикоснуться" к Java-полю clob / bloc, пока сеанс загрузки все еще открыт.Затем данные будут считаны из БД.Но это до боли неэффективно (это LOB по какой-то причине, то есть big ).

Еще один вариант - разбить небольшие данные и блоки на две разные таблицы и загрузить их.только при необходимости.

Надеюсь, что это поможет вам с направлением.

Answer 3

Скорее всего, я считаю, что это связано с Session бесхозяйственность. Но без просмотра большого количества кода я не могу сказать вам, в чем именно заключается проблема вашей текущей реализации.

Я считаю, threadSession является ThreadLocal. Вместо того, чтобы делать это вручную, используйте

sessionFactory.getCurrentSession();

и установите поток в конфигурационном файле hibernate.

И сделать ваш HibernateUtil простым без всех этих проверок. Лично я чувствую, что эти проверки покроют неправильное управление Сессией и другие ошибки ... Но хорошо, что это может быть только я ...

Answer 4

Я предполагаю, что у вас есть очень большое поле, поэтому оно сопоставлено с sql lob. Я подозреваю, что само отображение некорректно. Но это происходит только тогда, когда вы пытаетесь сохранить сущность с ненулевым значением. Попробуйте сохранить все ваши сущности с ненулевыми полями в приложении одно за другим. Это изолирует проблему.

Answer 5

Поскольку вы используете многопоточность, я предполагаю, что у вас могут возникнуть проблемы с транзакциями.Это может быть из-за того, что некоторые транзакции как-то зафиксированы, прежде чем вы внесете необходимые изменения в объект.Или вы пытаетесь получить доступ к объекту, сохраненному из другого потока, это означает, что объект не находится в области транзакции.

Answer 6

Возможно, это связано с драйверами JDBC, как описано в этой теме . Можете ли вы опубликовать версию Oracle и версию jar ojdbc, которую вы используете в проекте.