MyBatis連接池的深入和動態(tài)SQL詳解
一，Mybatis 連接池與事務(wù)深入
1.1 Mybatis 的連接池技術(shù)
Mybatis 中連接池技術(shù)，它采用的是自己的連接池技術(shù)。在 Mybatis 的 SqlMapConfig.xml 配置文件中，通過來實現(xiàn) Mybatis 中連接池的配置。
1.1.1 Mybatis 連接池的分類
在 Mybatis 中我們將它的數(shù)據(jù)源 dataSource 分為以下幾類：
可以看出 Mybatis 將它自己的數(shù)據(jù)源分為三類：
UNPOOLED不使用連接池的數(shù)據(jù)源POOLED使用連接池的數(shù)據(jù)源JNDI使用 JNDI 實現(xiàn)的數(shù)據(jù)源
具體結(jié)構(gòu)如下：
相應地，MyBatis 內(nèi)部分別定義了實現(xiàn)了 java.sql.DataSource 接口的 UnpooledDataSource，PooledDataSource 類來表示 UNPOOLED、POOLED 類型的數(shù)據(jù)源。
在這三種數(shù)據(jù)源中，我們一般采用的是 POOLED 數(shù)據(jù)源（很多時候我們所說的數(shù)據(jù)源就是為了更好的管理數(shù)據(jù)庫連接，也就是我們所說的連接池技術(shù)）。
1.1.2 Mybatis 中數(shù)據(jù)源的配置
MyBatis 在初始化時，根據(jù)的 type 屬性來創(chuàng)建相應類型的的數(shù)據(jù)源 DataSource，即：
- type=”POOLED”：MyBatis 會創(chuàng)建 PooledDataSource 實例
- type=”UNPOOLED” ： MyBatis 會創(chuàng)建 UnpooledDataSource 實例
- type=”JNDI”：MyBatis 會從 JNDI 服務(wù)上查找 DataSource 實例，然后返回使用
我們的數(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 中我們可以通過手動方式將事務(wù)的提交改為手動方式，通過 setAutoCommit()方法就可以調(diào)整。
通過 JDK 文檔，我們找到該方法如下：
那么我們的 Mybatis 框架因為是對 JDBC 的封裝，所以 Mybatis 框架的事務(wù)控制方式，本身也是用 JDBC 的setAutoCommit()方法來設(shè)置事務(wù)提交方式的。
1.2.2 Mybatis 中事務(wù)提交方式
Mybatis 中事務(wù)的提交方式，本質(zhì)上就是調(diào)用 JDBC 的 setAutoCommit()來實現(xiàn)事務(wù)控制。
我們運行之前所寫的代碼：
@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//在測試方法執(zhí)行之前執(zhí)行
public void init()throws Exception {
//1.讀取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創(chuàng)建構(gòu)建者對象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3.創(chuàng)建 SqlSession 工廠對象
factory = builder.build(in);
//4.創(chuàng)建 SqlSession 對象
session = factory.openSession();
//5.創(chuàng)建 Dao 的代理對象
userDao = session.getMapper(IUserDao.class);
}
@After//在測試方法執(zhí)行完成之后執(zhí)行
public void destroy() throws Exception{
//7.提交事務(wù)
session.commit();
//8.釋放資源
session.close();
in.close();
}
默認 setAutoCommit()方法，在執(zhí)行時它的值被設(shè)置為 false 了，所以我們在 CUD 操作中，必須通過 sqlSession.commit()方法來執(zhí)行提交操作。
1.2.3 Mybatis 自動提交事務(wù)的設(shè)置
通過上面的研究和分析，現(xiàn)在我們一起思考，為什么 CUD 過程中必須使用 sqlSession.commit()提交事務(wù)？主要原因就是在連接池中取出的連接，都會將調(diào)用 connection.setAutoCommit(false)方法，這樣我們就必須使用 sqlSession.commit()方法，相當于使用了 JDBC 中的 connection.commit()方法實現(xiàn)事務(wù)提交。
明白這一點后，我們現(xiàn)在一起嘗試不進行手動提交，一樣實現(xiàn) CUD 操作。
@Before//在測試方法執(zhí)行之前執(zhí)行
public void init()throws Exception {
//1.讀取配置文件
in = Resources.getResourceAsStream("SqlMapConfig.xml");
//2.創(chuàng)建構(gòu)建者對象
SqlSessionFactoryBuilder builder = new SqlSessionFactoryBuilder();
//3.創(chuàng)建 SqlSession 工廠對象
factory = builder.build(in);
//4.創(chuàng)建 SqlSession 對象
**session = factory.openSession(true);**
//5.創(chuàng)建 Dao 的代理對象
userDao = session.getMapper(IUserDao.class);
}
@After//在測試方法執(zhí)行完成之后執(zhí)行
public void destroy() throws Exception{
//7.釋放資源
session.close();
in.close();
}
事務(wù)就設(shè)置為自動提交了，同樣可以實現(xiàn)CUD操作時記錄的保存。雖然這也是一種方式，但就編程而言，設(shè)置為自動提交方式為 false 再根據(jù)情況決定是否進行提交，這種方式更常用。因為我們可以根據(jù)業(yè)務(wù)情況來決定提交是否進行提交。
二.Mybatis 的動態(tài) SQL 語句
Mybatis 的映射文件中，前面我們的 SQL 都是比較簡單的，有些時候業(yè)務(wù)邏輯復雜時，我們的 SQL 是動態(tài)變化的，此時在前面的學習中我們的 SQL 就不能滿足要求了。
參考的官方文檔，描述如下：
2.1 動態(tài) SQL 之標簽
我們根據(jù)實體類的不同取值，使用不同的 SQL 語句來進行查詢。比如在 id 如果不為空時可以根據(jù) id 查詢，如果 username 不同空時還要加入用戶名作為條件。這種情況在我們的多條件組合查詢中經(jīng)常會碰到。
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>標簽的 test 屬性中寫的是對象的屬性名，如果是包裝類的對象要使用 OGNL 表達式的寫法。
另外要注意 where 1=1 的作用~！
2.1.3 測試
@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 動態(tài) SQL 之標簽
為了簡化上面 where 1=1 的條件拼裝，我們可以采用標簽來簡化開發(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 動態(tài)標簽之標簽
需求
傳入多個 id 查詢用戶信息，用下邊兩個 sql 實現(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)
這樣我們在進行范圍查詢時，就要將一個集合中的值，作為參數(shù)動態(tài)添加進來。
這樣我們將如何進行參數(shù)的傳遞？
2.3.1 在 QueryVo 中加入一個 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 語句：
select 字段 from user where id in (?)
<foreach>標簽用于遍歷集合，它的屬性：
collection:代表要遍歷的集合元素，注意編寫時不要寫#{}open:代表語句的開始部分close:代表結(jié)束部分item:代表遍歷集合的每個元素，生成的變量名sperator:代表分隔符
2.3.4 編寫測試方法
@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 中簡化編寫的 SQL 片段
Sql 中可將重復的 sql 提取出來，使用時用 include 引用即可，最終達到 sql 重用的目的。
2.4.1 定義代碼片段
<!-- 抽取重復的語句代碼片段 --> <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>
以上為個人經(jīng)驗，希望能給大家一個參考，也希望大家多多支持腳本之家。
相關(guān)文章
下面小編就為大家?guī)硪黄趈ava servlet過濾器和監(jiān)聽器(詳解)。小編覺得挺不錯的，現(xiàn)在就分享給大家，也給大家做個參考。一起跟隨小編過來看看吧2021-07-07
springcloud 服務(wù)降級的實現(xiàn)方法
這篇文章主要介紹了springcloud 服務(wù)降級的實現(xiàn)方法,本文給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下2020-12-12
這篇文章主要介紹了JDK線程池和Spring線程池的使用實例解析,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下2019-11-11
這篇文章主要介紹了淺談Mybatis分頁插件,自定義分頁的坑，具有很好的參考價值，希望對大家有所幫助。一起跟隨小編過來看看吧2020-09-09
這篇文章主要為大家介紹了Java多線程入門，具有一定的參考價值，感興趣的小伙伴們可以參考一下，希望能夠給你帶來幫助2022-01-01
RocketMQ事務(wù)消息（Transactional Message）是指應用本地事務(wù)和發(fā)送消息操作可以被定義到全局事務(wù)中，要么同時成功，要么同時失敗。RocketMQ的事務(wù)消息提供類似 X/Open XA 的分布式事務(wù)功能，通過事務(wù)消息能達到分布式事務(wù)的最終一致2022-12-12
Java創(chuàng)建線程池為什么一定要用ThreadPoolExecutor
本文介紹了Java創(chuàng)建線程池為什么一定要用ThreadPoolExecutor，手動方式使用ThreadPoolExecutor創(chuàng)建線程池和使用Executors執(zhí)行器自動創(chuàng)建線程池，下文更多相關(guān)內(nèi)容需要的小伙伴可以參考一下2022-05-05
這篇文章主要介紹了Java SoftReference類案例詳解,本篇文章通過簡要的案例,講解了該項技術(shù)的了解與使用,以下就是詳細內(nèi)容,需要的朋友可以參考下2021-08-08
淺談StringBuilder類的capacity()方法和length()方法的一些小坑
這篇文章主要介紹了StringBuilder類的capacity()方法和length()方法的一些小坑，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教2021-07-07
今天給大家?guī)淼氖荍ava的相關(guān)知識,文章圍繞著SpringBoot的異常處理流程展開,文中有非常詳細的介紹及代碼示例,需要的朋友可以參考下2021-06-06