Java: вставьте несколько строк в MySQL с помощью PreparedStatement

Вы можете создать пакет с помощью PreparedStatement#addBatch() и выполните его с помощью PreparedStatement#executeBatch().

public void save(List<Entity> entities) throws SQLException {
    try (
        Connection connection = database.getConnection();
        PreparedStatement statement = connection.prepareStatement(SQL_INSERT);
    ) {
        int i = 0;

        for (Entity entity : entities) {
            statement.setString(1, entity.getSomeProperty());
            // ...

            statement.addBatch();
            i++;

            if (i % 1000 == 0 || i == entities.size()) {
                statement.executeBatch(); // Execute every 1000 items.
            }
        }
    }
}

• Учебное пособие по JDBC — использование PreparedStatement
• Учебное пособие по JDBC: использование объектов инструкций для пакетных обновлений

Когда используется драйвер MySQL, вы должны установить для параметра соединения rewriteBatchedStatements значение true ( jdbc:mysql://localhost:3306/TestDB?**rewriteBatchedStatements=true**).

С этим параметром оператор переписывается на массовую вставку, когда таблица блокируется только один раз и индексы обновляются только один раз. Так намного быстрее.

Без этого параметра единственным преимуществом является более чистый исходный код.

Если вы можете создать свой оператор sql динамически, вы можете сделать следующее обходное решение:

String myArray[][] = { { "1-1", "1-2" }, { "2-1", "2-2" }, { "3-1", "3-2" } };

StringBuffer mySql = new StringBuffer("insert into MyTable (col1, col2) values (?, ?)");

for (int i = 0; i < myArray.length - 1; i++) {
    mySql.append(", (?, ?)");
}

myStatement = myConnection.prepareStatement(mySql.toString());

for (int i = 0; i < myArray.length; i++) {
    myStatement.setString(i, myArray[i][1]);
    myStatement.setString(i, myArray[i][2]);
}
myStatement.executeUpdate();

Если у вас есть автоматическое увеличение в таблице и вам нужно получить к ней доступ... вы можете использовать следующий подход... Проведите тест перед использованием, потому что getGeneratedKeys() в операторе, потому что это зависит от используемого драйвера. Приведенный ниже код протестирован на Maria DB 10.0.12 и драйвере Maria JDBC 1.2.

Помните, что увеличение размера пакета улучшает производительность только в определенной степени... для моей установки увеличение размера пакета выше 500 на самом деле снижало производительность.

public Connection getConnection(boolean autoCommit) throws SQLException {
    Connection conn = dataSource.getConnection();
    conn.setAutoCommit(autoCommit);
    return conn;
}

private void testBatchInsert(int count, int maxBatchSize) {
    String querySql = "insert into batch_test(keyword) values(?)";
    try {
        Connection connection = getConnection(false);
        PreparedStatement pstmt = null;
        ResultSet rs = null;
        boolean success = true;
        int[] executeResult = null;
        try {
            pstmt = connection.prepareStatement(querySql, Statement.RETURN_GENERATED_KEYS);
            for (int i = 0; i < count; i++) {
                pstmt.setString(1, UUID.randomUUID().toString());
                pstmt.addBatch();
                if ((i + 1) % maxBatchSize == 0 || (i + 1) == count) {
                    executeResult = pstmt.executeBatch();
                }
            }
            ResultSet ids = pstmt.getGeneratedKeys();
            for (int i = 0; i < executeResult.length; i++) {
                ids.next();
                if (executeResult[i] == 1) {
                    System.out.println("Execute Result: " + i + ", Update Count: " + executeResult[i] + ", id: "
                            + ids.getLong(1));
                }
            }
        } catch (Exception e) {
            e.printStackTrace();
            success = false;
        } finally {
            if (rs != null) {
                rs.close();
            }
            if (pstmt != null) {
                pstmt.close();
            }
            if (connection != null) {
                if (success) {
                    connection.commit();
                } else {
                    connection.rollback();
                }
                connection.close();
            }
        }
    } catch (SQLException e) {
        e.printStackTrace();
    }
}

@Ali Shakiba, ваш код нуждается в некоторой модификации. Часть ошибки:

for (int i = 0; i < myArray.length; i++) {
     myStatement.setString(i, myArray[i][1]);
     myStatement.setString(i, myArray[i][2]);
}

Обновленный код:

String myArray[][] = {
    {"1-1", "1-2"},
    {"2-1", "2-2"},
    {"3-1", "3-2"}
};

StringBuffer mySql = new StringBuffer("insert into MyTable (col1, col2) values (?, ?)");

for (int i = 0; i < myArray.length - 1; i++) {
    mySql.append(", (?, ?)");
}

mysql.append(";"); //also add the terminator at the end of sql statement
myStatement = myConnection.prepareStatement(mySql.toString());

for (int i = 0; i < myArray.length; i++) {
    myStatement.setString((2 * i) + 1, myArray[i][1]);
    myStatement.setString((2 * i) + 2, myArray[i][2]);
}

myStatement.executeUpdate();

мы можем отправлять несколько обновлений вместе в JDBC для отправки пакетных обновлений.

мы можем использовать объекты Statement, PreparedStatement и CallableStatement для обновления bacth с отключением автофиксации.

Функции addBatch() и executeBatch() доступны для всех объектов операторов, для которых установлено BatchUpdate.

здесь метод addBatch() добавляет набор операторов или параметров к текущему пакету.