本文代码地址：https://github.com/hawkingfoo/java-web

一、概述

我们在写Mapper的时候，经常会通过注解的方式来写SQL语句，像下面这样。这要求我们传递的参数为一个具体的对象。

@Insert("INSERT INTO student (name, sex, addr) VALUES (#{name}, #{sex}, #{addr})")
int insert(Student stu);


但是，如果需要批量插入List<Student> studentList；不可能遍历studentList并依次执行插入语句，这样效率太差。

还有一种是配置Mybatis的xml文件，反正题主觉得那个配置好复杂。有没有还是通过注解的方式，执行批量操作呢？

二、批量执行

我们回想下SQL语句，插入一条记录：

INSERT INTO student (name, sex, addr) VALUES ("LiMing", 0, "Beijing");


批量插入：

INSERT INTO student (name, sex, addr) VALUES ("LiMing", 0, "Beijing"), ("LiNing", 0, "Shanghai");


根据 id 删除一条记录：

DELETE FROM student WHERE id = 1;


根据ids批量删除：

DELETE FROM student WHERE id IN (1, 2, 3);


三、方法

既然可以通过SQL语句批量执行，那我们可以修改注解。这里需要通过自定义Provider来实现。

@Component
@Mapper
public interface StudentMapper {
    @Insert("INSERT INTO student (name, sex, addr) VALUES (#{name}, #{sex}, #{addr})")
    int insert(Student stu);

    @InsertProvider(type = Provider.class, method = "batchInsert")
    int batchInsert(List<Student> students);

    @Select("SELECT * FROM student WHERE id = #{id}")
    Student selectById(@Param("id") int id);

    @DeleteProvider(type = Provider.class, method = "batchDelete")
    int batchDelete(List<Student> students);

    @Select("SELECT * FROM student")
    List<Student> selectAll();


    class Provider {
        /* 批量插入 */
        public String batchInsert(Map map) {
            List<Student> students = (List<Student>) map.get("list");
            StringBuilder sb = new StringBuilder();
            sb.append("INSERT INTO student (name,sex,addr) VALUES ");
            MessageFormat mf = new MessageFormat(
                    "(#'{'list[{0}].name}, #'{'list[{0}].sex}, #'{'list[{0}].addr})"
            );

            for (int i = 0; i < students.size(); i++) {
                sb.append(mf.format(new Object[] {i}));
                if (i < students.size() - 1)
                    sb.append(",");
            }
            return sb.toString();
        }

        /* 批量删除 */
        public String batchDelete(Map map) {
            List<Student> students = (List<Student>) map.get("list");
            StringBuilder sb = new StringBuilder();
            sb.append("DELETE FROM student WHERE id IN (");
            for (int i = 0; i < students.size(); i++) {
                sb.append("'").append(students.get(i).getId()).append("'");
                if (i < students.size() - 1)
                    sb.append(",");
            }
            sb.append(")");
            return sb.toString();
        }
    }
}

也可以用如下定义（stackoverflow 中的回答我做了扩展）： 

批量插入：

   // 批量插入
    @Insert({
            "<script>",
            "insert into author(id, name)",
            "values ",
            "<foreach  collection='authorList' item='item' separator=','>",
            "( #{item.id,jdbcType=INTEGER},#{item.name,jdbcType=VARCHAR} )",
            "</foreach>",
            "</script>"
    })
    int insertBatch(@Param("authorList") List<Author> dmoList);



调用使用：

		// 批量插入
List<Author> insertList = new ArrayList<>();
Author a = new Author();
a.setId( 4 );
a.setName( "aa" );
insertList.add( a );

Author b = new Author();
b.setId( 5 );
b.setName( "bb" );
insertList.add( b );

authorMapper.insertBatch( insertList );

这种方法有个好处，就是如果数据很大，因为mysql sqlserver等数据库sql 语句 1M 4M 的大小限制，mybatis本身没有这个限制，所以只要控制调用的地方就可以了, 分割 dmoList 为比如大于1000 大小 批量插入就可以了。     

批量删除： 

   // 批量删除
    @Delete({
         "<script>" +
                 "delete from author where id in " +
            "<foreach item='eid' collection='idList' open='(' separator=',' close=')'>\n" +
                 "#{eid}\n" +
                 "</foreach>" +
                 "</script>"
    })
    int deleteBatch(@Param("idList") List< Integer > idList );

调用：

List<Integer> list = new ArrayList<>();
Integer i = new Integer(3);
Integer i2 = new Integer( 4 );
list.add( i );
list.add( i2 );

authorMapper.deleteBatch( list );

批量修改：

spring.datasource.url=jdbc:mysql://localhost/yangzm?serverTimezone=UTC&useUnicode=true&characterEncoding=utf-8&useSSL=true&allowMultiQueries=true

要增加这个项，否则批量更新不能成功： &allowMultiQueries=true

    @Update({
            "<script>" +
                    "<foreach collection='authorList' item='item' separator=';' open='' close='\n'>\n" +
                    "    UPDATE author <set> name = #{item.name} </set>" +
                    "    WHERE  id = #{item.id}  \n" +
                    "</foreach></script>"
    })
    int updateBatch(@Param("authorList") List<Author> aList);

调用：

List<Author> aList = new ArrayList<>();
Author a = new Author();
a.setId(4);
a.setName("change");
aList.add(a);

Author b = new Author();
b.setId(5);
b.setName("change2");
aList.add(b);

authorMapper.updateBatch(aList);

现在这几种情况都可以运行了：(^ ^) 

 

 

前言：我尝试过用for循环直接将10W数据插入mysql数据库，用时四分半左右。用批量插入的方式用两分钟左右，用时减少一半。插入一万条数据在12秒左右

 

CommodityController代码

package security.controller;

import java.util.ArrayList;
import java.util.Date;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;

import cn.hutool.core.util.RandomUtil;
import security.service.CommodityService;

@Controller
@RequestMapping("commodity")
public class CommodityController {
	private static Logger log =LoggerFactory.getLogger(CommodityController.class);
	@Autowired
	private CommodityService commodityService;
	
	@RequestMapping("add")
	public void add() {
		long systime = new Date().getTime();//当前系统时间
       
		String sex = "a";
		String money = "100";
		int frequency = 12;
		String chepai = "M12345";
		String phone = "123456789";
		List<Map<String, Object>> list = new ArrayList<Map<String,Object>>();
		for(int i=0;i<10;i++) {
			for(int j=0;j<10000;j++) {
				String id = RandomUtil.randomUUID();
				String username = "a"+j;
				Map<String, Object> usermap = new HashMap<String, Object>();
				usermap.put("sex", sex);
				usermap.put("id", id);
				usermap.put("username", username);
				usermap.put("money", money);
				usermap.put("chepai", chepai);
				usermap.put("phone", phone);
				usermap.put("frequency", frequency);
				usermap.put("beizhu", "备注");
				list.add(usermap);
			}
			log.debug("执行第： "+i+" 组数据,组内数据条数为："+list.size()+" 条");
			
			commodityService.addservice(list);
			list.clear();
			log.debug("集合中数据后的数据条数为："+list.size()+" 条");
		}
		 long oldtime = new Date().getTime();//相比较的时间
	     Long time = (oldtime-systime);//相差毫秒数
	     log.debug("用时："+time);
		
	}
}


CommodityService代码

注释掉的部分为用for循环传入参数插入数据库的传值

package security.service;

import java.util.List;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;

import security.mapper.CommodityMapper;

@Service
public class CommodityService {
	
	@Autowired
	private CommodityMapper commodityMapper;
	
	/*
	 * public int addservice(String id,String name,String phone, @Param("chepai")
	 * String chepai, @Param("money") String money ,@Param("sex") String sex
	 * ,@Param("beizhu") String beizhu) { return commodityMapper.add(id, name,
	 * phone, chepai, money, sex, beizhu); }
	 */
	public int addservice(List<Map<String, Object>> list) {
		return commodityMapper.add(list);
	}
}


CommodityMapper代码

注释掉的部分为用for循环传入参数插入数据库的传值及sql语句

 

package security.mapper;

import java.util.List;
import java.util.Map;

import org.apache.ibatis.annotations.Insert;
import org.apache.ibatis.annotations.Param;

public interface CommodityMapper {

	/*
	 * @Insert("INSERT INTO user(id,username,sex,frequency,money,chepai,phone,beizhu) VALUES(#{id},#{name},#{sex},0,#{money},#{chepai},#{phone},#{beizhu})"
	 * ) int add(@Param("id") String id,@Param("name") String name,@Param("phone")
	 * String phone, @Param("chepai") String chepai, @Param("money") String money
	 * ,@Param("sex") String sex ,@Param("beizhu") String beizhu);
	 */
	 
	 @Insert("<script>"  +
		 "INSERT INTO user(id,username,sex,frequency,money,chepai,phone,beizhu) "
	 		+ "VALUES <foreach collection=\"list\" item=\"usermap\" index=\"index\" separator=\",\">" + 
	 		"(#{usermap.id},#{usermap.username},#{usermap.sex},#{usermap.frequency},#{usermap.money},#{usermap.chepai},#{usermap.phone},#{usermap.beizhu})" + 
	 		" </foreach>"
	 		+ "</script>")
	 int add(@Param("list") List<Map<String, Object>> list);
	 
}


@Insert（）括号里面有的会加上{}（如下图查询语句所示），可是我加上后会导致拼接sql语句错误，具体原因没有分析出来。

春季常用注解
redis视频集合，看完这些别说不会redis
1，批量插入
<插入
id =“ insertBatch”
parameterType =“ java.util.List”>
插入
t_student（姓名，年龄，班级）
价值观
<foreach
collection =“列表”
item =“ item”
index =“ index”
spacer =“，”>
（
＃{item.name，jdbcType = VARCHAR}，
＃{item.age，jdbcType = INTEGER}，
＃{item.class，jdbcType = LONGVARCHAR}
）
</ foreach>
</ insert>
2，批量更新
方式一：
<update id =“ updateBatch”>
<foreach
collection =“列表”
spacer =“;”
item =“ stud”>
更新t_studetn集
名称=＃{stud.name}，
年龄=＃{stud.age}，
class =＃{stud.sex}，
其中id =＃{stud.id}
</ foreach>
</ update>
方式二：
<更新
id =“ updateBatch”
parameterType =“ list”>
更新t_student
设置名称=案例ID
<foreach
collection =“列表”
item =“ i”
index =“ index”>
当＃{i.id}然后## i.name}
</ foreach>
结束，
年龄=案件编号
<foreach
collection =“列表”
item =“ i”
index =“ index”>
当＃{i.id}然后## i.age
</ foreach>
结束
在哪里
<foreach
collection =“列表”
spacer =“ or”
item =“ i”
index =“ index”>
id =＃{i.id}
</ foreach>
</ update>
3，批量删除
<delete id =“ deleteBatchByParams”>
从中删除
学生
哪里
ID IN
<foreach
collection =“ ids”
item =“ item”
index =“ index”
open =“（” close =“）”
spacer =“，”>
＃{项目}
</ foreach>
</ delete>

本文代码地址：https://github.com/hawkingfoo/java-web

一、概述

我们在写Mapper的时候，经常会通过注解的方式来写SQL语句，像下面这样。这要求我们传递的参数为一个具体的对象。



@Insert("INSERT INTO student (name, sex, addr) VALUES (#{name}, #{sex}, #{addr})")
int insert(Student stu);

但是，如果需要批量插入List<Student> studentList；不可能遍历studentList并依次执行插入语句，这样效率太差。 

还有一种是配置Mybatis的xml文件，反正题主觉得那个配置好复杂。有没有还是通过注解的方式，执行批量操作呢？



二、批量执行

我们回想下SQL语句，插入一条记录：



INSERT INTO student (name, sex, addr) VALUES ("LiMing", 0, "Beijing");

批量插入：



INSERT INTO student (name, sex, addr) VALUES ("LiMing", 0, "Beijing"), ("LiNing", 0, "Shanghai");

根据 id 删除一条记录：



DELETE FROM student WHERE id = 1;

根据ids批量删除：



DELETE FROM student WHERE id IN (1, 2, 3);



三、方法

既然可以通过SQL语句批量执行，那我们可以修改注解。这里需要通过自定义Provider来实现。



@Component
@Mapper
public interface StudentMapper {
    @Insert("INSERT INTO student (name, sex, addr) VALUES (#{name}, #{sex}, #{addr})")
    int insert(Student stu);

    @InsertProvider(type = Provider.class, method = "batchInsert")
    int batchInsert(List<Student> students);

    @Select("SELECT * FROM student WHERE id = #{id}")
    Student selectById(@Param("id") int id);

    @DeleteProvider(type = Provider.class, method = "batchDelete")
    int batchDelete(List<Student> students);

    @Select("SELECT * FROM student")
    List<Student> selectAll();


    class Provider {
        /* 批量插入 */
        public String batchInsert(Map map) {
            List<Student> students = (List<Student>) map.get("list");
            StringBuilder sb = new StringBuilder();
            sb.append("INSERT INTO student (name,sex,addr) VALUES ");
            MessageFormat mf = new MessageFormat(
                    "(#'{'list[{0}].name}, #'{'list[{0}].sex}, #'{'list[{0}].addr})"
            );

            for (int i = 0; i < students.size(); i++) {
                sb.append(mf.format(new Object[] {i}));
                if (i < students.size() - 1)
                    sb.append(",");
            }
            return sb.toString();
        }

        /* 批量删除 */
        public String batchDelete(Map map) {
            List<Student> students = (List<Student>) map.get("list");
            StringBuilder sb = new StringBuilder();
            sb.append("DELETE FROM student WHERE id IN (");
            for (int i = 0; i < students.size(); i++) {
                sb.append("'").append(students.get(i).getId()).append("'");
                if (i < students.size() - 1)
                    sb.append(",");
            }
            sb.append(")");
            return sb.toString();
        }
    }
}