mybatis 批量插入的兩種方式

1、mybiats foreach標籤

foreach的主要用在構建in條件中,它能夠在SQL語句中進行迭代一個集合。foreach元素的屬性主要有 item,index,collection,open,separator,close。item表示集合中每個元素進行迭代時的別名,index指 定一個名字,用於表示在迭代過程當中,每次迭代到的位置,open表示該語句以什麼開始,separator表示在每次進行迭代之間以什麼符號做爲分隔 符,close表示以什麼結束,在使用foreach的時候最關鍵的也是最容易出錯的就是collection屬性,該屬性是必須指定的,可是在不一樣狀況 下,該屬性的值是不同的,主要有一下3種狀況:java

  1. 若是傳入的是單參數且參數類型是一個List的時候,collection屬性值爲list
  2. 若是傳入的是單參數且參數類型是一個array數組的時候,collection的屬性值爲array
  3. 若是傳入的參數是多個的時候,咱們就須要把它們封裝成一個Map了
具體用法以下:
<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>

2、mybatis ExecutorType.BATCH

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();
    }
  • spring+mybatis

方法二:數組

結合通用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

相關文章
相關標籤/搜索