管理Hibernate Session的策略

Question

我使用Hibernate开发了一个java web应用程序。下面是一些代码：

的hibernate.cfg.xml

<property name="hibernate.dialect">org.hibernate.dialect.MySQLDialect</property> 
<property name="hibernate.connection.driver_class">com.mysql.jdbc.Driver</property> 
<property name="hibernate.connection.url">jdbc:mysql://localhost:3306/mydb?useUnicode=true&amp;characterEncoding=UTF-8&amp;connectionCollation=utf8mb4_general_ci</property> 
<property name="hibernate.connection.username">root</property> 
<property name="hibernate.connection.password">123456</property> 
<property name="hibernate.show_sql">true</property> 
<property name="hibernate.format_sql">true</property> 
<!--<property name="hibernate.connection.autocommit">true</property>--> 
<property name="hibernate.current_session_context_class">thread</property> 

BaseDAO.class

public class BaseDAO { 

public Session getSession() { 
    return HibernateUtil.getSessionFactory().openSession(); 
} 

}

我写插入，更新，删除一个通用类，发现

public class GenericDAO<T, K extends Serializable> extends BaseDAO implements IGenericDAO<T, K> { 
private Class<T> type; 

protected Class<T> getType() { 
    return this.type; 
} 

protected String getClassName() { 
    return type.getName(); 
} 

@SuppressWarnings("unchecked") 
public GenericDAO() { 
    Type t = getClass().getGenericSuperclass(); 
    ParameterizedType pt = (ParameterizedType) t; 
    type = (Class<T>) pt.getActualTypeArguments()[0]; 
} 

@Override 
public K save(T t) { 
    Session session = getSession(); 
    Transaction tran = session.beginTransaction(); 
    try { 
     K k = (K) session.save(t); 
     tran.commit(); 
     return k; 
    } catch (Exception e) { 
     if (tran.isActive()) { 
      tran.rollback(); 
     } 
     System.out.println("Sql Error : " + e.getMessage()); 
    } 
    return null; 
} 

@Override 
public void saveOrUpdate(T t) { 
    Session session = getSession(); 
    Transaction tran = session.beginTransaction(); 
    try { 
     session.saveOrUpdate(t); 
     tran.commit(); 
    } catch (Exception e) { 
     if (tran.isActive()) { 
      tran.rollback(); 
     } 
     System.out.println("Sql Error : " + e.getMessage()); 
    } 
} 

@Override 
public void update(T t) { 
    Session session = getSession(); 
    Transaction tran = session.beginTransaction(); 
    try { 
     session.update(t); 
     tran.commit(); 
    } catch (Exception e) { 
     if (tran.isActive()) { 
      tran.rollback(); 
     } 
     System.out.println("Sql Error : " + e.getMessage()); 
    } 
} 

@Override 
public void delete(T t) { 
    Session session = getSession(); 
    Transaction tran = session.beginTransaction(); 
    try { 
     session.delete(t); 
     tran.commit(); 
    } catch (Exception e) { 
     if (tran.isActive()) { 
      tran.rollback(); 
     } 
     System.out.println("Sql Error : " + e.getMessage()); 
    } 
} 

@Override 
public void delete(K k) { 
    Session session = getSession(); 
    Transaction tran = session.beginTransaction(); 
    try { 
     T t = (T) session.get(type, k); 
     session.delete(t); 
     tran.commit(); 
    } catch (Exception e) { 
     if (tran.isActive()) { 
      tran.rollback(); 
     } 
     System.out.println("Sql Error : " + e.getMessage()); 
    } 
} 

@SuppressWarnings("unchecked") 
@Override 
public T find(K id) { 
    Session session = getSession(); 
    Transaction tran = session.beginTransaction(); 
    try { 
     T t = (T) session.get(type, id); 
     tran.commit(); 
     return t; 
    } catch (Exception e) { 
     if (tran.isActive()) { 
      tran.rollback(); 
     } 
     System.out.println("Sql Error : " + e.getMessage()); 
    } 
    return null; 
} 

@SuppressWarnings("unchecked") 
@Override 
public List<T> findAll() { 
    Session session = getSession(); 
    Transaction tran = session.beginTransaction(); 
    try { 
     Query query = session.createQuery("from " + type.getSimpleName()); 
     List<T> list = query.list(); 
     tran.commit(); 
     return list; 
    } catch (Exception e) { 
     if (tran.isActive()) { 
      tran.rollback(); 
     } 
     System.out.println("Sql Error : " + e.getMessage()); 
    } 
    return new ArrayList<>(); 
} 

@SuppressWarnings("unchecked") 
@Override 
public List<T> findAllWithOrder(String column, String orderType) { 
    Session session = getSession(); 
    Transaction tran = session.beginTransaction(); 
    try { 
     if (orderType == null && orderType.equals("")) { 
      orderType = "ASC"; 
     } 
     Query query = session.createQuery(
       String.format("from %s order by %s %s", type.getSimpleName(), 
         column, orderType)); 
     tran.commit(); 
     return query.list(); 
    } catch (Exception e) { 
     if (tran.isActive()) { 
      tran.rollback(); 
     } 
     System.out.println("Sql Error : " + e.getMessage()); 
    } 
    return new ArrayList<>(); 
} 
} 

你可以看到，我不会在每种方法之后关闭会话。此代码适用于插入，更新和查找。但是当我想删除一个对象时：

TblUser user = (TblUser)find(id); 
delete(user); 

这是抛出异常，因为我使用这个函数的两个会话。 然后尝试各种方法来关闭会话：

finally{ 
    session.close(); 
} 

现在我可以删除的对象，但由于会议已经结束，每笔交易我不能使用延迟加载。

那么，我如何管理会话来克服这些情况！

Answer 1

既然你已经激活属性：

<property name="hibernate.current_session_context_class">thread</property> 

你为什么不使用：

public Session getSession() { 
    return HibernateUtil.getSessionFactory().getCurrentSession(); 
} 

不是打开一个新的会话？通过这样做，您不必担心关闭会话，因为在关闭sessionFactory时，Hibernate会关闭它。

但请注意，这不是线程安全的，所以如果您在多线程环境中工作，这不是一个好的选择。