MyBatis

MyBatis

问题场景：

问题描述：

    /*** 批量添加设备* @param deviceList* @param applicationName* @return*/public boolean saveBatchDevice(List<Device> deviceList, String applicationName) {if (CollectionUtils.isEmpty(deviceList)) {return false;}boolean result = saveBatch(deviceList);if (result) {List<Map> mapList = deviceList.stream().map((Function<Device, Map>) device -> {Map<String, String> item = new HashMap<>(5);item.put("imei", Imei());item.put("supplier", Supplier());item.put("model", Model());return item;}).List());kafkaTemplate.send(String.format(ADD_DEVICE_TOPIC, applicationName), Str(mapList));}return result;}

原因分析：

    /*** 执行批量操作** @param entityClass 实体类* @param log         日志对象* @param list        数据集合* @param batchSize   批次大小* @param consumer    consumer* @param <E>         T* @return 操作结果* @since 3.4.0*/public static <E> boolean executeBatch(Class<?> entityClass, Log log, Collection<E> list, int batchSize, BiConsumer<SqlSession, E> consumer) {Assert.isFalse(batchSize < 1, "batchSize must not be less than one");return !CollectionUtils.isEmpty(list) && executeBatch(entityClass, log, sqlSession -> {int size = list.size();int i = 1;for (E element : list) {consumer.accept(sqlSession, element);if ((i % batchSize == 0) || i == size) {sqlSession.flushStatements();}i++;}});}

MySQL的JDBC连接的url中要加rewriteBatchedStatements参数，并保证5.1.13以上版本的驱动，才能实现高性能的批量插入。
MySQL JDBC驱动在默认情况下会无视executeBatch()语句，把我们期望批量执行的一组sql语句拆散，一条一条地发给MySQL数据库，批量插入实际上是单条插入，直接造成较低的性能。
只有把rewriteBatchedStatements参数置为true, 驱动才会帮你批量执行SQL
另外这个选项对INSERT/UPDATE/DELETE都有效

解决方案：

————————————————
解决方案参考博文：