MyBatis學習——第三篇(資料批量處理)
阿新 • • 發佈:2018-11-07
1:資料批量處理方法有兩種
第一種:傳統的sqlsession的批量處理方法
第二種:ExecutorType.BATCH
介面程式碼如下:
//批量新增資料
public int addPersons(@Param("persons1") List<Person> persons);
public int addPerson1(Person person);
2:第一種傳統的sqlsession的批量處理方法:
mapper配置:
<!-- 批量新增--> <insert id="addPersons"> insert into person (username,email,gender) VALUES <foreach collection="persons1" item="persons" separator=","> (#{persons.username},#{persons.email},#{persons.gender}) </foreach> </insert> <!-- 批量新增依賴allowMultiQueries=true--> <insert id="addPersons"> <foreach collection="persons1" item="persons" separator=";"> insert into person (username,email,gender) VALUES (#{persons.username},#{persons.email},#{persons.gender}) </foreach> </insert>
程式碼實現:
void addPersons() { System.out.println("--------getPersonsByIds方法開始---------"); SqlSession sqlSession = dbtools.getSession(); System.out.println(sqlSession.toString()); PersonMapper personMapper = sqlSession.getMapper(PersonMapper.class); List<Person> list=new ArrayList<Person>(); list.add(new Person("AAA1", "a郵箱", "F")); list.add(new Person("BBB1", "b郵箱", "F")); list.add(new Person("CCC1", "c郵箱", "F")); int a=personMapper.addPersons(list); System.err.println(a); for(Person p:list) { System.out.println(p); } System.out.println("---------結束---------"); sqlSession.commit(); }
3:第二種ExecutorType.BATCH
// 配置預設的執行器。
// SIMPLE 就是普通的執行器;
// REUSE 執行器會重用預處理語句(prepared statements);
// BATCH 執行器將重用語句並執行批量更新。
mapper配置檔案:
<insert id="addPerson1" parameterType="person">
insert into person (username,email,gender)
VALUES
(#{username},#{email},#{gender})
</insert>
程式碼實現:
void testBach() {
// 配置預設的執行器。
// SIMPLE 就是普通的執行器;
// REUSE 執行器會重用預處理語句(prepared statements);
// BATCH 執行器將重用語句並執行批量更新。
System.out.println("--------批處理方法開始,設定執行器型別---------");
//批處理
SqlSession sqlSession = dbtools.getSqlSessionFactory().openSession(ExecutorType.BATCH);
System.out.println(sqlSession.toString());
PersonMapper personMapper = sqlSession.getMapper(PersonMapper.class);
List<Person> list=new ArrayList<Person>();
list.add(new Person("AAAbach11", "a郵箱", "F"));
list.add(new Person("BBBbach11", "b郵箱", "F"));
list.add(new Person("CCCbach11", "c郵箱", "F"));
for(Person p:list) {
int a=personMapper.addPerson1(p);
System.out.println("返回值:"+a);
}
System.out.println("---------結束---------");
sqlSession.commit();
sqlSession.close();
}
通過兩種不同當時均可實現資料批量處理,但是推薦使用ExecutorType.BATCH實現