一、批量操作(batch)

    當需要成批插入或者更新記錄時，可以採用Java的批量更新機制，這一機制允許多條語句一次性提交給資料庫批量處理。通常情況下比單獨提交處理更有效率.

JDBC的批量處理語句包括下面兩個方法：
addBatch(String sql)：新增需要批量處理的SQL語句或是引數；
executeBatch（）；執行批量處理語句；

通常我們會遇到兩種批量執行SQL語句的情況：
多條SQL語句的批量處理； :Statement
一個SQL語句的批量傳參； :PreparedStatement


需求:同時向t_student表,插入1000條資料，在JDBC中,MySQL不支援批量操作。
-------------------------------------------------------------------------
Statement 批處理 ： 一次性可以執行多條sql語句，需要編譯多次。
應用場景：系統初始化 (建立表，建立資料等)
新增sql語句，st.addBatch(sql)   --新增sql語句
批量處理sql語句，int[] st.executeBatch()
清除快取： st.clearBatch();
-------------------------------------------------------------------------
PreparedStatement 批處理 ： 執行一條sql語句，編譯一次，執行sql語句的引數不同。
應用場景：表資料初始化
新增批量引數：psmt.addBatch()    --新增實際引數，執行之前，需要執行psmt.setXxx()設定實際引數
執行批處理：int[] psmt.executeBatch()
清除快取：pstm.clearBatch();

1.使用Statement完成，沒有批處理

程式碼演示：

public void saveByStatement() {
	// 宣告資源物件
	Connection conn = null;
	Statement stmt = null;
	// 賈璉欲執事
	try {
		// 1.載入註冊驅動
		Class.forName("com.mysql.jdbc.Driver");
		// 2.獲取連線物件
		conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "rootroot");
		// 3.獲取語句物件
		stmt = conn.createStatement();
		// 迴圈5000次
		long begin = System.currentTimeMillis();
		for (int i = 0; i < 1000; i++) {
			String sql = "insert into t_student (name,age) values('a'," + i + ")";
			stmt.executeUpdate(sql);
		}
		long end = System.currentTimeMillis();
		System.out.println(end - begin);
	} catch (Exception e) {
		e.printStackTrace();
	} finally {
		// 5.釋放資源
		try {
			if (stmt != null) {
				stmt.close();
			}
			if (conn != null) {
				conn.close();
			}
		} catch (SQLException e) {
			e.printStackTrace();
		}
	}
}
 

程式碼執行結果：

// InnoDB:2263ms
// MyISAM:300ms

2.使用Statement完成，使用批處理

程式碼演示：

        @Test
	public void BatchsaveByStatement() {
		// 宣告資源物件
		Connection conn = null;
		Statement stmt = null;
		// 賈璉欲執事
		try {
			// 1.載入註冊驅動
			Class.forName("com.mysql.jdbc.Driver");
			// 2.獲取連線物件
			conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "rootroot");
			// 3.獲取語句物件
			stmt = conn.createStatement();
			// 迴圈5000次
			long begin = System.currentTimeMillis();
			for (int i = 0; i < 1000; i++) {
				String sql = "insert into t_student (name,age) values('a'," + i + ")";
				// 將SQL新增到批處理中
				stmt.addBatch(sql);
				if (i % 200 == 0) {
					stmt.executeBatch();// 執行批量操作
					stmt.clearBatch();// 清除批處理
				}
			}
			long end = System.currentTimeMillis();
			System.out.println(end - begin);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			// 5.釋放資源
			try {
				if (stmt != null) {
					stmt.close();
				}
				if (conn != null) {
					conn.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}
 

程式碼執行結果：

// InnoDB:1990ms
// MyISAM:387ms

3.使用PreparedStatement完成，沒有批處理

程式碼演示：

	public void saveByPreparedStatement() {
		// 宣告資源物件
		Connection conn = null;
		PreparedStatement ps = null;
		// 賈璉欲執事
		try {
			// 1.載入註冊驅動
			Class.forName("com.mysql.jdbc.Driver");
			// 2.獲取連線物件
			conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "rootroot");
			// 3.獲取語句物件
			String sql = "insert into t_student (name,age) values('a',?)";
			ps = conn.prepareStatement(sql);
			// 迴圈5000次
			long begin = System.currentTimeMillis();
			for (int i = 0; i < 1000; i++) {
				ps.setInt(1, i);
				ps.executeUpdate();
			}
			long end = System.currentTimeMillis();
			System.out.println(end - begin);
		} catch (Exception e) {
			e.printStackTrace();
		} finally {
			// 5.釋放資源
			try {
				if (ps != null) {
					ps.close();
				}
				if (conn != null) {
					conn.close();
				}
			} catch (SQLException e) {
				e.printStackTrace();
			}
		}
	}	

程式碼執行結果：

// InnoDB:1793ms
// MyISAM:277ms

4.使用PreparedStatement完成，使用批處理

程式碼演示：

public void BatchsaveByByPreparedStatement() {
        // 宣告資源物件
        Connection conn = null;
        PreparedStatement ps = null;
        // 賈璉欲執事
        try {
            // 1.載入註冊驅動
            Class.forName("com.mysql.jdbc.Driver");
            // 2.獲取連線物件
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test", "root", "rootroot");
            // 3.獲取語句物件
            String sql = "insert into t_student (name,age) values('a',?)";
            ps = conn.prepareStatement(sql);
            // 迴圈5000次
            long begin = System.currentTimeMillis();
            for (int i = 0; i < 1000; i++) {
                ps.setInt(1, i);
                ps.addBatch();
                if (i % 200 == 0) {
                    ps.executeBatch();
                    ps.clearBatch();
                    ps.clearParameters(); // 清除佔位符操作
                }

            }
            long end = System.currentTimeMillis();
            System.out.println(end - begin);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 5.釋放資源
            try {
                if (ps != null) {
                    ps.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

程式碼執行結果：

// InnoDB:1793ms
// MyISAM:277ms

二、結論

  MySQL伺服器既不支援PreparedStatement的效能優化,也不支援JDBC中的批量操作.但是,在新的JDBC驅動中,我們可以通過設定引數來優化。

url=jdbc:mysql://localhost:3306/test?rewriteBatchedStatements=true

5.使用PreparedStatement完成，使用批處理,rewriteBatchedStatements=true

程式碼演示：

public void BatchsaveByByPreparedStatement2() {
        // 宣告資源物件
        Connection conn = null;
        PreparedStatement ps = null;
        // 賈璉欲執事
        try {
            // 1.載入註冊驅動
            Class.forName("com.mysql.jdbc.Driver");
            // 2.獲取連線物件
            conn = DriverManager.getConnection("jdbc:mysql://localhost:3306/test?rewriteBatchedStatements=true", "root", "rootroot");
            // 3.獲取語句物件
            String sql = "insert into t_student (name,age) values('a',?)";
            ps = conn.prepareStatement(sql);
            // 迴圈5000次
            long begin = System.currentTimeMillis();
            for (int i = 0; i < 1000; i++) {
                ps.setInt(1, i);
                ps.addBatch();
                if (i % 200 == 0) {
                    ps.executeBatch();
                    ps.clearBatch();
                    ps.clearParameters(); // 清除佔位符操作
                }

            }
            long end = System.currentTimeMillis();
            System.out.println(end - begin);
        } catch (Exception e) {
            e.printStackTrace();
        } finally {
            // 5.釋放資源
            try {
                if (ps != null) {
                    ps.close();
                }
                if (conn != null) {
                    conn.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

程式碼執行結果：

// InnoDB:51ms
// MyISAM:29ms