|NO.Z.00107|——————————|BigDataEnd|——|Java&MySQL.数据库连接池和DBUtils.V16|——|MySQL.v17|批处理插入10000条数据|
一、什么是批处理
### --- 批处理 (batch) 操作数据库
——> 批处理指的是一次操作中执行多条SQL语句，批处理相比于一次一次执行效率会提高很多。
——> 当向数据库中添加大量的数据时，需要用到批处理。
~~~ # 举例: 送货员的工作：
——> 未使用批处理的时候，送货员每次只能运送 一件货物给商家；
——> 使用批处理，则是送货员将所有要运送的货物, 都用车带到发放处派给客户。
### --- 实现批处理
——> Statement和PreparedStatement都支持批处理操作，
——> 这里我们介绍一下PreparedStatement的批处理方式：
二、要用到的方法
| 方法 | 说明 |
| void addBatch() |
将给定的 SQL 命令添加到此 Statement 对象的当前命令列表中。
通过调用方法 executeBatch 可以批量执行此列表中的命令。
|
| int[] executeBatch() |
每次提交一批命令到数据库中执行，如果所有的命令都成功执行了，
那么返回一个数组，这个数组是说明每条命令所影响的行数 |
### --- mysql 批处理是默认关闭的，所以需要加一个参数才打开 mysql 数据库批处理，在 url 中添加
rewriteBatchedStatements=true
例如: url=jdbc:mysql://127.0.0.1:3306/db5?characterEncoding=UTF-8&rewriteBatchedStatements=true
### --- 创建一张表
CREATE TABLE testBatch (
id INT PRIMARY KEY AUTO_INCREMENT,
uname VARCHAR(50)
)
三、测试向表中插入 1 万条数据
public class TestBatch {
// 使用批处理, 向表中添加 1 万条数据
public static void main(String[] args) {
try {
<span class="hljs-comment">//1.获取连接</span>
<span class="hljs-type">Connection</span> <span class="hljs-variable">con</span> <span class="hljs-operator">=</span> DruidUtils.getConnection();
<span class="hljs-comment">//2.获取预处理对象</span>
<span class="hljs-type">String</span> <span class="hljs-variable">sql</span> <span class="hljs-operator">=</span><span class="hljs-string">"insert into testBatch(uname) values(?)"</span>;
<span class="hljs-type">PreparedStatement</span> <span class="hljs-variable">ps</span> <span class="hljs-operator">=</span> con.prepareStatement(sql);
<span class="hljs-comment">//3.创建 for循环 来设置占位符参数</span>
<span class="hljs-keyword">for</span> (<span class="hljs-type">int</span> <span class="hljs-variable">i</span> <span class="hljs-operator">=</span> <span class="hljs-number">0</span>; i < <span class="hljs-number">10000</span> ; i++) {
ps.setString(<span class="hljs-number">1</span>,<span class="hljs-string">"小强"</span>+i);
<span class="hljs-comment">//将SQL添加到批处理 列表</span>
ps.addBatch();
}
<span class="hljs-comment">//添加时间戳 测试执行效率</span>
<span class="hljs-type">long</span> <span class="hljs-variable">start</span> <span class="hljs-operator">=</span> System.currentTimeMillis();
<span class="hljs-comment">//统一 批量执行</span>
ps.executeBatch();
<span class="hljs-type">long</span> <span class="hljs-variable">end</span> <span class="hljs-operator">=</span> System.currentTimeMillis();
System.out.println(<span class="hljs-string">"插入10000条数据使用: "</span> +(end - start) +<span class="hljs-string">" 毫秒!"</span>);
} <span class="hljs-keyword">catch</span> (SQLException e) {
e.printStackTrace();
}
}
}
四、sql 语句
package com.yanqi.testbatch;
<span class="hljs-keyword">import</span> com.yanqi.utils.DruidUtils;
<span class="hljs-keyword">import</span> java.sql.Connection;
<span class="hljs-keyword">import</span> java.sql.PreparedStatement;
<span class="hljs-keyword">import</span> java.sql.SQLException;
public class BatchInsert {
<span class="hljs-comment">//使用批处理 向表中添加 10000条数据</span>
<span class="hljs-keyword">public</span> <span class="hljs-keyword">static</span> <span class="hljs-keyword">void</span> <span class="hljs-title function_">main</span><span class="hljs-params">(String[] args)</span> <span class="hljs-keyword">throws</span> SQLException {
<span class="hljs-comment">//1.获取连接</span>
<span class="hljs-type">Connection</span> <span class="hljs-variable">connection</span> <span class="hljs-operator">=</span> DruidUtils.getConnection();
<span class="hljs-comment">//2.获取预处理对象</span>
<span class="hljs-type">PreparedStatement</span> <span class="hljs-variable">ps</span> <span class="hljs-operator">=</span> connection.prepareStatement(<span class="hljs-string">"insert into testBatch(uname) values(?)"</span>);
<span class="hljs-comment">//3.执行批量插入操作</span>
<span class="hljs-keyword">for</span> (<span class="hljs-type">int</span> <span class="hljs-variable">i</span> <span class="hljs-operator">=</span> <span class="hljs-number">0</span>; i < <span class="hljs-number">10000</span> ; i++){
ps.setString(<span class="hljs-number">1</span>,<span class="hljs-string">"小强"</span> + i);
<span class="hljs-comment">//将SQL添加到批处理列表</span>
ps.addBatch();
}
<span class="hljs-comment">//添加时间戳 测试执行效率</span>
<span class="hljs-type">long</span> <span class="hljs-variable">start</span> <span class="hljs-operator">=</span> System.currentTimeMillis();
<span class="hljs-comment">//4.统一执行 批量插入操作</span>
ps.executeBatch();
<span class="hljs-type">long</span> <span class="hljs-variable">end</span> <span class="hljs-operator">=</span> System.currentTimeMillis();
System.out.println(<span class="hljs-string">"插入10000条数据需要使用: "</span> + (end - start) + <span class="hljs-string">" 毫秒!"</span>);
<span class="hljs-comment">//5.关闭连接</span>
DruidUtils.close(connection,ps);
}
}
五、打印输出
D:\JAVA\jdk-11.0.2\bin\java.exe "-javaagent:D:\IntelliJIDEA\IntelliJ IDEA 2019.3.3\lib\idea_rt.jar=51623:D:\IntelliJIDEA\IntelliJ IDEA 2019.3.3\bin" -Dfile.encoding=UTF-8 -classpath "E:\NO.Z.10000——javaproject\NO.H.00002.mysql\mysql\out\production\mysql.jdbc_task06;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\dom4j-1.6.1.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\druid-1.0.9.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\c3p0-0.9.5.2.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\commons-dbcp-1.4.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\jaxen-1.1-beta-6.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\commons-pool-1.5.6.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\commons-dbutils-1.6.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\mchange-commons-java-0.2.12.jar;F:\NO.Z.02000——soft——IT. 实验 \20210801——Hadoop\20210801.2——Hadoop——第二阶段——预科班 \ 预科班第二阶段模块一\05 任务五 (JDBC)\03_ 软件 \myJar\mysql-connector-java-5.1.37-bin.jar;C:\Users\Administrator\.m2\repository\org\testng\testng\6.14.3\testng-6.14.3.jar;C:\Users\Administrator\.m2\repository\com\beust\jcommander\1.72\jcommander-1.72.jar;C:\Users\Administrator\.m2\repository\org\apache-extras\beanshell\bsh\2.0b6\bsh-2.0b6.jar;C:\Users\Administrator\.m2\repository\org\junit\jupiter\junit-jupiter\5.4.2\junit-jupiter-5.4.2.jar;C:\Users\Administrator\.m2\repository\org\junit\jupiter\junit-jupiter-api\5.4.2\junit-jupiter-api-5.4.2.jar;C:\Users\Administrator\.m2\repository\org\apiguardian\apiguardian-api\1.0.0\apiguardian-api-1.0.0.jar;C:\Users\Administrator\.m2\repository\org\opentest4j\opentest4j\1.1.1\opentest4j-1.1.1.jar;C:\Users\Administrator\.m2\repository\org\junit\platform\junit-platform-commons\1.4.2\junit-platform-commons-1.4.2.jar;C:\Users\Administrator\.m2\repository\org\junit\jupiter\junit-jupiter-params\5.4.2\junit-jupiter-params-5.4.2.jar;C:\Users\Administrator\.m2\repository\org\junit\jupiter\junit-jupiter-engine\5.4.2\junit-jupiter-engine-5.4.2.jar;C:\Users\Administrator\.m2\repository\org\junit\platform\junit-platform-engine\1.4.2\junit-platform-engine-1.4.2.jar;C:\Users\Administrator\.m2\repository\junit\junit\4.12\junit-4.12.jar;C:\Users\Administrator\.m2\repository\org\hamcrest\hamcrest-core\1.3\hamcrest-core-1.3.jar" com.yanqi.testbatch.BatchInsert
8月 05, 2021 10:42:26 下午 com.alibaba.druid.pool.DruidDataSource info
信息: {dataSource-1} inited
插入10000条数据需要使用: 3205 毫秒! // 不准确
Process finished with exit code 0
Walter Savage Landor:strove with none,for none was worth my strife.Nature I loved and, next to Nature, Art:I warm'd both hands before the fire of life.It sinks, and I am ready to depart
——W.S.Landor