?作為CRUD程序員，大部分Java開發(fā)者應(yīng)該都在用Mybatis Plus來操作數(shù)據(jù)庫。但是BaseMapper默認(rèn)僅提供了int insert(T entity)這個(gè)單條插入的方法。那么我們想批量插入數(shù)據(jù)該怎么辦呢？

在駐馬店等地區(qū)，都構(gòu)建了全面的區(qū)域性戰(zhàn)略布局，加強(qiáng)發(fā)展的系統(tǒng)性、市場(chǎng)前瞻性、產(chǎn)品創(chuàng)新能力，以專注、極致的服務(wù)理念，為客戶提供做網(wǎng)站、成都網(wǎng)站制作 網(wǎng)站設(shè)計(jì)制作按需設(shè)計(jì),公司網(wǎng)站建設(shè),企業(yè)網(wǎng)站建設(shè),品牌網(wǎng)站建設(shè),全網(wǎng)營銷推廣,外貿(mào)網(wǎng)站建設(shè),駐馬店網(wǎng)站建設(shè)費(fèi)用合理。

在以前用Mybatis的時(shí)候，我們會(huì)在Mapper.xml里面去寫foreach循環(huán):

1
2
3
4
5
6
7
8

insert into user (user_name,create_time)
  values

   

        (#{list.userName},now())

    

如果批量的實(shí)體對(duì)象較多的話，我們就會(huì)寫很多這樣的Mapper，如果表字段較多，這工作量的也不小的，當(dāng)然，如果你用了代碼生成工具，那就當(dāng)我沒說。Mybatis Plus作為Mybatis的增強(qiáng)版，也為我們考慮到了這個(gè)問題。使用Mybatis Plus批量插入數(shù)據(jù)有兩種方式，第一種是Service層繼承IService,第二種便是insertBatchSomeColumn。先來看看IService的方式

• 新建Mapper繼承BaseMapperpublic interface UserMapper extends BaseMapper {}
• 新建一個(gè)Service接口，繼承IServicepublic interface UserService extends IService { void batchAddUser();}
• 新建一個(gè)Service實(shí)現(xiàn)類,繼承ServiceImplpublic class UserServiceImpl extends ServiceImpl implements UserService { @Autowired private UserMapper userMapper; @Override public void batchAddUser() { List userDOList=new ArrayList<>(); UserDO user1=new UserDO(); user1.setAge(99); user1.setName("99_1"); userDOList.add(user1); UserDO user2=new UserDO(); user2.setAge(999); user2.setName("999_1"); userDOList.add(user2); this.saveBatch(userDOList,2); }}

這種方式，會(huì)生成多條INSERT語句一條條執(zhí)行，然后按設(shè)置的batchSize來提交事務(wù)。

我們?cè)賮砜纯磇nsertBatchSomeColumn是怎么做的呢。1.新建一個(gè)InsertBatchInjector類來擴(kuò)展DefaultSqlInjector

1
2
3
4
5
6
7
8
9

@Component
public class InsertBatchInjector extends DefaultSqlInjector  {
    @Override
    public List getMethodList(Class mapperClass, TableInfo tableInfo) {
        List methodList = super.getMethodList(mapperClass,tableInfo);
        methodList.add(new InsertBatchSomeColumn());
        return methodList;
    }
}

2.新建一個(gè)Mapper接口，繼承BaseMapper并添加insertBatchSomeColumn方法，

1
2
3
4

@Mapper
public interface UserMapper extends BaseMapper {
    int insertBatchSomeColumn(List userDOList);
}

3.在要批量寫的地方直接調(diào)用該Mapper的insertBatchSomeColumn即可

1
2
3
4
5
6
7
8
9
10
11
12

public void batchAddUser() {
        List userDOList=new ArrayList<>();
        UserDO user1=new UserDO();
        user1.setAge(99);
        user1.setName("99_1");
        userDOList.add(user1);
        UserDO user2=new UserDO();
        user2.setAge(999);
        user2.setName("999_1");
        userDOList.add(user2);
        userMapper.insertBatchSomeColumn(userDOList);
}

這種方式則是拼接成一條SQL，一次性提交到數(shù)據(jù)庫執(zhí)行

這里，SQL語句的長(zhǎng)度受MySQL服務(wù)端的max_allowed_packet參數(shù)限制，默認(rèn)為1M，如果拼接的字符串過長(zhǎng)則會(huì)報(bào)錯(cuò)?？梢赃M(jìn)來減少批量提交的記錄，或者是調(diào)整max_allowed_packet參數(shù)的大小。除了受到max_allowed_packet的影響，innodb_buffer_pool_size的大小也會(huì)影響批量的記錄數(shù)大小，innodb_buffer_pool_size的默認(rèn)值為128M，我們可以根據(jù)情況適當(dāng)調(diào)整，合理地配置innodb_buffer_pool_size參數(shù)，可以提高M(jìn)ySQL的讀寫性能。