Mysql批量插入executeBatch测试

Mysql批量插入executeBatch测试

第一次：没有设置手动提交，jdbc自动提交，代码如下：

public void test23(){
		Connection conn = new ConnectionManager().newConnection();
        PreparedStatement ps = null;
        try {
            String sql = "insert into uuidtest(uuid) values(?)";
            ps = conn.prepareStatement(sql);
            long start = System.currentTimeMillis();
            for (int i = 0; i < 10000; i++) {
                String uuid = UUID.randomUUID().toString();
                System.out.println(uuid);
                ps.setString(1, uuid);
                ps.addBatch();
            }
            ps.executeBatch();
            long end = System.currentTimeMillis();
            System.out.println(end-start);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
	}

执行时间为：165766毫秒

第二次：设置手动提交，程序最后手动提交，代码如下：

public void test23(){
		Connection conn = new ConnectionManager().newConnection();
        PreparedStatement ps = null;
        try {
        	conn.setAutoCommit(false);
            String sql = "insert into uuidtest(uuid) values(?)";
            ps = conn.prepareStatement(sql);
            long start = System.currentTimeMillis();
            for (int i = 0; i < 10000; i++) {
                String uuid = UUID.randomUUID().toString();
                System.out.println(uuid);
                ps.setString(1, uuid);
                ps.addBatch();
            }
            ps.executeBatch();
            conn.commit();
            long end = System.currentTimeMillis();
            System.out.println(end-start);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
	}

执行时间为：1135毫秒

第三次：设置手动提交，程序最后手动提交，每一千次执行缓存的sql语句并清空缓存，代码如下：

public void test23(){
		Connection conn = new ConnectionManager().newConnection();
        PreparedStatement ps = null;
        try {
        	conn.setAutoCommit(false);
            String sql = "insert into uuidtest(uuid) values(?)";
            ps = conn.prepareStatement(sql);
            long start = System.currentTimeMillis();
            for (int i = 0; i < 10000; i++) {
                String uuid = UUID.randomUUID().toString();
                System.out.println(uuid);
                ps.setString(1, uuid);
                ps.addBatch();
                if(i%1000==0){
                	ps.executeBatch();
                	ps.clearBatch();
                }
            }
            conn.commit();
            long end = System.currentTimeMillis();
            System.out.println(end-start);
        } catch (SQLException e) {
            e.printStackTrace();
        } finally {
            if (ps != null) {
                try {
                    ps.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
            if (conn != null) {
                try {
                    conn.close();
                } catch (SQLException e) {
                    e.printStackTrace();
                }
            }
        }
	}

执行时间为：993毫秒