JDBC批处理

2017年9月5日 上午8:35

作用：通过预编译对象，同时执行多条sql
实现方式：
1. PreparedStatement ps = conn.prepareStatement(sql);使用预编译对象，绑定sql
2. ps.addBatch();添加批处理
3. int[] counts = ps.executeBatch();执行批处理

package com.shanxi.weixin;

import java.io.FileInputStream;
import java.io.IOException;
import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.ResultSet;
import java.sql.SQLException;
import java.sql.Statement;
import java.util.Properties;

public class JDBCDemo5 {

	public static void main(String[] args) {
		
		try {
			Class.forName("com.mysql.jdbc.Driver");
	  		Connection conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test4?useUnicode=true&characterEncoding=utf8","root", "root");
	  		String sql = "insert into people(name,age,sex) values(?,?,?)";
	  		//Statement sta = conn.createStatement();
	  		
	  		//打开一个预编译对象  同时绑定sql
	  		PreparedStatement ps = conn.prepareStatement(sql);
	  		ps.setString(1, "bob");
	  		ps.setString(3, "boy");
	  		ps.setInt(2, 22);
	  		//将本条sql处理 加入批处理
	  		ps.addBatch();
	  		
	  		ps.setString(1, "mary");
	  		ps.setString(3, "girl");
	  		ps.setInt(2, 18);
	  		//将重新设置参数后的预编译sql继续加入批处理
	  		ps.addBatch();
	  		//同时也可以绑定多条静态sql
	  		ps.addBatch("insert into people(name,age,sex) values('rose',19,'girl')");
	  		//执行批处理任务
	  		int[] counts = ps.executeBatch();
	  		ps.clearBatch();
	  		for (int i : counts) {
				System.out.println(i);
			}
	  		if(conn!=null){
	  			conn.close();
	  		}                                      
		}catch (ClassNotFoundException e) {
			e.printStackTrace();
		}catch (SQLException e) {
			e.printStackTrace();
		}
	}
}