Java實現(xiàn)JDBC向數(shù)據(jù)庫批量插入

更新時間：2023年09月22日 16:38:07 作者：境里婆娑

在Java項目中可能會出現(xiàn)大量向數(shù)據(jù)庫中插入的情況,本文主要介紹了Java實現(xiàn)JDBC向數(shù)據(jù)庫批量插入,具有一定的參考價值,感興趣的可以了解一下

一、JDBC實現(xiàn)批量插入幾種方式

使用PreparedStatement的批處理：這是最常見的批量插入方式之一，適用于大多數(shù)數(shù)據(jù)庫。你可以使用addBatch方法將多個插入語句添加到PreparedStatement對象中，然后使用executeBatch執(zhí)行批處理操作。這個方式在上一個回答中已經(jīng)進行了詳細說明。
使用批處理語句：一些數(shù)據(jù)庫支持批處理語句，例如MySQL的INSERT INTO ... VALUES (?, ?), (?, ?), ...語法。你可以構建這樣的SQL語句，一次性插入多個數(shù)據(jù)行。

String sql = "INSERT INTO your_table (column1, column2) VALUES (?, ?), (?, ?), (?, ?)";
PreparedStatement preparedStatement = connection.prepareStatement(sql);
// 設置占位符的值
preparedStatement.setString(1, value1);
preparedStatement.setString(2, value2);
preparedStatement.setString(3, value3);
preparedStatement.setString(4, value4);
preparedStatement.setString(5, value5);
preparedStatement.setString(6, value6);
// 執(zhí)行批處理
int[] batchResults = preparedStatement.executeBatch();

使用JDBC批處理API： JDBC 2.0引入了java.sql.Statement接口的批處理方法。你可以使用addBatch方法將多個SQL語句添加到Statement對象中，然后使用executeBatch方法執(zhí)行批處理操作。

Statement statement = connection.createStatement();
statement.addBatch("INSERT INTO your_table (column1, column2) VALUES ('value1', 'value2')");
statement.addBatch("INSERT INTO your_table (column1, column2) VALUES ('value3', 'value4')");
statement.addBatch("INSERT INTO your_table (column1, column2) VALUES ('value5', 'value6')");
int[] batchResults = statement.executeBatch();

二、PreparedStatement addBatch方法使用

PreparedStatement的addBatch方法用于將多個SQL語句添加到批處理中，以便一次性執(zhí)行多個SQL操作。這可以顯著提高數(shù)據(jù)庫操作的性能，尤其是在需要插入、更新或刪除多個數(shù)據(jù)行時。

import java.sql.Connection;
import java.sql.DriverManager;
import java.sql.PreparedStatement;
import java.sql.SQLException;
public class BatchInsertExample {
    public static void main(String[] args) {
        String jdbcUrl = "jdbc:mysql://localhost:3306/tbl";
        String username = "root";
        String password = "root";
        Connection connection = null;
        PreparedStatement preparedStatement = null;
        try {
            // 建立數(shù)據(jù)庫連接
            connection = DriverManager.getConnection(jdbcUrl, username, password);
            // SQL插入語句，使用占位符來防止SQL注入
            String sql = "INSERT INTO goods(name, price) VALUES (?, ?)";
            // 創(chuàng)建PreparedStatement對象，并設置為批處理模式
            preparedStatement = connection.prepareStatement(sql);
            connection.setAutoCommit(false); // 設置為手動提交
            // 循環(huán)添加多個批處理操作
            for (int i = 0; i < 10; i++) {
                // 設置占位符的值
                preparedStatement.setString(1, "value" + i);
                preparedStatement.setString(2, "value" + (i * 2));
                // 添加到批處理中
                preparedStatement.addBatch();
            }
            // 執(zhí)行批處理
            int[] batchResults = preparedStatement.executeBatch();
            // 手動提交事務
            connection.commit();
            // 檢查批處理執(zhí)行結果
            for (int result : batchResults) {
                if (result == PreparedStatement.SUCCESS_NO_INFO || result == PreparedStatement.EXECUTE_FAILED) {
                    // 處理失敗的情況
                }
            }
        } catch (SQLException e) {
            e.printStackTrace();
            try {
                // 發(fā)生異常時回滾事務
                if (connection != null) {
                    connection.rollback();
                }
            } catch (SQLException ex) {
                ex.printStackTrace();
            }
        } finally {
            try {
                // 關閉PreparedStatement和Connection
                if (preparedStatement != null) {
                    preparedStatement.close();
                }
                if (connection != null) {
                    connection.close();
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }
}

在上述示例中，我們創(chuàng)建了一個PreparedStatement對象，將多個插入操作添加到批處理中，并最后執(zhí)行批處理。注意以下幾點：

使用setString等方法設置占位符的值，然后使用addBatch方法將每個操作添加到批處理中。
執(zhí)行批處理操作后，executeBatch返回一個整數(shù)數(shù)組，其中包含每個批處理操作的執(zhí)行結果。你可以根據(jù)需要處理失敗的情況。
為了保持數(shù)據(jù)的一致性，我們使用connection.setAutoCommit(false)關閉了自動提交模式，手動提交事務，以便在所有操作成功后一起提交。
在異常情況下，我們使用connection.rollback()回滾事務，以避免數(shù)據(jù)不一致。

connection.setAutoCommit是用于設置JDBC連接的自動提交模式的方法。在JDBC中，自動提交是指每個SQL操作是否都立即提交到數(shù)據(jù)庫，或者是否需要手動調用commit方法來提交事務。

默認情況下，JDBC連接的自動提交模式是打開的（true）。這意味著每個SQL操作都會立即提交到數(shù)據(jù)庫，形成一個獨立的事務。這對于簡單的操作非常方便，但在某些情況下，你可能希望將多個SQL操作組合成一個事務以確保數(shù)據(jù)的一致性。

你可以使用connection.setAutoCommit(false)來關閉自動提交模式，這樣就可以手動管理事務。一旦關閉了自動提交，你可以通過調用connection.commit()來提交事務，將之前的SQL操作組合成一個事務。

三、Statement 和PreparedStatement 區(qū)別

Statement和PreparedStatement是Java JDBC（Java數(shù)據(jù)庫連接）中兩種執(zhí)行SQL語句的方式，它們在使用和性能上有一些重要的區(qū)別。

Statement：

靜態(tài)SQL語句： Statement用于執(zhí)行靜態(tài)SQL語句，這意味著SQL查詢在編寫代碼時已經(jīng)被定義好，不能包含動態(tài)參數(shù)。
不安全： 由于Statement不支持參數(shù)化查詢，因此它容易受到SQL注入攻擊。如果直接將用戶提供的數(shù)據(jù)拼接到SQL語句中，可能會導致安全問題。
性能問題： 在需要多次執(zhí)行相同的SQL語句時，Statement的性能通常較差。每次執(zhí)行時，數(shù)據(jù)庫都需要解析和編譯SQL語句。
代碼可讀性： 由于SQL語句直接嵌入在Java代碼中，Statement的代碼通常比較難讀懂，維護困難。

PreparedStatement：

動態(tài)SQL語句： PreparedStatement用于執(zhí)行動態(tài)SQL語句，它支持參數(shù)化查詢。你可以使用占位符來表示參數(shù)，然后在執(zhí)行之前設置這些參數(shù)的值。這使得你可以輕松地構建動態(tài)查詢，根據(jù)不同的輸入執(zhí)行不同的查詢。
安全性： 由于參數(shù)化查詢，PreparedStatement可以防止SQL注入攻擊，因為參數(shù)值不會直接嵌入到SQL語句中，而是通過參數(shù)傳遞。
性能優(yōu)化： PreparedStatement通常比Statement更高效，因為數(shù)據(jù)庫可以緩存已編譯的SQL語句，而且每次只需傳遞參數(shù)值，而不是重新解析和編譯SQL語句。
代碼可讀性： 使用PreparedStatement可以使代碼更清晰和易于維護，因為SQL語句與參數(shù)值分離，降低了代碼的復雜性。