mybatis使用之SqlSession获取

在使用mybatis的时候（先不结合spring）,一般会先创建SqlSession.

/**
*
*/
package com.odianyun.steel.test.effective;

import java.io.IOException;
import java.io.InputStream;

import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import com.ibatis.common.resources.Resources;

/**
* @author diaoxingguo
*
*/
public class MyBatisSqlSessionFactory {
private static SqlSessionFactory sqlSessionFactory;

public static SqlSessionFactory getSqlSessionFactory(){
if(null == sqlSessionFactory){
InputStream inputStream;
try {
inputStream = Resources.getResourceAsStream("mybatis-config.xml");
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
} catch (IOException e) {
e.printStackTrace();
}
}

return sqlSessionFactory;
}

public static SqlSession getSqlSession(){
return getSqlSessionFactory().openSession();
}
}

在使用sqlSession进行数据库操作的时候有两种方式。

一种是使用接口的形式。

第二种是直接调用命名空间执行sql.

public interface BookMapper{
void insertBook(Book book);
}

MyBatisSqlSessionFactory.getSqlSession().getMapper(BookMapper.class).insertBook(book);

MyBatisSqlSessionFactory.getSqlSession().insert("insertBook", book);

这篇主要看下，SqlSessionFactoryBuilder，SqlSessionFactory和SqlSession

首先看下SqlSessionFactoryBuilder，在这个类中都是build（）方法的重载，其中

public SqlSessionFactory build(InputStream inputStream, String environment, Properties properties) {
try {
XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);
return build(parser.parse());
} catch (Exception e) {
throw ExceptionFactory.wrapException("Error building SqlSession.", e);
} finally {
ErrorContext.instance().reset();
try {
inputStream.close();
} catch (IOException e) {
// Intentionally ignore. Prefer previous error.
}
}
}

public SqlSessionFactory build(Configuration config) {
return new DefaultSqlSessionFactory(config);
}

比较关键的几行有

XMLConfigBuilder parser = new XMLConfigBuilder(inputStream, environment, properties);
return build(parser.parse());

其中这个是对配置文件的解析，我在前几篇有提到过，后面还会继续分析。这里就先略过。

然后就是返回DefaultSqlSessionFactory，DefaultSqlSessionFactory是SqlSessionFactory的实现类。

然后就把配置信息Configuration注册进去了。

这样就获取了SqlSessionFactory。

下面看下DefaultSqlSessionFactory类中的方法。类中对openSession（）方法的重载也很多，参数主要包括事务隔离级别，执行的类型，数据库连接，是够自动提交。先看下没有参数的

public SqlSession openSession() {
return openSessionFromDataSource(configuration.getDefaultExecutorType(), null, false);
}

private SqlSession openSessionFromDataSource(ExecutorType execType, TransactionIsolationLevel level, boolean autoCommit) {
Transaction tx = null;
try {
final Environment environment = configuration.getEnvironment();
final TransactionFactory transactionFactory = getTransactionFactoryFromEnvironment(environment);
tx = transactionFactory.newTransaction(environment.getDataSource(), level, autoCommit);
final Executor executor = configuration.newExecutor(tx, execType);
return new DefaultSqlSession(configuration, executor, autoCommit);
} catch (Exception e) {
closeTransaction(tx); // may have fetched a connection so lets call close()
throw ExceptionFactory.wrapException("Error opening session.  Cause: " + e, e);
} finally {
ErrorContext.instance().reset();
}
}

可以看到先获取配置信息中的数据库连接，然后读取事务，默认为ManagedTransactionFactory，然后注册事务和执行类型（默认为sample）,最后返回DefaultSqlSession。