使用JDBC连接MySQL数据库--典型案例分析(七)----批量插入员工信息
转载请注明:张奇的CSDN博客 - 博客频道 - CSDN.NET
问题:
向Emp表中批量插入100条数据,需要插入数据的列为empno,ename以及sal.这三个字段对应的数据分别为empno列的数据通过序列emp_seq自动生成,ename列的数据为字符串 "name"+循环次数i组成、sal的数据有随机生成的10000以内的整数构成。
方案:
每循环一次,向数据库插入一条数据,频繁的访问数据库,效率很低。
在java中专门提供的批处理的API。在对数据库频繁操作时,可以使用JDBC批处理方式提高程序的效率。批处理的主要特点如下:
1.使用同一Connection资源,一次发送多条SQL语句执行。
2.提高应用程序与DB之间的吞吐量,缩短DB的响应时间
3.与逐条执行SQL的方式相比,需要处理的数据量越大,批处理的优势越明显
实现缓存SQL语句和批量执行,使用Statement实现批处理的核心代码如下:
步骤一:在Mysql数据中创建序列emp_seq
在Mysql数据库中创建序列名为emp_sql,该序列的起始值为1,步进为1,SQL语句如下所示:
CREATE TABLE emp_seq ( seq VARCHAR(8));
INSERT INTO emp_seq VALUES('0');
UPDATE emp_seq SET seq = LAST_INSERT_ID(seq+1);
SELECT LAST_INSERT_ID();
步骤二:准备JDBC操作数据库的基本代码
首先新建类Batch,在该类中新建batchAdd方法,然后,准备数据库连接Connection对象,操作SQL语句的Statement对象以及设置事务管理;最后进行异常的处理,代码如下所示:
package Account;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Random;
import dao.ConnectionSource;
public class Batch {
public static void main(String [] args){
}
public void batchAdd(){
Connection con=null;
Statement stmt=null;
String sql=null;
try {
con=ConnectionSource.getConnection();
stmt=con.createStatement();
//关闭自动提交
con.setAutoCommit(false);
// 提交
con.commit();
} catch (SQLException e) {
System.out.println("数据库访问异常!");
throw new RuntimeException(e);
}finally{
try {
if(stmt!=null){
stmt.close();
}
if(con!=null){
con.close();
}
} catch (SQLException e) {
System.out.println("释放资源时发生异常!");
}
}
}
}
步骤 三:批量向Emp表中插入数据
使用statement的addBatch方法和executeBatch方法,批量向Emp表中插入数据,代码如下所示:
package Account;
import java.sql.Connection;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Random;
import dao.ConnectionSource;
public class Batch {
public static void main(String [] args){
}
public void batchAdd(){
Connection con=null;
Statement stmt=null;
String sql=null;
try {
con=ConnectionSource.getConnection();
stmt=con.createStatement();
//关闭自动提交
con.setAutoCommit(false);
for(int i=0;i<100;i++){
//插入数据的sql语句
sql="insert into emp(empno,ename,sal) values("+"emp_seq.nextval,'name"+i+"',"+new Random().nextInt(10000)+")";
//将sql语句加入到Batch中
stmt.addBatch(sql);
}
//执行批处理
stmt.executeBatch();
// 提交
con.commit();
} catch (SQLException e) {
System.out.println("数据库访问异常!");
throw new RuntimeException(e);
}finally{
try {
if(stmt!=null){
stmt.close();
}
if(con!=null){
con.close();
}
} catch (SQLException e) {
System.out.println("释放资源时发生异常!");
}
}
}
}
步骤四:测试是否批量插入数据成功
public static void main(String [] args){
Batch batch=new Batch();
batch.batchAdd();
}
运行前:
运行后:
结果有点问题,上述代码中有一句是orcle的函数功能,
emp_seq.nextval
目前还没有找到合适的能运行的类似解决方法,如果你是用orcle作为数据库的话,那么就会没有问题的。
如果找到了适合的好方法的朋友,可以给我评论将 解决方法发一下, 一起交流交流。
等待下节的精彩哦~
- C++服务器开发之基于对象的编程风格
- The jQuery UI CSS Framework
- hadoop:将WordCount打包成独立运行的jar包
- Hadoop: MapReduce2多个job串行处理
- UE4新手引导之下载和安装虚幻4游戏引擎
- mac 下卸载mysql的方法
- ZooKeeper 笔记(1) 安装部署及hello world
- mybatis 使用经验小结
- ZooKeeper 笔记(2) 监听数据变化
- 使用C# 和Consul进行分布式系统协调
- 设置 java -jar 的进程显示名称
- 爱浪携手豆瓣内容、腾讯共同发布AI语音耳机
- Win.ini和注册表的读取写入
- ZooKeeper 笔记(4) 实战应用之【消除单点故障】
- MySQL 教程
- MySQL 安装
- MySQL 管理与配置
- MySQL PHP 语法
- MySQL 连接
- MySQL 创建数据库
- MySQL 删除数据库
- MySQL 选择数据库
- MySQL 数据类型
- MySQL 创建数据表
- MySQL 删除数据表
- MySQL 插入数据
- MySQL 查询数据
- MySQL where 子句
- MySQL UPDATE 查询
- MySQL DELETE 语句
- MySQL LIKE 子句
- mysql order by
- Mysql Join的使用
- MySQL NULL 值处理
- MySQL 正则表达式
- MySQL 事务
- MySQL ALTER命令
- MySQL 索引
- MySQL 临时表
- MySQL 复制表
- 查看MySQL 元数据
- MySQL 序列 AUTO_INCREMENT
- MySQL 处理重复数据
- MySQL 及 SQL 注入
- MySQL 导出数据
- MySQL 导入数据
- MYSQL 函数大全
- MySQL Group By 实例讲解
- MySQL Max()函数实例讲解
- mysql count函数实例
- MYSQL UNION和UNION ALL实例
- MySQL IN 用法
- MySQL between and 实例讲解
- 写一个通用的幂等组件,我觉得很有必要
- PC性能监测工具,您不可或缺的好帮手~~
- 特征工程之处理时间序列数据
- Matplotlib中的“plt”和“ax”到底是什么?
- 使用深度学习模型创作动漫故事,比较LSTM和GPT2的文本生成方法
- 聊聊BitCaskLock
- LightGBM的参数详解以及如何调优
- 聊聊BitCaskKeyDir
- 使用2D卷积技术进行时间序列预测
- 在PyTorch中使用DistributedDataParallel进行多GPU分布式模型训练
- 同城双活与异地多活架构分析
- leetcode多线程之按序打印
- leetcode多线程之交替打印FooBar
- leetcode链表之反转链表
- leetcode链表之合并两个排序的链表