1.MyBatis的基本構(gòu)成
- SqlSessionFactoryBuilder(構(gòu)造器)
它會根據(jù)配置信息或者代碼生成SqlSessionFactory(工廠接口)
- SqlSessionFactory
依靠工廠來生成SqlSession 會話
- SqlSession
是一個既可以發(fā)送 SQL去執(zhí)行并返回結(jié)果,也可以獲取Mapper的接口
- SQL Mapper
它是MyBatis新設(shè)計的組件,它是由一個Java接口和Xml文件(或者注解)構(gòu)成的,需要給出對應(yīng)的SQL和映射規(guī)劃。它負責(zé)發(fā)送SQL去執(zhí)行,并返回接口

2.構(gòu)建SqlSessionFactory
每個MyBatis的應(yīng)用都是以SqlSessionFactory的實例為中心。SqlSessionFactory的實例可以通過SqlSessionFactoryBuilder獲得。
- SqlSessionFactory是接口類
public interface SqlSessionFactory {
SqlSession openSession();
SqlSession openSession(boolean autoCommit);
SqlSession openSession(Connection connection);
SqlSession openSession(TransactionIsolationLevel level);
SqlSession openSession(ExecutorType execType);
SqlSession openSession(ExecutorType execType, boolean autoCommit);
SqlSession openSession(ExecutorType execType, TransactionIsolationLevel level);
SqlSession openSession(ExecutorType execType, Connection connection);
Configuration getConfiguration();
}
SqlSessionFactory的任務(wù)是創(chuàng)建SqlSession。
SqlSession是類似一個JDBC的Connection對象。
- JBDC的Connection的作用
private Connection getConnection() throws ClassNotFoundException, SQLException {
Connection connection = null;
Class.forName("com.mysql.jdbc.Driver");
String url = "jdbc:mysql://localhost:3306/mybatis";
String user = "root";
String password = "root";
connection = DriverManager.getConnection(url, user, password);
return connection;
}
2.1 MyBatis的構(gòu)建代碼
public static void main(String[] args) throws IOException {
//讀取mybatis-config.xml文件
InputStream inputStream = Resources.getResourceAsStream("mybatis-config.xml");
//初始化mybatis,創(chuàng)建SqlsessionFactory類的實例
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
//創(chuàng)建Sqlsession實例
SqlSession sqlSession = sqlSessionFactory.openSession();
//獲取User Dao的實例
UserDao dao = sqlSession.getMapper(UserDao.class);
User user = dao.getUser(1);
System.out.println(user.toString());
}
從上面的代碼可以看出,build方法是真正創(chuàng)建SqlSessionFactory的核心代碼
- 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.
}
}
}
- parse()方法
public Configuration parse() {
if (parsed) {
throw new BuilderException("Each XMLConfigBuilder can only be used once.");
}
parsed = true;
parseConfiguration(parser.evalNode("/configuration"));
return configuration;
}
parse方法就是讀取xml的信息,并將xml的信息寫入到org.apache.ibatis.session.Configuration實例對象中。而這個對象是存在于整個MyBatis應(yīng)用的生命周期中,以便重復(fù)讀取和運用。
2.2 SqlSessionFactory的實現(xiàn)類
- 1.SqlSessionManager
- 2.DefaultSqlSessionFactory
3.構(gòu)建方式
3.1 使用xml方式構(gòu)建
- 1.定義MyBatis全局xml配置
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
"http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
<!--定義別名-->
<typeAliases>
<typeAlias type="model.User" alias="user"/>
</typeAliases>
<!--定義數(shù)據(jù)庫信息-->
<!--默認使用id為mysqldata的數(shù)據(jù)庫作為應(yīng)用程序的開發(fā)數(shù)據(jù)庫-->
<environments default="mysqldata">
<environment id="mysqldata">
<!--采用jdbc事務(wù)管理-->
<transactionManager type="JDBC" />
<dataSource type="POOLED">
<property name="driver" value="com.mysql.jdbc.Driver" />
<property name="url" value="jdbc:mysql://localhost:3306/mybatis" />
<property name="username" value="root" />
<property name="password" value="root" />
</dataSource>
</environment>
</environments>
<!--定制映射器-->
<mappers>
<mapper resource="mapper/UserDao.xml" />
</mappers>
</configuration>
- 2.定義xml映射器
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >
<mapper namespace="dao.UserDao">
<select id="getUser" parameterType="int" resultType="user">
select * from tb_user where id=#{id};
</select>
</mapper>
這個文件我們在mybatis-config.xml中配置了,所以MyBatis會讀取這個配置文件,生成映射器
這里的命名空間名稱與持久層的接口的名稱一致
用一個select元素定義了一個查詢SQL,id為getUser。這需要跟下面的持久層接口名稱一致。并且參數(shù)類型也必須與持久層的參數(shù)一樣。這里返回的參數(shù)為user。這個是別名我們在mybatis-config.xml里面定義的。
- 3.定義持久層接口
public interface UserDao {
User getUser(int id);
}
- 4.客戶端調(diào)用
public class MyBatisClient {
public static void main(String[] args) throws IOException {
//讀取mybatis-config.xml文件
InputStream inputStream = Resources.getResourceAsStream("mybatis-config.xml");
//初始化mybatis,創(chuàng)建SqlsessionFactory類的實例
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
//創(chuàng)建Sqlsession實例
SqlSession sqlSession = sqlSessionFactory.openSession();
//獲取User Dao的實例
UserDao dao = sqlSession.getMapper(UserDao.class);
User user = dao.getUser(1);
System.out.println(user.toString());
}
}
映射器的功能就是提供SQL和SQL對POJO的映射規(guī)則定義。
3.2 使用代碼方式構(gòu)建
除了使用xml的配置的方式創(chuàng)建代碼外,也可以使用Java編碼來實現(xiàn)。不過當我們在需要修改環(huán)境的時候,我們需要重新編譯代碼,不利于維護。
- 1.定義Java代碼映射器
public interface UserDaoJavaCode {
@Select("select * from tb_user where id=#{id}")
User getUser(int id);
}
{id}為這條SQL的請求參數(shù)。因為定義的實體名稱與數(shù)據(jù)庫的屬性名稱一樣。那么MyBatis就會把這條語句的查詢結(jié)果自動映射到我們需要的POJO屬性上。
Java實體上注解的SQL語句與xml上的SQL沒有差別,但是如果SQL復(fù)雜的話,使用xml來描述SQL語句遠比在Java實體上方便。
- 2.客戶端調(diào)用及注冊MyBatis環(huán)境信息
public class MyBatisCodeClient {
public static void main(String[] args) {
SqlSessionFactory sqlSessionFactory = getSqlSessionFactory();
//創(chuàng)建Sqlsession實例
SqlSession sqlSession = sqlSessionFactory.openSession();
//獲取User Dao的實例
UserDaoJavaCode dao = sqlSession.getMapper(UserDaoJavaCode.class);
User user = dao.getUser(1);
System.out.println(user.toString());
}
private static PooledDataSource getDataSource() {
PooledDataSource dataSource = new PooledDataSource();
dataSource.setDriver("com.mysql.jdbc.Driver");
dataSource.setUrl("jdbc:mysql://localhost:3306/mybatis");
dataSource.setUsername("root");
dataSource.setPassword("root");
return dataSource;
}
private static SqlSessionFactory getSqlSessionFactory() {
TransactionFactory transactionFactory = new JdbcTransactionFactory();
Environment environment = new Environment("development", transactionFactory, getDataSource());
Configuration configuration = new Configuration(environment);
configuration.getTypeAliasRegistry().registerAlias("user", User.class);
configuration.addMapper(UserDaoJavaCode.class);
SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(configuration);
return sqlSessionFactory;
}
}
3.3 使用"命名空間(namespace)+SQL id"獲取數(shù)據(jù)
這種方式是MyBatis原始版本的iBatis的獲取數(shù)據(jù)方式
- 使用getMapper獲取數(shù)據(jù)對象
UserDao dao = sqlSession.getMapper(UserDao.class);
User user = dao.getUser(1);
System.out.println(user.toString());
- 使用原始獲取數(shù)據(jù)方式
User user=sqlSession.selectOne("getUser",1);
System.out.println(user);
getUser為定義的SQL語句的id。如果SQL語句名稱全局定義兩個相同或更多,那么需要加上對應(yīng)的包的名稱
4.MyBatis的生命周期
4.1 SqlSessionFactoryBuilder
其作用是利用XML或者Java編碼獲取資源來構(gòu)建SqlSessionFactory的。通過它可以構(gòu)建多個SessionFactory。相當于一個構(gòu)建器,一旦構(gòu)建完成后,作用就消失。這時候我們應(yīng)該回收它
4.2 SqlSessionFactory
其作用是創(chuàng)建SqlSession,而SqlSession就是一個會話,相當于JDBC的Connection對象。每次應(yīng)用程序需要訪問數(shù)據(jù)庫,我們就要通過SqlSessionFactory創(chuàng)建SqlSession。
所以SqlSessionFactory的應(yīng)該在MyBatis應(yīng)用的整個生命周期內(nèi)。而如果我們多次創(chuàng)建同一個數(shù)據(jù)庫的SqlSessionFactory,每次創(chuàng)建SqlSessionFactory會打開更多的數(shù)據(jù)庫連接(Connection)資源。所以應(yīng)該使用單例模式去維護這個對象
4.3 SqlSession
SqlSession是一個會話,相當于JDBC的Connection對象,所以它的生命周期應(yīng)該是在請求數(shù)據(jù)庫處理事務(wù)的過程中。它是一個線程不安全的對象。在涉及多線程的時候需要特別注意。操作數(shù)據(jù)庫需要注意其隔離級別,數(shù)據(jù)庫鎖等高級對象。
4.4 Mapper
Mapper是一個接口,沒有實現(xiàn)任何實現(xiàn)類,它的作用是發(fā)送SQL,然后返回我們需要的結(jié)果,或者執(zhí)行SQL從而修改數(shù)據(jù)庫的數(shù)據(jù)。它應(yīng)該在一個SqlSession事務(wù)方法之內(nèi)。如同JDBC的一條SQL語句的執(zhí)行。生命周期與SqlSession相同。

5.優(yōu)化后的代碼
- 1.新建一個SqlSessionFactoryUtil工具類,維護單例模型
package utils;
import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;
import java.io.IOException;
import java.io.InputStream;
import java.util.logging.Level;
import java.util.logging.Logger;
public class SqlSessionFactoryUtil {
private static SqlSessionFactory sqlSessionFactory = null;
//類線程鎖
private static final Class CLASS_LOCK = SqlSessionFactoryUtil.class;
/**
* 私有化構(gòu)造函數(shù)
*/
private SqlSessionFactoryUtil() {
}
public static SqlSessionFactory inintSqlSessionFactory() {
String resource = "mybatis-config.xml";
InputStream inputStream = null;
try {
inputStream = Resources.getResourceAsStream(resource);
} catch (IOException ex) {
Logger.getLogger(SqlSessionFactoryUtil.class.getName()).log(Level.SEVERE, null, ex);
}
synchronized (CLASS_LOCK) {
if (sqlSessionFactory == null)
sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
}
return sqlSessionFactory;
}
public static SqlSession openSqlSession() {
if (sqlSessionFactory == null)
inintSqlSessionFactory();
return sqlSessionFactory.openSession();
}
}
- 2.調(diào)用客戶端
import dao.UserDao;
import model.User;
import org.apache.ibatis.session.SqlSession;
import utils.SqlSessionFactoryUtil;
public class MyBatisOptimizeClient {
public static void main(String[] args) {
SqlSession sqlSession = SqlSessionFactoryUtil.openSqlSession();
UserDao userMapper = sqlSession.getMapper(UserDao.class);
User user = userMapper.getUser(1);
System.out.println(user);
}
}