JDBC的批处理操作

1 什么是JDBC批处理

JDBC批处理，意思是我们可以执行一批（组）SQL操作。批处理可以使数据库执行性能更快。

java.sql.Statement和java.sql.PreparedStatement接口都提供了用于批处理的方法。

2 JDBC批处理的好处

提交数据库执行性能

3 批处理的方法

方法	说明
void addBatch(String query)	将SQL语句添加到批处理中。
int[] executeBatch()	执行批处理中的SQL语句。

4 Statement进行JDBC批处理

4.1 编写测试类

StmtBatchDemo：

package com.yiidian;

import java.io.*;
import java.sql.*;

/**
 * 一点教程网 - http://www.yiidian.com
 */
public class StmtBatchDemo {
    public static void main(String args[])throws Exception {
        try {
            Class.forName("com.mysql.jdbc.Driver");

            Connection con = DriverManager.getConnection(
                    "jdbc:mysql://localhost:3306/test", "root", "root");

            con.setAutoCommit(false);

            Statement stmt=con.createStatement();

            //把SQL语句加入批处理中
            stmt.addBatch("insert into t_user(username,password) values('eric','123')");
            stmt.addBatch("insert into t_user(username,password) values('jack','123')");

            //执行批处理
            stmt.executeBatch();

            con.commit();

            con.close();
        }catch(Exception e){
            System.out.println(e);
        }
    }
}

4.2 运行测试

5 PreparedStatement进行JDBC批处理

5.1 编写测试类

PsmtBatchDemo：

package com.yiidian;

import java.io.*;
import java.sql.*;

/**
 * 一点教程网 - http://www.yiidian.com
 */
public class PsmtBatchDemo {
    public static void main(String args[])throws Exception {
        try {
            Class.forName("com.mysql.jdbc.Driver");

            Connection con = DriverManager.getConnection(
                    "jdbc:mysql://localhost:3306/test", "root", "root");

            PreparedStatement ps=con.prepareStatement("insert into t_user(username,password) values(?,?)");

            BufferedReader br=new BufferedReader(new InputStreamReader(System.in));
            while(true){

                System.out.println("请输入名称");
                String name=br.readLine();

                System.out.println("请输入密码");
                String password=br.readLine();

                ps.setString(1,name);
                ps.setString(2,password);

                //添加到批处理中
                ps.addBatch();
                System.out.println("想要继续添加记录么？ y/n");
                String ans=br.readLine();
                if(ans.equals("n")){
                    break;
                }

            }

            //执行批处理操作
            ps.executeBatch();

            System.out.println("保存成功");

            con.close();
        }catch(Exception e){
            System.out.println(e);
        }
    }
}

5.2 运行测试

最终数据库表中添加了两条记录