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

Я использую 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. Через много потоков я snychronized эту часть в моем коде. Я думаю, что мы все время подключаемся к базе данных, но это дает возможность отключить закрытую связь. Может кто-нибудь, пожалуйста, дайте мне некоторое предложение об этом исключении. Какая проблема должна быть?

Я думал, что это может быть из-за использования 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();
}

Ответы

Ответ 1

Я считаю, что раньше у меня был этот.

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

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

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

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

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

Ответ 2

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

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

sessionFactory.getCurrentSession();

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

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

Ответ 3

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

Ответ 4

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

Ответ 5

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