ibatis 批量添加数据

ibatis批量添加数据

自己项目中用到的。

public void insertCiyt(final List<City> cityList) {
		// TODO Auto-generated method stub
		System.out.println("批量添加开始");

		SqlMapClientCallback callback = new SqlMapClientCallback() {
			public Object doInSqlMapClient(SqlMapExecutor executor)
					throws SQLException {
				int counter =1;
				executor.startBatch();
				for (City dto : cityList) {
                                        //需要插入的语句
					executor.insert("inserSql", dto);
					counter++;
					if (counter % 4000 == 0) {
						executor.executeBatch();
						executor.startBatch();
					}
				}
				executor.executeBatch();
				return null;//这里的返回值会被下面的Object接收到
			}
		};
		//num 接受的是每次批量处理多少条数据
		Object num = this.getSqlMapClientTemplate().execute(callback);

	}

下面配置文件里面的

<sqlMap namespace="City">
	<typeAlias alias="city" type="com.xxx.City" />
	<resultMap class="city" id="cityMap">
		<result property="cid" column="cid" />
		<result property="name" column="name" />
        </resultMap>

	<insert id="insertSql" parameterClass="city">
		<![CDATA[insert into u_city_copy(`cid`,`name`)
			values(#cid#,#name#);]]>	
	</insert>
</sqlMap>

另一种方法也可以：

@Override
	public void mergerLeagueRelation(final List<LeagueRelation> leagueRelation) {
		this.getSqlMapClientTemplate().execute(new SqlMapClientCallback(){
			public Object doInSqlMapClient(SqlMapExecutor executor)
					throws SQLException {
				executor.startBatch();
				int counter = 0;
				for (LeagueRelation temp : leagueRelation) {
					executor.insert("mergerLeagueRelation",temp);
					counter ++ ;
					if(counter%10000==0){
						executor.executeBatch();
						executor.startBatch();
					}
				}
				executor.executeBatch();
				return null;
			}
			
		});
	}