设为首页 加入收藏

TOP

使用JDBC连接MySQL数据库--典型案例分析(七)----批量插入员工信息
2015-07-24 11:31:58 来源: 作者: 【 】 浏览:2
Tags:使用 JDBC 连接 MySQL 数据库 典型 案例分析 ---- 批量 插入 员工 信息

问题:

向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作为数据库的话,那么就会没有问题的。

】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇mysql日期相关函数使用 下一篇查看sedna创建的数据库和集合,文..

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

·请问微信4.0版本xwec (2025-12-24 22:48:42)
·电脑NVIDIA的文件夹 (2025-12-24 22:48:40)
·如何看待微信新版本 (2025-12-24 22:48:37)
·C语言中如何将结构体 (2025-12-24 22:20:09)
·纯C语言结构体成员变 (2025-12-24 22:20:06)