MyBatis簡介
MyBatis是一個支持普通SQL查詢,存儲過程和高級映射的優秀持久層框架。MyBatis消除了幾乎所有的JDBC代碼和參數的手工設置以及對結果集的檢索封裝。MyBatis可以使用簡單的XML或注解用於配置和原始映射,將接口和Java的POJO(Plain Old Java Objects,普通的Java對象)映射成數據庫中的記錄。
一、mybiats foreach標簽
foreach的主要用在構建in條件中,它可以在SQL語句中進行迭代一個集合。foreach元素的屬性主要有 item,index,collection,open,separator,close。item表示集合中每一個元素進行迭代時的別名,index指 定一個名字,用於表示在迭代過程中,每次迭代到的位置,open表示該語句以什么開始,separator表示在每次進行迭代之間以什么符號作為分隔 符,close表示以什么結束,在使用foreach的時候最關鍵的也是最容易出錯的就是collection屬性,該屬性是必須指定的,但是在不同情況 下,該屬性的值是不一樣的,主要有一下3種情況:
如果傳入的是單參數且參數類型是一個List的時候,collection屬性值為list
如果傳入的是單參數且參數類型是一個array數組的時候,collection的屬性值為array
如果傳入的參數是多個的時候,我們就需要把它們封裝成一個Map了
具體用法如下:
1
2
3
4
5
6
|
<insert id=
"insertBatch"
parameterType=
"List"
>
INSERT INTO TStudent(name,age)
<foreach collection=
"list"
item=
"item"
index=
"index"
open=
"("
close=
")"
separator=
"union all"
>
SELECT #{item.name} as a, #{item.age} as b FROM DUAL
</foreach>
</insert>
|
二、mybatis ExecutorType.BATCH
Mybatis內置的ExecutorType有3種,默認的是simple,該模式下它為每個語句的執行創建一個新的預處理語句,單條提交sql;而batch模式重復使用已經預處理的語句,並且批量執行所有更新語句,顯然batch性能將更優; 但batch模式也有自己的問題,比如在Insert操作時,在事務沒有提交之前,是沒有辦法獲取到自增的id,這在某型情形下是不符合業務要求的
具體用法如下:
*方式一 spring+mybatis 的
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
|
//獲取sqlsession
//從spring注入原有的sqlSessionTemplate
@Autowired
private
SqlSessionTemplate sqlSessionTemplate;
// 新獲取一個模式為BATCH,自動提交為false的session
// 如果自動提交設置為true,將無法控制提交的條數,改為最后統一提交,可能導致內存溢出
SqlSession session = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH,
false
);
//通過新的session獲取mapper
fooMapper = session.getMapper(FooMapper.
class
);
int
size =
10000
;
try
{
for
(
int
i =
0
; i < size; i++) {
Foo foo =
new
Foo();
foo.setName(String.valueOf(System.currentTimeMillis()));
fooMapper.insert(foo);
if
(i %
1000
==
0
|| i == size -
1
) {
//手動每1000個一提交,提交后無法回滾
session.commit();
//清理緩存,防止溢出
session.clearCache();
}
}
}
catch
(Exception e) {
//沒有提交的數據可以回滾
session.rollback();
}
finally
{
session.close();
}
spring+mybatis
|
方法二:
結合通用mapper sql別名最好是包名+類名
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
|
public
void
insertBatch(Map<String,Object> paramMap, List<User> list)
throws
Exception {
// 新獲取一個模式為BATCH,自動提交為false的session
// 如果自動提交設置為true,將無法控制提交的條數,改為最后統一提交,可能導致內存溢出
SqlSession session = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH,
false
);
try
{
if
(
null
!= list || list.size()>
0
){
int
lsize=list.size();
for
(
int
i =
0
, n=list.size(); i < n; i++) {
User user= list.get(i);
user.setIndate((String)paramMap.get(
"indate"
));
user.setDatadate((String)paramMap.get(
"dataDate"
));
//數據歸屬時間
//session.insert("com.xx.mapper.UserMapper.insert",user);
//session.update("com.xx.mapper.UserMapper.updateByPrimaryKeySelective",_entity);
session.insert(“包名+類名", user);
if
((i>
0
&& i %
1000
==
0
) || i == lsize -
1
) {
// 手動每1000個一提交,提交后無法回滾
session.commit();
// 清理緩存,防止溢出
session.clearCache();
}
}
}
}
catch
(Exception e) {
// 沒有提交的數據可以回滾
session.rollback();
e.printStackTrace();
}
finally
{
session.close();
}
}
|
以上所述是小編給大家介紹的mybatis中批量插入的兩種方式(高效插入),希望對大家有所幫助