Подтвердить что ты не робот

Hibernate/Spring: не удалось лениво инициализировать - сеанс или сеанс закрыты

Для ответа прокрутите список до конца этого...

Основная проблема - это то же самое, что и заданное несколько раз. У меня есть простая программа с двумя событиями POJO и пользователем - где пользователь может иметь несколько событий.

@Entity
@Table
public class Event {
 private Long id;
 private String name;
 private User user;

 @Column
 @Id
 @GeneratedValue
 public Long getId() {return id;}
 public void setId(Long id) { this.id = id; }

 @Column
 public String getName() {return name;}
 public void setName(String name) {this.name = name;}

 @ManyToOne
 @JoinColumn(name="user_id")
 public User getUser() {return user;}
 public void setUser(User user) {this.user = user;}

}

Пользователь:

@Entity
@Table
public class User {
 private Long id;
 private String name;
 private List<Event> events;

 @Column
 @Id
 @GeneratedValue
 public Long getId() { return id; }
 public void setId(Long id) { this.id = id; }

 @Column
 public String getName() { return name; }
 public void setName(String name) { this.name = name; }

 @OneToMany(mappedBy="user", fetch=FetchType.LAZY)
 public List<Event> getEvents() { return events; }
 public void setEvents(List<Event> events) { this.events = events; }

}

Примечание. Это пример проекта. Я действительно хочу использовать здесь ленивый выбор.

Теперь нам нужно настроить spring и спящий режим и иметь простой basic-db.xml для загрузки:


<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
       xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
       xmlns:aop="http://www.springframework.org/schema/aop"
       xsi:schemaLocation="http://www.springframework.org/schema/beans 
           http://www.springframework.org/schema/beans/spring-beans-3.0.xsd
           http://www.springframework.org/schema/aop 
           http://www.springframework.org/schema/aop/spring-aop-3.0.xsd">


 <bean id="myDataSource" class="org.apache.commons.dbcp.BasicDataSource"
  destroy-method="close"  scope="thread">
  <property name="driverClassName" value="com.mysql.jdbc.Driver" />
  <property name="url" value="jdbc:mysql://192.168.1.34:3306/hibernateTest" />
  <property name="username" value="root" />
  <property name="password" value="" />
  <aop:scoped-proxy/>
 </bean>

 <bean class="org.springframework.beans.factory.config.CustomScopeConfigurer">
  <property name="scopes">
   <map>
    <entry key="thread">
     <bean class="org.springframework.context.support.SimpleThreadScope" />
    </entry>
   </map>
  </property>
 </bean>

 <bean id="mySessionFactory"
  class="org.springframework.orm.hibernate3.annotation.AnnotationSessionFactoryBean" scope="thread">
  <property name="dataSource" ref="myDataSource" />
  <property name="annotatedClasses">
   <list>
    <value>data.model.User</value>
    <value>data.model.Event</value>
   </list>
  </property>
  <property name="hibernateProperties">
   <props>
    <prop key="hibernate.dialect">org.hibernate.dialect.MySQLDialect</prop>
    <prop key="hibernate.show_sql">true</prop>
    <prop key="hibernate.hbm2ddl.auto">create</prop>
   </props>
  </property>
  <aop:scoped-proxy/>

 </bean>

 <bean id="myUserDAO" class="data.dao.impl.UserDaoImpl">
  <property name="sessionFactory" ref="mySessionFactory" />
 </bean>

 <bean id="myEventDAO" class="data.dao.impl.EventDaoImpl">
  <property name="sessionFactory" ref="mySessionFactory" />
 </bean>

</beans>

Примечание. Я играл с CustomScopeConfigurer и SimpleThreadScope, но это ничего не меняло.

У меня есть простой dao-impl (только при вставке userDao - EventDao почти то же самое, за исключением функции "listWith":


public class UserDaoImpl implements UserDao{

 private HibernateTemplate hibernateTemplate;

 public void  setSessionFactory(SessionFactory sessionFactory) {
  this.hibernateTemplate = new HibernateTemplate(sessionFactory);

 }

 @SuppressWarnings("unchecked")
 @Override
 public List listUser() {
  return hibernateTemplate.find("from User");
 }

 @Override
 public void saveUser(User user) {
  hibernateTemplate.saveOrUpdate(user);

 }

 @Override
 public List listUserWithEvent() {

  List users = hibernateTemplate.find("from User");
  for (User user : users) {
   System.out.println("LIST : " + user.getName() + ":");
   user.getEvents().size();
  }
  return users;
 }

}

Я получаю org.hibernate.LazyInitializationException - не удалось лениво инициализировать коллекцию роли: data.model.User.events, сеанс или сеанс не закрывались в строке с user.getEvents(). size();

И последнее, но не менее важное: класс Test, который я использую:


public class HibernateTest {

 public static void main(String[] args) {

  ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext("basic-db.xml");


  UserDao udao = (UserDao) ac.getBean("myUserDAO");
  EventDao edao = (EventDao) ac.getBean("myEventDAO");


  System.out.println("New user...");
  User user = new User();
  user.setName("test");

  Event event1 = new Event();
  event1.setName("Birthday1");
  event1.setUser(user);

  Event event2 = new Event();
  event2.setName("Birthday2");
  event2.setUser(user);

  udao.saveUser(user);
  edao.saveEvent(event1);
  edao.saveEvent(event2);

  List users = udao.listUserWithEvent();
  System.out.println("Events for users");
  for (User u : users) {

   System.out.println(u.getId() + ":" + u.getName() + " --");
   for (Event e : u.getEvents())
   {
    System.out.println("\t" + e.getId() + ":" + e.getName());
   }
  }

  ((ConfigurableApplicationContext)ac).close();
 }

}

и вот Исключение:

1621 [main] ERROR org.hibernate.LazyInitializationException - failed to lazily initialize a collection of role: data.model.User.events, no session or session was closed
org.hibernate.LazyInitializationException: failed to lazily initialize a collection of role: data.model.User.events, no session or session was closed
 at org.hibernate.collection.AbstractPersistentCollection.throwLazyInitializationException(AbstractPersistentCollection.java:380)
 at org.hibernate.collection.AbstractPersistentCollection.throwLazyInitializationExceptionIfNotConnected(AbstractPersistentCollection.java:372)
 at org.hibernate.collection.AbstractPersistentCollection.readSize(AbstractPersistentCollection.java:119)
 at org.hibernate.collection.PersistentBag.size(PersistentBag.java:248)
 at data.dao.impl.UserDaoImpl.listUserWithEvent(UserDaoImpl.java:38)
 at HibernateTest.main(HibernateTest.java:44)
Exception in thread "main" org.hibernate.LazyInitializationException: failed to lazily initialize a collection of role: data.model.User.events, no session or session was closed
 at org.hibernate.collection.AbstractPersistentCollection.throwLazyInitializationException(AbstractPersistentCollection.java:380)
 at org.hibernate.collection.AbstractPersistentCollection.throwLazyInitializationExceptionIfNotConnected(AbstractPersistentCollection.java:372)
 at org.hibernate.collection.AbstractPersistentCollection.readSize(AbstractPersistentCollection.java:119)
 at org.hibernate.collection.PersistentBag.size(PersistentBag.java:248)
 at data.dao.impl.UserDaoImpl.listUserWithEvent(UserDaoImpl.java:38)
 at HibernateTest.main(HibernateTest.java:44)

Все пробовали, но не работали:

  • назначить threadScope и использовать beanfactory (я использовал "запрос" или "поток" - никакой разницы не заметил):
  // scope stuff
  Scope threadScope = new SimpleThreadScope();
  ConfigurableListableBeanFactory beanFactory = ac.getBeanFactory();
  beanFactory.registerScope("request", threadScope);
  ac.refresh();
...
  • Настройка транзакции путем получения объекта сеанса из deo:
...
  Transaction tx = ((UserDaoImpl)udao).getSession().beginTransaction();
  tx.begin();
  users = udao.listUserWithEvent();
...
  • получение транзакции внутри спискаUserWithEvent()
 public List listUserWithEvent() {
  SessionFactory sf = hibernateTemplate.getSessionFactory();
  Session s = sf.openSession();
  Transaction tx = s.beginTransaction();
  tx.begin();

  List users = hibernateTemplate.find("from User");
  for (User user : users) {
   System.out.println("LIST : " + user.getName() + ":");
   user.getEvents().size();
  }
  tx.commit();
  return users;
 }

У меня действительно нет идей. Кроме того, использование listUser или listEvent просто отлично работает.

Шаг вперед:

Благодаря Тьерри я сделал еще один шаг (я думаю). Я создал класс MyTransaction и выполняю всю свою работу, получая все от spring. Новый главный выглядит следующим образом:


 public static void main(String[] args) {

  ClassPathXmlApplicationContext ac = new ClassPathXmlApplicationContext("basic-db.xml");

  // getting dao
  UserDao udao = (UserDao) ac.getBean("myUserDAO");
  EventDao edao = (EventDao) ac.getBean("myEventDAO");

  // gettting transaction template
  TransactionTemplate transactionTemplate = (TransactionTemplate) ac.getBean("transactionTemplate");

  MyTransaction mt = new MyTransaction(udao, edao);
  transactionTemplate.execute(mt);

  ((ConfigurableApplicationContext)ac).close();
 }

К сожалению, теперь есть нулевой указатель Exception @: user.getEvents(). size(); (в daoImpl).

Я знаю, что он не должен быть нулевым (ни с выхода в консоли, ни с макета db).

Вот консольный вывод для получения дополнительной информации (я проверил для user.getEvent() == null и напечатал "EVENT NULL" ):

New user...
Hibernate: insert into User (name) values (?)
Hibernate: insert into User (name) values (?)
Hibernate: insert into Event (name, user_id) values (?, ?)
Hibernate: insert into Event (name, user_id) values (?, ?)
Hibernate: insert into Event (name, user_id) values (?, ?)
List users:
Hibernate: select user0_.id as id0_, user0_.name as name0_ from User user0_
1:User1
2:User2
List events:
Hibernate: select event0_.id as id1_, event0_.name as name1_, event0_.user_id as user3_1_ from Event event0_
1:Birthday1 for 1:User1
2:Birthday2 for 1:User1
3:Wedding for 2:User2
Hibernate: select user0_.id as id0_, user0_.name as name0_ from User user0_
Events for users
1:User1 --
EVENT is NULL
2:User2 --
EVENT is NULL

Вы можете получить образец проекта из http://www.gargan.org/code/hibernate-test1.tgz (это проект eclipse/maven)

Решение (для консольных приложений)

На самом деле существует два решения этой проблемы - в зависимости от вашей среды:

Для консольного приложения вам нужен шаблон транзакции, который захватывает логику actutal db и берет на себя транзакцию:


public class UserGetTransaction implements TransactionCallback{

 public List users;

 protected ApplicationContext context;

 public UserGetTransaction (ApplicationContext context) {
  this.context = context;
 }

 @Override
 public Boolean doInTransaction(TransactionStatus arg0) {
  UserDao udao = (UserDao) ac.getBean("myUserDAO");
  users = udao.listUserWithEvent();
  return null;
 }

}

Вы можете использовать это, позвонив:


 TransactionTemplate transactionTemplate = (TransactionTemplate) context.getBean("transactionTemplate");
 UserGetTransaction mt = new UserGetTransaction(context);
 transactionTemplate.execute(mt);

Для этого вам нужно определить класс шаблона для spring (т.е. в вашем базовом db.xml):

<bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
    <property name="transactionManager" ref="transactionManager"/>
</bean>

Другое (возможное) решение

спасибо andi

    PlatformTransactionManager transactionManager = (PlatformTransactionManager) applicationContext.getBean("transactionManager");
    DefaultTransactionAttribute transactionAttribute = new DefaultTransactionAttribute(TransactionDefinition.PROPAGATION_REQUIRED);

transactionAttribute.setIsolationLevel(TransactionDefinition.ISOLATION_SERIALIZABLE);
    TransactionStatus status = transactionManager.getTransaction(transactionAttribute);
    boolean success = false;
    try {
      new UserDataAccessCode().execute();
      success = true;
    } finally {
      if (success) {
        transactionManager.commit(status);
      } else {
        transactionManager.rollback(status);
      }
    }

Решение (для сервлетов)

Сервлеты не являются проблемой. Когда у вас есть сервлет, вы можете просто начать и привязать транзакцию в начале вашей функции и снова отвязать ее в конце:

public void doGet(...) {
  SessionFactory sessionFactory = (SessionFactory) context.getBean("sessionFactory");
  Session session = SessionFactoryUtils.getSession(sessionFactory, true);
  TransactionSynchronizationManager.bindResource(sessionFactory, new SessionHolder(session));

// Your code....

  TransactionSynchronizationManager.unbindResource(sessionFactory);
}
4b9b3361

ОТВЕТЫ

Ответ 1

Я думаю, вы не должны использовать транзакционные методы сеанса спящего режима, но пусть spring сделает это.

Добавьте это в свой spring conf:

<bean id="txManager" class="org.springframework.orm.hibernate3.HibernateTransactionManager">
    <property name="sessionFactory" ref="mySessionFactory" />
</bean>

<bean id="transactionTemplate" class="org.springframework.transaction.support.TransactionTemplate">
    <property name="transactionManager" ref="txManager"/>
</bean>

а затем я бы изменил ваш метод тестирования для использования шаблона транзакции spring:

public static void main(String[] args) {
    // init here (getting dao and transaction template)

    transactionTemplate.execute(new TransactionCallback() {
        @Override
        public Object doInTransaction(TransactionStatus status) {
          // do your hibernate stuff in here : call save, list method, etc
        }
    }
}

как побочная заметка, ассоциации @OneToMany по умолчанию полны, поэтому вам не нужно комментировать его ленивым. (@* ToMany LAZY по умолчанию, @* ToOne по умолчанию EAGER)

EDIT: вот что происходит с точки спящего режима:

  • открытый сеанс (с началом транзакции)
  • сохранить пользователя и сохранить его в сеансе (см. кеш сеанса как хэш файл объекта, где ключ является идентификатором объекта)
  • сохранить событие и сохранить его в сеансе
  • сохранить другое событие и сохранить его в сеансе

  • ... то же самое со всеми операциями сохранения...

  • затем загрузите всех пользователей (запрос "от пользователей" )

  • в этом пункте hibernate увидит, что у него уже есть объект в его сеансе, поэтому отбросьте тот, который он получил от запроса, и верните его из сеанса.
  • Ваш пользователь в сеансе не инициализируется своей коллекцией событий, поэтому вы получите нуль.
  • ...

Вот некоторые моменты для улучшения вашего кода:

  • в вашей модели, когда упорядочение коллекции не требуется, используйте Set, not List для своих коллекций (private Set events, а не private List).
  • в вашей модели, введите ваши коллекции, иначе hibernate не будет удалять этот объект (частные события Set <Event> ).
  • когда вы устанавливаете одну сторону двунаправленного отношения, и вы хотите использовать сторону mappedBy отношения в той же транзакции, установите обе стороны. Hibernate не сделает это для вас до следующего tx (когда сеанс представляет собой новый вид из состояния db).

Итак, чтобы обратиться к указанному выше пункту, либо сделайте сохранение в одной транзакции, либо загрузку в другой:

public static void main(String[] args) {
    // init here (getting dao and transaction template)
    transactionTemplate.execute(new TransactionCallback() {
        @Override
        public Object doInTransaction(TransactionStatus status) {
          // save here
        }
    }

    transactionTemplate.execute(new TransactionCallback() {
        @Override
        public Object doInTransaction(TransactionStatus status) {
          // list here
        }
    }
}

или установите обе стороны:

...
event1.setUser(user);
...
event2.setUser(user);
...
user.setEvents(Arrays.asList(event1,event2));
...

(Также не забудьте обратиться к вышеперечисленным пунктам улучшения кода, Set not List, набор символов)

Ответ 2

В случае веб-приложения также можно объявить специальный фильтр в web.xml, который будет выполнять сеанс за запрос:

<filter>
    <filter-name>openSessionInViewFilter</filter-name>
    <filter-class>org.springframework.orm.hibernate3.support.OpenSessionInViewFilter</filter-class>
</filter>

<filter-mapping>
    <filter-name>openSessionInViewFilter</filter-name>
    <url-pattern>/*</url-pattern>
</filter-mapping>

После этого вы можете lazyload ваши данные в любое время во время запроса.

Ответ 3

Я здесь искал намек на аналогичную проблему. Я попробовал решение, упомянутое Тьерри, и он не работал. После этого я пробовал эти строки, и это сработало:

SessionFactory sessionFactory = (SessionFactory) context.getBean("sessionFactory");
Session session = SessionFactoryUtils.getSession(sessionFactory, true);
TransactionSynchronizationManager.bindResource(sessionFactory, new SessionHolder(session));

Действительно, то, что я делаю, это пакетный процесс, который должен использовать Spring существующих менеджеров/служб. После загрузки контекста и выполнения некоторых вызовов я основал знаменитый вопрос "не лениво инициализировать коллекцию". Эти 3 строки решили это для меня.

Ответ 4

Проблема заключается в том, что ваш dao использует один сеанс спящего режима, но ленивая загрузка имени user.getName(я предполагаю, что это то, что он выбрасывает) происходит за пределами этого сеанса - либо не в сеансе вообще, либо в другом сеансе, Обычно мы открываем сеанс спящего режима, прежде чем мы совершаем вызовы DAO и не закрываем его, пока не закончим все ленивые нагрузки. Веб-запросы обычно завертываются в большую сессию, поэтому этих проблем не происходит.

Обычно мы завершаем наши дао и ленивые вызовы в SessionWrapper. Что-то вроде следующего:

public class SessionWrapper {
    private SessionFactory sessionFactory;
    public void setSessionFactory(SessionFactory sessionFactory) {
        this.hibernateTemplate = new HibernateTemplate(sessionFactory);
    }
    public <T> T runLogic(Callable<T> logic) throws Exception {
        Session session = null;
        // if the session factory is already registered, don't do it again
        if (TransactionSynchronizationManager.getResource(sessionFactory) == null) {
            session = SessionFactoryUtils.getSession(sessionFactory, true);
            TransactionSynchronizationManager.bindResource(sessionFactory, new SessionHolder(session));
        }

        try {
            return logic.call();
        } finally {
            // if we didn't create the session don't unregister/release it
            if (session != null) {
                TransactionSynchronizationManager.unbindResource(sessionFactory);
                SessionFactoryUtils.releaseSession(session, sessionFactory);
            }
        }
    }
}

Очевидно, SessionFactory тот же SessionFactory, который был введен в ваше dao.

В вашем случае вы должны обернуть весь элемент listUserWithEvent в этой логике. Что-то вроде:

public List listUserWithEvent() {
    return sessionWrapper.runLogic(new Callable<List>() {
        public List call() {
            List users = hibernateTemplate.find("from User");
            for (User user : users) {
                System.out.println("LIST : " + user.getName() + ":");
                user.getEvents().size();
            }
        }
    });
}

Вам нужно будет ввести экземпляр SessionWrapper в свои daos.

Ответ 5

Интересно!

У меня была такая же проблема в методе обработчика @Controller @RequestMapping. Простое решение заключалось в том, чтобы добавить аннотацию @Transactional к методу обработчика, чтобы сеанс оставался открытым на всю продолжительность выполнения тела метода

Ответ 6

Самое простое решение для реализации:

В рамках сеанса [внутри API, аннотированного с помощью @Transactional] выполните следующие действия:

если A имеет список <B> который лениво загружен, просто вызовите API, который обеспечивает загрузку списка.

Что этот API?

размер(); API класса List.

Итак, все, что вам нужно:

Logger.log(a.getBList.size());

Этот простой вызов регистрации размера гарантирует, что он получит весь список перед вычислением размера списка. Теперь вы не получите исключения!

Ответ 7

Что работало для нас в JBoss, было решение № 2, взятое из этого сайта на Java Code Geeks.

web.xml:

  <filter>
      <filter-name>ConnectionFilter</filter-name>
      <filter-class>web.ConnectionFilter</filter-class>
  </filter>
  <filter-mapping>
      <filter-name>ConnectionFilter</filter-name>
      <url-pattern>/faces/*</url-pattern>
  </filter-mapping>

ConnectionFilter:

import java.io.IOException;
import javax.annotation.Resource;
import javax.servlet.*;
import javax.transaction.UserTransaction;

public class ConnectionFilter implements Filter {
    @Override
    public void destroy() { }

    @Resource
    private UserTransaction utx;

    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        try {
            utx.begin();
            chain.doFilter(request, response);
            utx.commit();
        } catch (Exception e) { }
    }

    @Override
    public void init(FilterConfig arg0) throws ServletException { }
}

Возможно, он будет работать и с Spring.