力所能及之关于Mybatis SqlSession工具类
小狼最近在做mybatis的CURD,发现一个小狼不能接受的问题,当然,小狼是比较懒的,见不得冗余代码
每一个CURD操作,小狼都得写一遍下面的代码,一口老血吐出来了...
SqlSessionFactoryBuilder sqlSessionFactoryBuilder = new SqlSessionFactoryBuilder(); InputStream config = Resources .getResourceAsStream("mybatities-config.xml"); SqlSessionFactory sqlSessionFactory = sqlSessionFactoryBuilder .build(config); SqlSession sqlSession = sqlSessionFactory.openSession();
为了小狼后半生幸福,决定了,写一个工具类
public class GetSqlSession { private static SqlSessionFactory sqlSessionFactory; private static ThreadLocal<SqlSession> tl = new ThreadLocal<SqlSession>(); synchronized public static SqlSessionFactory getSqlSessionFactory() { try { InputStream isRef=GetSqlSession.class.getResourceAsStream("/DBMysql.properties"); Properties properties=new Properties(); properties.load(isRef); //Log.getLog().info("properties="+properties); if (sqlSessionFactory == null) { String resource = "mybatis-config.xml"; InputStream inputStream = Resources .getResourceAsStream(resource); sqlSessionFactory = new SqlSessionFactoryBuilder() .build(inputStream,properties); } else { } } catch (IOException e) { // TODO Auto-generated catch block e.printStackTrace(); } return sqlSessionFactory; } public static SqlSession getSqlSession() { SqlSession sqlSession = tl.get(); if (sqlSession == null) { sqlSession = getSqlSessionFactory() .openSession(); tl.set(sqlSession); } else { } //System.out.println("获得的sqlSession对象的hashCode:" + sqlSession.hashCode()); return sqlSession; } public static void commit() { if (tl.get() != null) { tl.get().commit(); tl.get().close(); tl.set(null); //System.out.println("提交了"); } } public static void rollback() { if (tl.get() != null) { tl.get().rollback(); tl.get().close(); tl.set(null); //System.out.println("回滚了"); } } }
小狼上一次说了,sqlsessionFactory的生命周期是整个项目运行期间,他都会存在。但是我们采用单例懒汉模式,比较人性化。每一个线程都得使用一个sqlsession,并且sqlsession是不能共享的,它是线程不安全的,所以这就涉及到多线程的问题。我们采用ThreadLocal<SqlSession>,为每一个线程创建一个sqlsession副本,副本跟副本之间互相不影响。这样我们获得sqlsession对象的时候,直接这么写
SqlSession sqlSession = GetSqlSession.getSqlSession();大家可能发现一个问题,小狼这里写了一句
synchronized public static SqlSessionFactory getSqlSessionFactory() {
try {
InputStream isRef=GetSqlSession.class.getResourceAsStream("/DBMysql.properties");
Properties properties=new Properties();
properties.load(isRef);
//Log.getLog().info("properties="+properties);
if (sqlSessionFactory == null) {
String resource = "mybatis-config.xml";
InputStream inputStream = Resources
.getResourceAsStream(resource);
sqlSessionFactory = new SqlSessionFactoryBuilder()
.build(inputStream,properties);
} else {
}
} catch (IOException e) {
// TODO Auto-generated catch block
e.printStackTrace();
}
return sqlSessionFactory;
}
这个小狼可以解释一下,小狼用的property,属性配置mybatis-config.xml,里面的参数,所以得读出property的文件内容,并与已经读出的mybatis-config.xml文件内容匹配,得到值,注入
写完了这么多,一口老血又咽回去了。。。
郑重声明:本站内容如果来自互联网及其他传播媒体,其版权均属原媒体及文章作者所有。转载目的在于传递更多信息及用于网络分享,并不代表本站赞同其观点和对其真实性负责,也不构成任何其他建议。