java之jdbc_批量添加数据(batch)

动力节点笔记

 

import java.sql.*;
//采用Batch添加数据
public class BatchTest01 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            //第一步，加载数据库驱动，不一样的数据库驱动程序不同
            Class.forName("oracle.jdbc.driver.OracleDriver");
            //第二部，获得数据库链接
            String dburl = "jdbc:oracle:thin:@localhost:1521:orcl";
            //String dburl = "jdbc:oracle:thin:@192.168.21.1:1521:orcl";
            //String dburl = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
            String userName = "system";
            String password = "wanwan";
            conn = DriverManager.getConnection(dburl, userName, password);
            //System.out.println(conn);

            String sql = "insert into enp(empno, ename) values(?, ?)";
            pstmt = conn.prepareStatement(sql);
            for (int i = 0; i < 10; i++) {
                pstmt.setInt(1, 8000 + i);
                pstmt.setString(2, "赵" + i);
                //这种方式与数据库打交道的次数比较频繁
                //若是数据库与应用程序再也不一台机器上，那么会有性能的损耗
                //因此跨网络的传输最好粒度粗一点
                pstmt.executeUpdate();
            }

            System.out.println("添加员工成功");

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //注意关闭原则：从里到外
            try {
                if (pstmt != null) {
                    pstmt.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch(SQLException e) {

            }

        }
    }
}

 

 

import java.sql.*;
//采用Batch添加数据
public class BatchTest02 {
    public static void main(String[] args) {
        Connection conn = null;
        PreparedStatement pstmt = null;
        try {
            //第一步，加载数据库驱动，不一样的数据库驱动程序不同
            Class.forName("oracle.jdbc.driver.OracleDriver");
            //第二部，获得数据库链接
            String dburl = "jdbc:oracle:thin:@localhost:1521:orcl";
            //String dburl = "jdbc:oracle:thin:@192.168.21.1:1521:orcl";
            //String dburl = "jdbc:oracle:thin:@127.0.0.1:1521:orcl";
            String userName = "system";
            String password = "wanwan";
            conn = DriverManager.getConnection(dburl, userName, password);
            //System.out.println(conn);

            String sql = "insert into enp(empno, ename) values(?, ?)";
            pstmt = conn.prepareStatement(sql);
            for (int i = 1; i <= 100; i++) {
                pstmt.setInt(1, 9000 + i);
                pstmt.setString(2, "张_" + i);
                pstmt.addBatch();
                if (i % 10 == 0) {
                    //批量更新
                    pstmt.executeBatch();
                }
            }
            pstmt.executeUpdate();
            System.out.println("添加员工成功");

        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            //注意关闭原则：从里到外
            try {
                if (pstmt != null) {
                    pstmt.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch(SQLException e) {

            }

        }
    }
}