foreach的主要用在構建in條件中,它能夠在SQL語句中進行迭代一個集合。foreach元素的屬性主要有 item,index,collection,open,separator,close。item表示集合中每個元素進行迭代時的別名,index指 定一個名字,用於表示在迭代過程當中,每次迭代到的位置,open表示該語句以什麼開始,separator表示在每次進行迭代之間以什麼符號做爲分隔 符,close表示以什麼結束,在使用foreach的時候最關鍵的也是最容易出錯的就是collection屬性,該屬性是必須指定的,可是在不一樣狀況 下,該屬性的值是不同的,主要有一下3種狀況:java
<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有3種,默認的是simple,該模式下它爲每一個語句的執行建立一個新的預處理語句,單條提交sql;而batch模式重複使用已經預處理的語句,而且批量執行全部更新語句,顯然batch性能將更優; 但batch模式也有本身的問題,好比在Insert操做時,在事務沒有提交以前,是沒有辦法獲取到自增的id,這在某型情形下是不符合業務要求的spring
*方式一 spring+mybatis 的sql
//獲取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())); //session.insert("com.xx.mapper.UserMapper.insert",foo); //session.update("com.xx.mapper.UserMapper.updateByPrimaryKeySelective",foo); // session.insert(「包名+類名", foo); fooMapper.insert(foo); //這裏要麼是用session那樣去新建,要麼是用新獲取的mapper if(i % 1000 == 0 || i == size - 1) { //手動每1000個一提交,提交後沒法回滾 session.commit(); //清理緩存,防止溢出 session.clearCache(); } } } catch (Exception e) { //沒有提交的數據能夠回滾 session.rollback(); } finally{ session.close(); }
方法二:數組
結合通用mapper sql別名最好是包名+類名緩存
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(); } }
========== 通過測試,上面的這個仍是對的。 主要是session.insert(「包名+類名", user); 這個必定要設置對。session