JDBC详解（五）：批量插入（超详解）

朱雀 2023-09-27 00:29 164阅读 0赞

### JDBC详解（五）：批量插入（超详解） ###

*  前言
 *  一、批量执行SQL语句
 *  二、高效的批量插入
 *   *  1、实现层次一：使用Statement
     *  2、实现层次二：使用PreparedStatement
     *  3、实现层次三
     *  4、实现层次四

--------------------

# 前言 #

本博主将用CSDN记录软件开发求学之路上亲身所得与所学的心得与知识，有兴趣的小伙伴可以关注博主！也许一个人独行，可以走的很快，但是一群人结伴而行，才能走的更远！

# 一、批量执行SQL语句 #

> 当需要成批插入或者更新记录时，可以采用Java的批量**更新**机制，这一机制允许多条语句一次性提交给数据库批量处理。通常情况下比单独提交处理更有效率

JDBC的批量处理语句包括下面三个方法：

*  **addBatch(String)：添加需要批量处理的SQL语句或是参数；**
 *  **executeBatch()：执行批量处理语句；**
 *  **clearBatch():清空缓存的数据**

通常我们会遇到两种批量执行SQL语句的情况：

*  多条SQL语句的批量处理；
 *  一个SQL语句的批量传参；

# 二、高效的批量插入 #

举例：向数据表中插入20000条数据

*  数据库中提供一个goods表。创建如下：

CREATE TABLE goods(
    id INT PRIMARY KEY AUTO_INCREMENT,
    NAME VARCHAR(20)
    );

## 1、实现层次一：使用Statement ##

Connection conn = JDBCUtils.getConnection();
    Statement st = conn.createStatement();
    for(int i = 1;i <= 20000;i++){
         
    	String sql = "insert into goods(name) values('name_' + "+ i +")";
    	st.executeUpdate(sql);
    }

## 2、实现层次二：使用PreparedStatement ##

//批量插入的方式二：使用PreparedStatement
    	@Test
    	public void testInsert1() {
         
    		Connection conn = null;
    		PreparedStatement ps = null;
    		try {
         
    			
    			long start = System.currentTimeMillis();
    			
    			conn = JDBCUtils.getConnection();
    			String sql = "insert into goods(name)values(?)";
    			ps = conn.prepareStatement(sql);
    			for(int i = 1;i <= 20000;i++){
         
    				ps.setObject(1, "name_" + i);
    				
    				ps.execute();
    			}
    			
    			long end = System.currentTimeMillis();
    			
    			System.out.println("花费的时间为：" + (end - start));//20000:83065
    		} catch (Exception e) {
         
    			e.printStackTrace();
    		}finally{
         
    			JDBCUtils.closeResource(conn, ps);
    			
    		}
    		
    	}

## 3、实现层次三 ##

/*
    	 * 批量插入的方式三：
    	 * 1.addBatch()、executeBatch()、clearBatch()
    	 * 2.mysql服务器默认是关闭批处理的，我们需要通过一个参数，让mysql开启批处理的支持。
    	 * 		 ?rewriteBatchedStatements=true 写在配置文件的url后面
    	 * 3.使用更新的mysql 驱动：mysql-connector-java-5.1.37-bin.jar
    	 */
    	@Test
    	public void testInsert2() {
         
    		Connection conn = null;
    		PreparedStatement ps = null;
    		try {
         
    			
    			long start = System.currentTimeMillis();
    			
    			conn = JDBCUtils.getConnection();
    			String sql = "insert into goods(name)values(?)";
    			ps = conn.prepareStatement(sql);
    			for(int i = 1;i <= 1000000;i++){
         
    				ps.setObject(1, "name_" + i);
    				
    				//1."攒"sql
    				ps.addBatch();
    				
    				if(i % 500 == 0){
         
    					//2.执行batch
    					ps.executeBatch();
    					
    					//3.清空batch
    					ps.clearBatch();
    				}
    				
    			}
    			
    			long end = System.currentTimeMillis();
    			
    			System.out.println("花费的时间为：" + (end - start));//20000:83065 -- 565
    		} catch (Exception e) {
         								//1000000:16086
    			e.printStackTrace();
    		}finally{
         
    			JDBCUtils.closeResource(conn, ps);
    			
    		}
    		
    	}

## 4、实现层次四 ##

//批量插入的方式四：设置连接不允许自动提交数据
    	@Test
    	public void testInsert3() {
         
    		Connection conn = null;
    		PreparedStatement ps = null;
    		try {
         
    			
    			long start = System.currentTimeMillis();
    			
    			conn = JDBCUtils.getConnection();
    			
    			//设置不允许自动提交数据
    			conn.setAutoCommit(false);
    			
    			String sql = "insert into goods(name)values(?)";
    			ps = conn.prepareStatement(sql);
    			for(int i = 1;i <= 1000000;i++){
         
    				ps.setObject(1, "name_" + i);
    				
    				//1."攒"sql
    				ps.addBatch();
    				
    				if(i % 500 == 0){
         
    					//2.执行batch
    					ps.executeBatch();
    					
    					//3.清空batch
    					ps.clearBatch();
    				}
    				
    			}
    			
    			//提交数据
    			conn.commit();
    			
    			long end = System.currentTimeMillis();
    			
    			System.out.println("花费的时间为：" + (end - start));//20000:83065 -- 565
    		} catch (Exception e) {
         								//1000000:16086 -- 5114
    			e.printStackTrace();
    		}finally{
         
    			JDBCUtils.closeResource(conn, ps);
    			
    		}
    		
    	}