[Java知识库]Mybatis 批量操作

对于 foreach 标签的解释参考了网上的资料，具体如下：

foreach 的主要用在构建in条件中，它可以在SQL语句中进行迭代一个集合。

foreach 元素的属性主要有 item，index，collection，open，separator，close。

• item表示集合中每一个元素进行迭代时的别名，
• index指定一个名字，用于表示在迭代过程中，每次迭代到的位置，
• open表示该语句以什么开始，
• separator表示在每次进行迭代之间以什么符号作为分隔 符，
• close表示以什么结束，

在使用foreach的时候最关键的也是最容易出错的就是collection属性，该属性是必须指定的，但是在不同情况下，该属性的值是不一样的，主要有一下3种情况：

• 如果传入的是单参数且参数类型是一个List的时候，collection属性值为list
• 如果传入的是单参数且参数类型是一个array数组的时候，collection的属性值为array
• 如果传入的参数是多个的时候，我们就需要把它们封装成一个Map了，当然单参数也可以封装成map

1 批量更新

<foreach collection="attendingUsrList" item="model"  separator=";">
    UPDATE table_name SET colum_1= #{model.value_1}
    WHERE  colum_2 = #{model.value_2}  
</foreach>

In oracle if you want to execute multiple statements at one time you have to enclose your statements in “begin” and “end” block.

<foreach collection="customerList" item="object" open="begin" close=";end;" separator=";">
    UPDATE customer SET isActive = #{object.isactive}
    WHERE  customerId= #{object.customerId}
</foreach>

2 批量插入

拼接 sql 方式【不返回 key 】

<insert id="insertList" parameterType="xxx.xxx.PO" useGeneratedKeys="false">
    INSERT INTO table_name
        (
            column_1, column_2, column_3, column_4
        ) 
    VALUES
    <foreach collection="paramList" item="model" separator=","> 
        (           
            #{model.value_1}, #{model.value_2}, #{model.value_3}, #{model.value_4}
        )
    </foreach>
</insert>

拼接 sql 方式【返回 key 】

<!-- 批量插入生成的兑换码 -->
<insert id ="insertCodeBatch" parameterType="java.util.List" >
	<selectKey resultType ="java.lang.Integer" keyProperty= "id" order= "AFTER">
		SELECT LAST_INSERT_ID()
    </selectKey >
      insert into redeem_code
		(bach_id, code, type, facevalue,create_user,create_time)
      values
    <foreach collection ="list" item="reddemCode" index= "index" separator =",">
        (
			#{reddemCode.batchId}, 
			#{reddemCode.code},
			#{reddemCode.type},
			#{reddemCode.facevalue},
			#{reddemCode.createUser}, 
			#{reddemCode.createTime}
        )
    </foreach >
</insert >

批处理方式

@SpringBootTest
class DemoApplicationTests {
    // @Autowired
    // private SqlSessionFactory sqlSessionFactory;
    @Autowired
    private SqlSessionTemplate sqlSessionTemplate;


    @Test
    public void testInsertBatch() {
        //数据生成
        List studentList = createData(100);
        //使用批处理
        long start = System.currentTimeMillis();
        // 新获取一个模式为BATCH，自动提交为false的session
		// 如果自动提交设置为true，将无法控制提交的条数，改为最后统一提交，可能导致内存溢出
    	SqlSession session = sqlSessionTemplate.getSqlSessionFactory().openSession(ExecutorType.BATCH, false);
        // SqlSession sqlSession = sqlSessionFactory.openSession(ExecutorType.BATCH, false);
        StudentMapper studentMapperNew = sqlSession.getMapper(StudentMapper.class);
        studentList.stream().forEach(student -> studentMapperNew.insert(student));
        // 这里提交前可以用过计数器来控制每次的提交数量
        sqlSession.commit();
        sqlSession.clearCache();
        System.out.println(System.currentTimeMillis() - start);
    }

    private List createData(int size) {
        List studentList = new ArrayList<>();
        Student student;
        for (int i = 0; i < size; i++) {
            student = new Student();
            student.setName("小王" + i);
            student.setAge(18);
            student.setClassId(1);
            student.setPhone("1585xxxx669");
            student.setAddress("未知");
            studentList.add(student);
        }
        return studentList;
    }
}