Hibernate исключение на открытых сессиях. Как я могу отладить это? - PullRequest
5 голосов
/ 28 ноября 2011

Я новичок в Hybernate и борюсь со следующим исключением:

Исключение в потоке "AWT-EventQueue-0" org.hibernate.HibernateException: незаконно попытался связать прокси с двумяopen Sessions

Я получаю это при попытке удалить объект (заказ).

Мои настройки / код:

Order.hbm.xml

<hibernate-mapping>
    <class name="com.database.entities.Order" table="ORDERS">
        <id name="orderId" type="java.lang.Long">
            <column name="ORDERID" />
            <generator class="identity" />
        </id>
         <property name="product" type="java.lang.String">
            <column name="SHIP" />
        </property>
        <property name="orderDate" type="java.util.Date">
            <column name="ORDERDATE" />
        </property>        
        <property name="quantity" type="java.lang.Integer">
            <column name="QUANTITY" />
        </property>       
        <many-to-one name="customer" class="com.database.entities.Customer" fetch="join">
            <column name="CUSTOMERID"/>
        </many-to-one>
        <many-to-one name="associate" column="ASSOCIATEID" class="com.database.entities.Employee" fetch="join">            
        </many-to-one>
    </class>
</hibernate-mapping>

Держатель сеанса:

public class DBSession {


    private static SessionFactory sessionFactory;

    static{     
        Configuration cfg = new Configuration();        
        sessionFactory = cfg.configure().buildSessionFactory();     
    }

    public static SessionFactory getSessionFactory() {
        return sessionFactory;      
    }

    public static void shutdown() {
        getSessionFactory().close();        
    }       



}

И все соответствующие DAO расширяют следующее:

public abstract class GenericDAO<T, ID extends Serializable> implements GenericDAOIF<T, ID> {

    private Class<T> persistentClass;
    private Session session;



    public Session getSession() {
        if(session == null || !session.isOpen()){
            session = DBUtil.getSessionFactory().openSession();
        }

        return session;
    }

    public void setSession(Session session) {
        this.session = session;
    }



    @SuppressWarnings("unchecked")
    @Override
    public T findById(ID id, boolean lock) {

        T entity;

        if(lock)
            entity = (T) getSession().load(getPersistentClass(), id, LockMode.UPGRADE);
        else
            entity = (T) getSession().load(getPersistentClass(), id);

        return entity;
    }



    @Override
    public T makePersistent(T entity) {
        getSession().beginTransaction();
        getSession().saveOrUpdate(entity);
        flush();
        getSession().getTransaction().commit();
        return entity;
    }

    @Override
    public void flush() {
        getSession().flush();

    }

    @Override
    public void clear() {
        getSession().clear();

    }

    @Override
    public void makeTransient(T entity) {
        getSession().getTransaction().begin();
        getSession().delete(entity);
        getSession().getTransaction().commit();


    }


}

В то время как все другие запросы работают (например, вставка / выбор для других объектов и порядка), когда я пытаюсь удалить заказ, я получаю следующее исключение в следующей части кода GenericDAO:

public void makeTransient(T entity) {
    getSession().getTransaction().begin();
    getSession().delete(entity);//--> Exception here
    getSession().getTransaction().commit();


}

Трассировка стека исключений:

Exception in thread "AWT-EventQueue-0" org.hibernate.HibernateException: illegally attempted to associate a proxy with two open Sessions
    at org.hibernate.proxy.AbstractLazyInitializer.setSession(AbstractLazyInitializer.java:126)
    at org.hibernate.engine.StatefulPersistenceContext.reassociateProxy(StatefulPersistenceContext.java:573)
    at org.hibernate.engine.StatefulPersistenceContext.unproxyAndReassociate(StatefulPersistenceContext.java:618)
    at org.hibernate.event.def.DefaultDeleteEventListener.onDelete(DefaultDeleteEventListener.java:89)
    at org.hibernate.event.def.DefaultDeleteEventListener.onDelete(DefaultDeleteEventListener.java:73)
    at org.hibernate.impl.SessionImpl.fireDelete(SessionImpl.java:956)
    at org.hibernate.impl.SessionImpl.delete(SessionImpl.java:934)
    at com.dao.GenericDAO.makeTransient(GenericDAO.java:100)
    at com.ui.panels.AdminDBPanel$11.actionPerformed(AdminDBPanel.java:414)
    at javax.swing.AbstractButton.fireActionPerformed(Unknown Source)
    at javax.swing.AbstractButton$Handler.actionPerformed(Unknown Source)

Это происходит только тогда, когда я удаляю заказ (поэтому я разместил только эту часть кода).

Я не понимаю, что означает это исключение.
Но при поиске в Google я попробовал следующее, которое не работает:
1) Объединение с сессией:

@Override
public void makeTransient(T entity) {
        getSession().merge(entity);  
    getSession().getTransaction().begin();
    getSession().delete(entity);
    getSession().getTransaction().commit();


}

2) Закрытие сессии и повторное ее открытие:

public Session getSession() {
    if(session == null || !session.isOpen()){
        session = DBUtil.getSessionFactory().openSession();
    }
            else{
                 session.close();
                 session = DBUtil.getSessionFactory().openSession();
            }

    return session;
}

Я застрял на том, как отладить это.

Любые входные данные приветствуются

ОБНОВЛЕНИЕ:

Дополнительная информация:
Отображение сотрудников:

<hibernate-mapping>
    <class name="com.database.entities.Employee" table="ASSOCIATE">
        <id name="assosiateId" type="java.lang.Long">
            <column name="ASSOCIATEID" />
            <generator class="identity" />
        </id>
        <property name="firstName" type="java.lang.String" not-null="true">
            <column name="FIRSTNAME" />
        </property>
        <property name="lastName" type="java.lang.String" not-null="true">
            <column name="LASTNAME" />
        </property>
        <property name="userName" type="java.lang.String" not-null="true">
            <column name="USERNAME" />
        </property>
        <property name="password" type="java.lang.String" not-null="true">
            <column name="PASSWORD" />
        </property>
        <set name="orders" table="ORDERS" inverse="true" cascade="all" lazy="true">
            <key>
                <column name="ASSOCIATEID" />
            </key>
            <one-to-many class="com.database.entities.Order" />
        </set>
    </class>
</hibernate-mapping>

<hibernate-mapping>
    <class name="com.database.entities.Customer" table="CUSTOMER">
        <id name="customerId" type="java.lang.Long">
            <column name="CUSTOMERID" />
            <generator class="identity" />
        </id>
        <property name="customerName" type="java.lang.String">
            <column name="CUSTOMERNAME" />
        </property>
        <set name="orders" table="ORDERS" inverse="true" cascade="all" lazy="true">
            <key>
                <column name="CUSTOMERID" />
            </key>
            <one-to-many class="com.database.entities.Order" />
        </set>
    </class>
</hibernate-mapping>  

Отображение клиента:

<hibernate-mapping>
    <class name="com.database.entities.Customer" table="CUSTOMER">
        <id name="customerId" type="java.lang.Long">
            <column name="CUSTOMERID" />
            <generator class="identity" />
        </id>
        <property name="customerName" type="java.lang.String">
            <column name="CUSTOMERNAME" />
        </property>
        <set name="orders" table="ORDERS" inverse="true" cascade="all" lazy="true">
            <key>
                <column name="CUSTOMERID" />
            </key>
            <one-to-many class="com.database.entities.Order" />
        </set>
    </class>
</hibernate-mapping>

OrderDAO:

public class OrderDAO extends GenericDAO<Order, Long> implements OrderDAOIF {

    @Override
    public void addOrder(Order order, Customer customer, Associate associate) {
        Session session = getSession();
        Transaction tx = session.beginTransaction();
        order.setAssociate(associate);
        order.setCustomer(customer);

        session.saveOrUpdate(order);

        tx.commit();
        session.close();        
    }

    @Override
    public void updateOrderStatus(String status, Long orderId) {

        Order order = findById(orderId, false);
        order.setOrderState(status);
        Session session = getSession();
        Transaction tx = session.beginTransaction();
        session.saveOrUpdate(order);
        tx.commit();
        session.close();


    }


}

Код, который запускает исключение:

Order order = getFactory().getOrderDAO().findById(Long.valueOf(orderId), false);
getFactory().getOrderDAO().makeTransient(order);//--> Exception thrown here

1 Ответ

7 голосов
/ 28 ноября 2011

Ошибка означает, что вы пытаетесь связать объект, загруженный в одном сеансе, с другим сеансом. Есть большая проблема с тем, как вы делаете управление сессиями, но я не могу комментировать это без гораздо большей информации. Работа с слиянием, которую вы пробовали, может решить проблему простым изменением - используйте ссылку, возвращаемую методом слияния, для дальнейшей операции.

@Override
public void makeTransient(T entity) {
    T newEntityRef =    getSession().merge(entity);  
    getSession().getTransaction().begin();
    getSession().delete(newEntityRef);
    getSession().getTransaction().commit();
}

Проблема связана с этим фрагментом кода.

Order order = getFactory().getOrderDAO().findById(Long.valueOf(orderId), false);
getFactory().getOrderDAO().makeTransient(order);//--> Exception thrown here

Предполагая, что getOrderDao () создает новый экземпляр класса OrderDao. Вызов findById использует новый экземпляр сеанса (давайте назовем его s1) для загрузки объекта. Загруженный объект - это прокси, который связан с сеансом, который использовался для его загрузки. Затем при следующем вызове создается новый OrderDAO (путем вызова метода getOrderDAO) - теперь, когда вызывается makeTransient, создается новый сеанс (давайте назовем этот s2). Теперь вы пытаетесь передать прокси, загруженный с s1, на s2 - это то, что указывает исключение. Метод слияния берет объект и либо создает новый объект в s2, либо объединяет содержимое с существующим объектом - в любом случае переданный входной объект не изменяется - созданный новый объект будет возвращаемым значением.

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

OrderDao orderDao = getFactory().getOrderDAO();
Order order = orderDao.findById(Long.valueOf(orderId), false);
orderDao.makeTransient(order);

Другая проблема с приведенным выше кодом заключается в том, что сессия не закрывается. Каждый сеанс использует соединение JDBC - поэтому это приведет к утечке соединения.

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

http://community.jboss.org/wiki/SessionsAndTransactions

http://community.jboss.org/wiki/GenericDataAccessObjects

...