首先看下我们的目标：向mysql数据库中批量插入10000条数据
操作环境：Mysql和Java代码都运行在我本地Windows电脑(i7处理器，4核，16G运行内存，64位操作系统
1、JPA单线程执行
代码省略，大概需要39S左右
2、JPA多线程执行
大概需要37S左右，并没有想象中的快很多
（免费学习视频分享：java视频教程）
Java注释规范Skills
下载
当用户要求为 Java 代码添加注释、修改注释、审查注释、整理注释格式，或要求按照代码注释规范处理 Java 文件时，使用本技能。本技能用于统一生成和维护 Java 类注释模板、按 Git 对比 release 判断版本号、补充每行代码上方中文块注释、调整注释空行规则，并保持 Java 文件 UTF-8 无 BOM 编码。典型触发场景包括：补充类注释、更新 @version、检查 @author 来源、整理行尾注释、把注释放到代码上一行、检查注释是否符合规范、构建前检查 Java 注释风格。
原因： 多线程只是大大提高了程序处理数据的时间，并不会提高插入数据库的时间，相反在我这边JPA的框架下，多线程也就意味着多连接，反而更加消耗数据库性能
package com.example.demo.controller;
import com.example.demo.entity.Student;
import com.example.demo.service.StudentServiceInterface;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.xml.bind.ValidationException;
import java.util.ArrayList;
import java.util.Date;
import java.util.List;
import java.util.concurrent.CountDownLatch;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;
@RestController
@RequestMapping("/student")
public class StudentController {
@Autowired
private StudentServiceInterface studentServiceInterface;
// 来使主线程等待线程池中的线程执行完毕
private CountDownLatch threadsSignal;
// 每个线程处理的数据量
private static final int count = 1000;
// 我的电脑为4核 线程池大小设置为2N+1
private static ExecutorService execPool = Executors.newFixedThreadPool(9);
/**
* 多线程保存
*
* @return
* @throws ValidationException
*/
@GetMapping()
public String saveStudentEnableThread() throws ValidationException {
Long begin = new Date().getTime();
// 需要插入数据库的数据
List<student> list = new ArrayList();
for (int i = 0; i > lists = dealData(list, count);
threadsSignal = new CountDownLatch(lists.size());
for (List<student> students : lists) {
execPool.submit(new InsertDate(students));
}
}
threadsSignal.await();
} catch (Exception e) {
System.out.println(e.toString() + " 错误所在行数：" + e.getStackTrace()[0].getLineNumber());
}
// 结束时间
Long end = new Date().getTime();
return "10000条数据插入花费时间 : " + (end - begin) / 1000 + " s";
}
/**
* 数据组装
* 把每个线程要处理的数据 再组成一个List
* 我这边就是把10000条数据 组成 10个1000条的集合
*
* @param target 数据源
* @param size 每个线程处理的数量
* @return
*/
public static List<list>> dealData(List<student> target, int size) {
List<list>> threadList = new ArrayList<list>>();
// 获取被拆分的数组个数
int arrSize = target.size() % size == 0 ? target.size() / size : target.size() / size + 1;
for (int i = 0; i students = new ArrayList<student>();
//把指定索引数据放入到list中
for (int j = i * size; j list = new ArrayList<student>();
public InsertDate(List<student> students) {
list = students;
}
public void run() {
try {
// 与数据库交互
studentServiceInterface.save(list);
threadsSignal.countDown();
} catch (ValidationException e) {
e.printStackTrace();
}
}
}
}</student></student></student></list></list></student></list></student></student>
3、传统JDBC插入
大概需要8S左右，相较于前两种方式已经快很多了，代码如下：
package com.example.demo.controller;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RestController;
import javax.xml.bind.ValidationException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.util.Date;
@RestController
@RequestMapping("/student1")
public class StudentController1 {
@GetMapping()
public String saveStudentEnableThread() throws ValidationException {
// 开始时间
Long begin = new Date().getTime();
Connection connection = null;
try {
connection = DriverManager.getConnection("jdbc:mysql://localhost:3306/db01?characterEncoding=utf8&useUnicode=true&useSSL=false&serverTimezone=UTC&allowPublicKeyRetrieval=true", "admin", "123456");//获取连接
if (connection != null) {
System.out.println("获取连接成功");
} else {
System.out.println("获取连接失败");
}
//这里必须设置为false，我们手动批量提交
connection.setAutoCommit(false);
//这里需要注意，SQL语句的格式必须是预处理的这种，就是values(?,?,...,?)，否则批处理不起作用
PreparedStatement statement = connection.prepareStatement("insert into student(id,`name`,age) values(?,?,?)");
// 塞数据
for (int i = 0; i <p>4、最后检查一下数据是否成功存库，一共30000条，没有丢数据</p><p><img src="https://img.php.cn/upload/image/763/588/484/1619768394880415.png?x-oss-process=image/resize,p_40" title="1619768394880415.png" alt="822537448de176c183deffcbd45b8f0.png"></p><p>完成！</p><p>相关推荐：<a href="https://www.php.cn/java/guide/" target="_blank">java入门教程</a></p>
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
