MyBatis連接池的深入和動(dòng)態(tài)SQL詳解
一，Mybatis 連接池與事務(wù)深入
1.1 Mybatis 的連接池技術(shù)
Mybatis 中連接池技術(shù)，它采用的是自己的連接池技術(shù)。在 Mybatis 的 SqlMapConfig.xml 配置文件中，通過(guò)來(lái)實(shí)現(xiàn) Mybatis 中連接池的配置。
1.1.1 Mybatis 連接池的分類
在 Mybatis 中我們將它的數(shù)據(jù)源 dataSource 分為以下幾類：
可以看出 Mybatis 將它自己的數(shù)據(jù)源分為三類：
UNPOOLED不使用連接池的數(shù)據(jù)源POOLED使用連接池的數(shù)據(jù)源JNDI使用 JNDI 實(shí)現(xiàn)的數(shù)據(jù)源
具體結(jié)構(gòu)如下：
相應(yīng)地，MyBatis 內(nèi)部分別定義了實(shí)現(xiàn)了 java.sql.DataSource 接口的 UnpooledDataSource，PooledDataSource 類來(lái)表示 UNPOOLED、POOLED 類型的數(shù)據(jù)源。
在這三種數(shù)據(jù)源中，我們一般采用的是 POOLED 數(shù)據(jù)源（很多時(shí)候我們所說(shuō)的數(shù)據(jù)源就是為了更好的管理數(shù)據(jù)庫(kù)連接，也就是我們所說(shuō)的連接池技術(shù)）。
1.1.2 Mybatis 中數(shù)據(jù)源的配置
MyBatis 在初始化時(shí)，根據(jù)的 type 屬性來(lái)創(chuàng)建相應(yīng)類型的的數(shù)據(jù)源 DataSource，即：
- type=”POOLED”：MyBatis 會(huì)創(chuàng)建 PooledDataSource 實(shí)例
- type=”UNPOOLED” ： MyBatis 會(huì)創(chuàng)建 UnpooledDataSource 實(shí)例
- type=”JNDI”：MyBatis 會(huì)從 JNDI 服務(wù)上查找 DataSource 實(shí)例，然后返回使用
我們的數(shù)據(jù)源配置就是在 SqlMapConfig.xml 文件中，具體配置如下：
<!-- 配置數(shù)據(jù)源（連接池）信息 -->?
<dataSource type="POOLED">?
?? ?<property name="driver" value="${jdbc.driver}"/>
?? ?<property name="url" value="${jdbc.url}"/>
?? ?<property name="username" value="${jdbc.username}"/>
?? ?<property name="password" value="${jdbc.password}"/>
</dataSource>1.2 Mybatis 的事務(wù)控制
1.2.1 JDBC 中事務(wù)的回顧
在 JDBC 中我們可以通過(guò)手動(dòng)方式將事務(wù)的提交改為手動(dòng)方式，通過(guò) setAutoCommit()方法就可以調(diào)整。
通過(guò) JDK 文檔，我們找到該方法如下：
那么我們的 Mybatis 框架因?yàn)槭菍?duì) JDBC 的封裝，所以 Mybatis 框架的事務(wù)控制方式，本身也是用 JDBC 的setAutoCommit()方法來(lái)設(shè)置事務(wù)提交方式的。
1.2.2 Mybatis 中事務(wù)提交方式
Mybatis 中事務(wù)的提交方式，本質(zhì)上就是調(diào)用 JDBC 的 setAutoCommit()來(lái)實(shí)現(xiàn)事務(wù)控制。
我們運(yùn)行之前所寫(xiě)的代碼：
@Test
public void testSaveUser() throws Exception {
User user = new User();
user.setUsername("mybatis user09");
//6.執(zhí)行操作
int res = userDao.saveUser(user);
System.out.println(res);
System.out.println(user.getId());
}
@Before//在測(cè)試方法執(zhí)行之前執(zhí)行
public void init()throws Exception {
//1.讀取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創(chuàng)建構(gòu)建者對(duì)象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3.創(chuàng)建 SqlSession 工廠對(duì)象
factory = builder.build(in);
//4.創(chuàng)建 SqlSession 對(duì)象
session = factory.openSession();
//5.創(chuàng)建 Dao 的代理對(duì)象
userDao = session.getMapper(IUserDao.class);
}
@After//在測(cè)試方法執(zhí)行完成之后執(zhí)行
public void destroy() throws Exception{
//7.提交事務(wù)
session.commit();
//8.釋放資源
session.close();
in.close();
}
默認(rèn) setAutoCommit()方法，在執(zhí)行時(shí)它的值被設(shè)置為 false 了，所以我們?cè)?CUD 操作中，必須通過(guò) sqlSession.commit()方法來(lái)執(zhí)行提交操作。
1.2.3 Mybatis 自動(dòng)提交事務(wù)的設(shè)置
通過(guò)上面的研究和分析，現(xiàn)在我們一起思考，為什么 CUD 過(guò)程中必須使用 sqlSession.commit()提交事務(wù)？主要原因就是在連接池中取出的連接，都會(huì)將調(diào)用 connection.setAutoCommit(false)方法，這樣我們就必須使用 sqlSession.commit()方法，相當(dāng)于使用了 JDBC 中的 connection.commit()方法實(shí)現(xiàn)事務(wù)提交。
明白這一點(diǎn)后，我們現(xiàn)在一起嘗試不進(jìn)行手動(dòng)提交，一樣實(shí)現(xiàn) CUD 操作。
@Before//在測(cè)試方法執(zhí)行之前執(zhí)行
public void init()throws Exception {
//1.讀取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創(chuàng)建構(gòu)建者對(duì)象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3.創(chuàng)建 SqlSession 工廠對(duì)象
factory = builder.build(in);
//4.創(chuàng)建 SqlSession 對(duì)象
**session = factory.openSession(true);**
//5.創(chuàng)建 Dao 的代理對(duì)象
userDao = session.getMapper(IUserDao.class);
}
@After//在測(cè)試方法執(zhí)行完成之后執(zhí)行
public void destroy() throws Exception{
//7.釋放資源
session.close();
in.close();
}
事務(wù)就設(shè)置為自動(dòng)提交了，同樣可以實(shí)現(xiàn)CUD操作時(shí)記錄的保存。雖然這也是一種方式，但就編程而言，設(shè)置為自動(dòng)提交方式為 false 再根據(jù)情況決定是否進(jìn)行提交，這種方式更常用。因?yàn)槲覀兛梢愿鶕?jù)業(yè)務(wù)情況來(lái)決定提交是否進(jìn)行提交。
二.Mybatis 的動(dòng)態(tài) SQL 語(yǔ)句
Mybatis 的映射文件中，前面我們的 SQL 都是比較簡(jiǎn)單的，有些時(shí)候業(yè)務(wù)邏輯復(fù)雜時(shí)，我們的 SQL 是動(dòng)態(tài)變化的，此時(shí)在前面的學(xué)習(xí)中我們的 SQL 就不能滿足要求了。
參考的官方文檔，描述如下：
2.1 動(dòng)態(tài) SQL 之標(biāo)簽
我們根據(jù)實(shí)體類的不同取值，使用不同的 SQL 語(yǔ)句來(lái)進(jìn)行查詢。比如在 id 如果不為空時(shí)可以根據(jù) id 查詢，如果 username 不同空時(shí)還要加入用戶名作為條件。這種情況在我們的多條件組合查詢中經(jīng)常會(huì)碰到。
2.1.1 持久層 Dao 接口
/** * 根據(jù)用戶信息，查詢用戶列表 * @param user * @return */ List<User> findByUser(User user);
2.1.2 持久層 Dao 映射配置
<select id="findByUser" resultType="user" parameterType="user">
select * from user where 1=1
<if test="username!=null and username != '' ">
and username like #{username}
</if> <if test="address != null">
and address like #{address}
</if>
</select>注意：<if>標(biāo)簽的 test 屬性中寫(xiě)的是對(duì)象的屬性名，如果是包裝類的對(duì)象要使用 OGNL 表達(dá)式的寫(xiě)法。
另外要注意 where 1=1 的作用~！
2.1.3 測(cè)試
@Test
public void testFindByUser() {
User u = new User();
u.setUsername("%王%");
u.setAddress("%順義%");
//6.執(zhí)行操作
List<User> users = userDao.findByUser(u);
for(User user : users) {
System.out.println(user);
} }
2.2 動(dòng)態(tài) SQL 之標(biāo)簽
為了簡(jiǎn)化上面 where 1=1 的條件拼裝，我們可以采用標(biāo)簽來(lái)簡(jiǎn)化開(kāi)發(fā)。
2.2.1 持久層 Dao 映射配置
<!-- 根據(jù)用戶信息查詢 -->
<select id="findByUser" resultType="user" parameterType="user"> <include refid="defaultSql">
</include> <where> <if test="username!=null and username != '' ">
and username like #{username}
</if> <if test="address != null">
and address like #{address}
</if>
</where>
</select>
2.3 動(dòng)態(tài)標(biāo)簽之標(biāo)簽
需求
傳入多個(gè) id 查詢用戶信息，用下邊兩個(gè) sql 實(shí)現(xiàn)：
SELECT * FROM USERS WHERE username LIKE ‘%張%' AND (id =10 OR id =89 OR id=16) SELECT * FROM USERS WHERE username LIKE ‘%張%' AND id IN (10,89,16)
這樣我們?cè)谶M(jìn)行范圍查詢時(shí)，就要將一個(gè)集合中的值，作為參數(shù)動(dòng)態(tài)添加進(jìn)來(lái)。
這樣我們將如何進(jìn)行參數(shù)的傳遞？
2.3.1 在 QueryVo 中加入一個(gè) List 集合用于封裝參數(shù)
/**
*
* <p>Title: QueryVo</p>
* <p>Description: 查詢的條件</p>
* <p>Company: http://www.itheima.com/ </p>
*/
public class QueryVo implements Serializable {
private List<Integer> ids;
public List<Integer> getIds() {
return ids; }
public void setIds(List<Integer> ids) {
this.ids = ids; } }
2.3.2 持久層 Dao 接口
/** * 根據(jù) id 集合查詢用戶 * @param vo * @return */ List<User> findInIds(QueryVo vo);
2.3.3 持久層 Dao 映射配置
<!-- 查詢所有用戶在 id 的集合之中 -->
?<select id="findInIds" resultType="user" parameterType="queryvo">
<!-- select * from user where id in (1,2,3,4,5); -->
?<include refid="defaultSql"></include>?
?<where>
? ? ? ? ? ? <if test="list != null and list.size() > 0">
? ? ? ? ? ? ? ? <foreach collection="list" open="id in ( " close=")" item="uid"
? ? ? ? ? ? ? ? ? ? ? ? ?separator=",">
? ? ? ? ? ? ? ? ? ? #{uid}
? ? ? ? ? ? ? ? </foreach>
? ? ? ? ? ? </if>
? ? ? ? </where>
</select>SQL 語(yǔ)句：
select 字段 from user where id in (?)
<foreach>標(biāo)簽用于遍歷集合，它的屬性：
collection:代表要遍歷的集合元素，注意編寫(xiě)時(shí)不要寫(xiě)#{}open:代表語(yǔ)句的開(kāi)始部分close:代表結(jié)束部分item:代表遍歷集合的每個(gè)元素，生成的變量名sperator:代表分隔符
2.3.4 編寫(xiě)測(cè)試方法
@Test
public void testFindInIds() {
QueryVo vo = new QueryVo();
List<Integer> ids = new ArrayList<Integer>();
ids.add(41);
ids.add(42);
ids.add(43);
ids.add(46);
ids.add(57);
vo.setIds(ids);
//6.執(zhí)行操作
List<User> users = userDao.findInIds(vo);
for(User user : users) {
System.out.println(user);
} }
2.4 Mybatis 中簡(jiǎn)化編寫(xiě)的 SQL 片段
Sql 中可將重復(fù)的 sql 提取出來(lái)，使用時(shí)用 include 引用即可，最終達(dá)到 sql 重用的目的。
2.4.1 定義代碼片段
<!-- 抽取重復(fù)的語(yǔ)句代碼片段 --> <sql id="defaultSql"> select * from user </sql>
2.4.2 引用代碼片段
<!-- 配置查詢所有操作 -->
<select id="findAll" resultType="user">
<include refid="defaultSql"></include>
</select>
<!-- 根據(jù) id 查詢 --> <select id="findById" resultType="UsEr" parameterType="int">
<include refid="defaultSql"></include>
where id = #{uid}
</select>
以上為個(gè)人經(jīng)驗(yàn)，希望能給大家一個(gè)參考，也希望大家多多支持腳本之家。
相關(guān)文章
詳細(xì)了解java監(jiān)聽(tīng)器和過(guò)濾器
下面小編就為大家?guī)?lái)一篇基于java servlet過(guò)濾器和監(jiān)聽(tīng)器(詳解)。小編覺(jué)得挺不錯(cuò)的，現(xiàn)在就分享給大家，也給大家做個(gè)參考。一起跟隨小編過(guò)來(lái)看看吧2021-07-07
springcloud 服務(wù)降級(jí)的實(shí)現(xiàn)方法
這篇文章主要介紹了springcloud 服務(wù)降級(jí)的實(shí)現(xiàn)方法,本文給大家介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或工作具有一定的參考借鑒價(jià)值，需要的朋友可以參考下2020-12-12
這篇文章主要介紹了JDK線程池和Spring線程池的使用實(shí)例解析,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-11-11
這篇文章主要介紹了淺談Mybatis分頁(yè)插件,自定義分頁(yè)的坑，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。一起跟隨小編過(guò)來(lái)看看吧2020-09-09
這篇文章主要為大家介紹了Java多線程入門(mén)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來(lái)幫助2022-01-01
RocketMQ事務(wù)消息（Transactional Message）是指應(yīng)用本地事務(wù)和發(fā)送消息操作可以被定義到全局事務(wù)中，要么同時(shí)成功，要么同時(shí)失敗。RocketMQ的事務(wù)消息提供類似 X/Open XA 的分布式事務(wù)功能，通過(guò)事務(wù)消息能達(dá)到分布式事務(wù)的最終一致2022-12-12
Java創(chuàng)建線程池為什么一定要用ThreadPoolExecutor
本文介紹了Java創(chuàng)建線程池為什么一定要用ThreadPoolExecutor，手動(dòng)方式使用ThreadPoolExecutor創(chuàng)建線程池和使用Executors執(zhí)行器自動(dòng)創(chuàng)建線程池，下文更多相關(guān)內(nèi)容需要的小伙伴可以參考一下2022-05-05
這篇文章主要介紹了Java SoftReference類案例詳解,本篇文章通過(guò)簡(jiǎn)要的案例,講解了該項(xiàng)技術(shù)的了解與使用,以下就是詳細(xì)內(nèi)容,需要的朋友可以參考下2021-08-08
淺談StringBuilder類的capacity()方法和length()方法的一些小坑
這篇文章主要介紹了StringBuilder類的capacity()方法和length()方法的一些小坑，具有很好的參考價(jià)值，希望對(duì)大家有所幫助。如有錯(cuò)誤或未考慮完全的地方，望不吝賜教2021-07-07
今天給大家?guī)?lái)的是Java的相關(guān)知識(shí),文章圍繞著SpringBoot的異常處理流程展開(kāi),文中有非常詳細(xì)的介紹及代碼示例,需要的朋友可以參考下2021-06-06