Mybatis(三):批量操作

时间:2025-04-09 07:20:19

批量操作分为批量插入和批量更新

主要使用<foreach>

<foreach collection="list" item="item" open="(" close=")" separator="," index="index">
   #{}, #{}
</foreach>
collection="list"    其中list是固定的,如果是数组就是array
item="item"         循环中每一项的别名
open=""             开始标识,比如删除in (id1,id2), open="(" close=")"
close=""            结束标识
separator=","       分隔符号
index="index"       下标值

批量新增

<!-- 批量保存用户,并返回每个用户插入的ID -->
<insert id="batchSave" parameterType="" useGeneratedKeys="true" keyProperty="id">
    INSERT INTO `test`.`tb_user`(`username`, age)
    VALUES
    <foreach collection="list" item="item" separator=",">
        (#{}, #{})
    </foreach>
</insert>

批量删除

<!-- 批量删除用户 -->
<delete id="batchDelete" parameterType="">
    DELETE FROM `test`.`tb_user` WHERE id IN
    <foreach collection="list" item="item" open="(" close=")" separator=",">
        #{id}
    </foreach>
</delete>

UserMapper

package ;

import ;
import ;

/**
 * @author L
 * @ClassName 
 * @Description
 */
public interface UserMapper {

    /**
     * 批量保存用户
     * @param userList
     */
    int batchSave(List<User> userList);

    /**
     * 批量删除用户
     * @param idList
     */
    int batchDelete(List<Integer> idList);
}

测试结果:

import ;
import ;
import ;
import ;
import ;
import ;
import ;
import ;

import ;
import ;
import ;
import ;

/**
 * Created by L on 2018/1/3.
 */
public class TestUserMapper {

    SqlSessionFactory sqlSessionFactory = null;
    SqlSession sqlSession = null;
    UserMapper userMapper = null;

    @Before
    public void before(){
        // mybatis 配置文件地址
        String resource = "";
        InputStream inputStream = null;
        try {
            inputStream = (resource);
        } catch (IOException e) {
            ();
        }
        // 加载配置文件,并构建sqlSessionFactory
        sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
        // 获取sqlSession对象
        sqlSession = ();
        userMapper = ();
    }

    @After
    public void after(){
        if(sqlSession != null){
            // 注意这里的commit,否则提交不成功
            ();
            ();
        }
    }

    /**
     * 测试批量保存
     */
    @org.
    public void testBatchSave(){
        List<User> userList = new ArrayList();
        (new User("张飞", 55));
        (new User("关羽", 60));

        int c = (userList);
        ("新增数量:" + c);
        for (User user : userList) {
            (user);
        }
    }

    /**
     * 测试批量删除
     */
    @org.
    public void testBatchDelete(){
        List<Integer> idList = new ArrayList();
        (13);
        (14);

        int c = (idList);
        ("删除数量为:"+c);

    }

}
新增数量:2
User{id=21, username='张飞', age=55}
User{id=22, username='关羽', age=60}
删除数量为:2