從Mybatis源碼到Spring動態(tài)數(shù)據(jù)源底層原理分析、Mybatis初始化源碼淺析

一、引入

本系列文章最終的目標是為了分析spring動態(tài)數(shù)據(jù)源的原理, 相信大家在公司的開發(fā)中應該都會遇到一個項目中出現(xiàn)多個數(shù)據(jù)庫連接的情況, 以我遇到的一種情況來說, 用戶根據(jù)id分布在不同的數(shù)據(jù)庫, 每個數(shù)據(jù)庫中的表結(jié)構(gòu)一模一樣, 這就會導致, 在執(zhí)行業(yè)務代碼的時候, 不同的用戶需求在不同的數(shù)據(jù)庫中執(zhí)行對應的sql, 即在mybatis作為持久層框架的情況下, 一個mapper可能會在不同的情況下, 對不同的數(shù)據(jù)庫進行操作, 這就需要我們有能夠執(zhí)行動態(tài)數(shù)據(jù)源的功能, 而在這其中, 最重要的一部分就是事務了(不是分布式事務, 應該屬于動態(tài)事務), @Transactional中標注的業(yè)務邏輯, 在不同的數(shù)據(jù)源下需要執(zhí)行不同數(shù)據(jù)庫的事務, 為了能夠清晰的了解到spring-mybatis是如何聯(lián)動實現(xiàn)動態(tài)數(shù)據(jù)源, 以及實現(xiàn)動態(tài)事務的原理, 我們從mybatis的源碼開始分析, 到spring整合mybatis的原理, 到spring事務原理, 最終來展示動態(tài)數(shù)據(jù)源情況下動態(tài)事務的原理

注意事項, mybatis源碼相對于之前我分析的spring、springmvc的源碼來說, 會更加的簡單, 但是我不會把每一個細節(jié)都分析的非常底層, 而是從一個整體的流程出發(fā)進行分析, 在對mybatis有一個整體的認知之后, 如果想深入的了解某一塊的內(nèi)容, 那么會變得非常輕松, 舉個例子, 對于如何將一個這樣的標簽解析并得到對應的實體類對象這樣的內(nèi)容不會進行分析(這里面其實就是一些xml的解析以及對嵌套查詢的處理而已)

二、配置文件整體概覽

2.1、簡單的描述

我們以xml格式下的mybatis文件進行分析, 這是相對比較傳統(tǒng)的, 而目前大家都是基于springboot進行開發(fā), 在這種情況下, 只不過是將對mybatis配置文件的解析變成了對application.yml文件的解析, 進而得到對應的mybatis配置對象而已, 之后我們在分析spring整合mybatis的時候, 也會分析這一塊, 從xml文件入手, 我們之后會能夠更加的清晰springboot是如何剔除了mybatis-config這樣的配置文件的

2.2、配置文件

------ mybatis-con.xml ------

configuration
		  PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
		  "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
	<environments default="development">
		<environment id="development">
			<transactionManager type="JDBC"/>
			<dataSource type="POOLED">
				<property name="driver" value="com.mysql.cj.jdbc.Driver"/>
				<property name="url" value="jdbc:mysql://dev1-linux.pospal.cn:3306/pospal?serverTimezone=GMT%2B8&useUnicode=true&characterEncoding=UTF-8&useSSL=true&allowMultiQueries=true"/>
				<property name="username" value="xxx"/>
				<property name="password" value="xxx"/>
			dataSource>
		environment>
	environments>
	<mappers>
		<mapper resource="mapper/CustomerMapper.xml"/>
	mappers>
configuration>


------ CustomerMapper.xml ------

mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<mapper namespace="com.fightzhong.mapper.CustomerMapper">
	<select id="selectRemarksById" parameterType="int" resultType="String" >
		select remarks
		from customer where id = #{id}
	select>
mapper>
復制代碼

2.3、config文件分析

其實mybatis在初始化的時候就是對上面這些配置文件進行xml解析而已, 將它們解析成一個個的java對象存儲起來, 首先我們來看看mybatis-con.xml這個文件, configuration對象, 故名思義, 就是mybatis的配置, 在mybatis初始化的時候, 會將其解析成一個Configuration對象, 而environment對象也是一樣, 會將其解析成一個Environment對象, environments標簽中可以配置多個environment標簽, 通過default來表示默認生效哪一個, 在environment中, 則表示的是當前環(huán)境下的數(shù)據(jù)庫配置信息, 其中包括事務工廠(用于創(chuàng)建事務的factory)、數(shù)據(jù)源等, 所以以上配置映射成java對象即如下:

class Configuration {
    private Environment environment;

    private Map mappedStatements;
}

class Environment {
    private TransactionFactory transactionFactory;

    private DataSource dataSource;
}
復制代碼

非常清晰的映射關系, 一個環(huán)境里面包含了數(shù)據(jù)源以及事務工廠, 如果不是很理解事務工廠的用處, 可以先不用著急, 我們后面的文章會進行詳細的分析, 在本小節(jié), 只是為了告訴大家, 一個mybatis的配置文件, 最終其實是以java對象保存的, 而xml中的標簽層級, 其實就是對應了對象中的屬性層級

2.4、mapper文件分析

對于xxxMapper.xml這些文件, mybatis中通過mapper標簽的namespace + select / update等標簽中的id構(gòu)成一個唯一標識(假設為statementId), 每一個sql標簽以MappedStatement的對象的形式保存在Configuration對象中, 在上面的Configuration中, 以statementId -> MappedStatement 形成一個映射關系, 而MappedStatement中則存儲了一個select等類型的標簽中的所有內(nèi)容, 比如parameterType, resultType, resultMap, sql等, 當我們在觸發(fā)sql執(zhí)行的時候, 即通過statementId找到對應的MappedStatement, 取出里面的sql來執(zhí)行, 然后利用resulthandler以及resultType或者resultMap等信息對結(jié)果集進行封裝映射, 最后返回

在日常的開發(fā)中, 我們面向接口編程, 會定義一個個的Mapper接口類, 當執(zhí)行這些接口方法的時候, 代理對象會利用接口的全路徑類名 + 接口方法名構(gòu)成一個statementId, 進而獲取到對應的MappedStatement, 然后從中提取sql, 執(zhí)行sql, 最后將結(jié)果集利用MappedStatement中的保存的resultMap等信息映射成對應的java對象

2.5、總結(jié)

mybatis-con.xml這樣的配置文件, 以Configuration對象存儲, 表示整個mybatis的配置文件, 里面包含了一個環(huán)境(當前mybatis中對應的數(shù)據(jù)源以及事務工廠)以及所有的Mapper文件中一個個sql標簽解析出來后的MappedStatement對象, xml文件的層次對應了java對象中的屬性層次, MappedStatement中包含了一個sql標簽需要執(zhí)行的所有信息, 包括sql、動態(tài)sql解析需要的數(shù)據(jù)以及通過jdbc查詢到的結(jié)果集如果處理的信息

3、配置文件初始化源碼分析

3.1、代碼引入

public static void main(String[] args) {
    SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(Resources.getResourceAsStream( "mybatis-con.xml" ) );
    SqlSession sqlSession = sqlSessionFactory.openSession();
    List