Hibernate中的ThreadLocal类
我们知道,Session是Hibernate运行的核心,通过它来对对象的生命周期,事务的管理和数据库的存取进行管理。
首先我们来看一下threadLocal类。
我们从上一篇文章已经知道,SessionFactory是线程安全的,不同的线程对它的实例进行调用,不会发生数据共享方面的问题。而 Session是又SessionFactory创建的,它却不是线程安全的,我们不能让session来进行数据共享。为了解决这个问题我们引入了 ThreadLocal类。下面看一下代码:
Java代码
1. package com.jnotnull;
2. import org.hibernate.*;
3. import org.hibernate.cfg.*;
4. public class SessionTest{
5. private static final SessionFactory sessionFactory;
6. static{
7. try{
8. sessionFactory = new Configuration().configure().buildSessionFactory();
9. }catch(Exception e){
10. }
11.
12. public static final ThreadLocal threadlocal = new ThreadLocal();
13. public static Session currentSession(){
14. Session s = (Session)threadlocal.get();
15. if(s==null){
16. s=sessionFactory.openSession();
17. threadlocal.set(s);
18. }
19. return s;
20. }
21. }
22.
23. public static void closeSession(){
24. Session s =(Session)threadlocal.get();
25. if(s != null)
26. s.close();
27. threadlocal.set(null);
28. }
29.
30. }
package com.jnotnull;
import org.hibernate.*;
import org.hibernate.cfg.*;
public class SessionTest{
private static final SessionFactory sessionFactory;
static{
try{
sessionFactory = new Configuration().configure().buildSessionFactory();
}catch(Exception e){
}
public static final ThreadLocal threadlocal = new ThreadLocal();
public static Session currentSession(){
Session s = (Session)threadlocal.get();
if(s==null){
s=sessionFactory.openSession();
threadlocal.set(s);
}
return s;
}
}
public static void closeSession(){
Session s =(Session)threadlocal.get();
if(s != null)
s.close();
threadlocal.set(null);
}
}
这里我们可以看到运用 ThreadLocal,可以在每一个线程中创建一个单独的Session,这样就保证了线程的安全了。
这里还要注意的是,这里的Session是保留着对各种操作的结果,和http中的session是不同的。