1. 程式人生 > >MyBatis學習——第三篇(資料批量處理)

MyBatis學習——第三篇(資料批量處理)

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實現