Добавление записей в таблицы базы данных с помощью PHP

Как выполнить массовую вставку тысяч записей с максимальной производительностью?

При вставке большого количества строк (например, из CSV или внешнего источника) используйте транзакции и один подготовленный запрос в цикле. Это ускоряет операцию за счет снижения накладных расходов на подтверждение каждой вставки.

// Пример: вставка 1000 случайных пользователей
$pdo = new PDO('mysql:host=localhost;dbname=test;charset=utf8mb4', 'root', '');
$pdo->beginTransaction();
$sql = 'INSERT INTO users (name, email, age) VALUES (:name, :email, :age)';
$stmt = $pdo->prepare($sql);

for ($i = 0; $i < 1000; $i++) {
    $stmt->execute([
        ':name' => 'User ' . $i,
        ':email' => "user{$i}@example.com",
        ':age' => rand(18, 80)
    ]);
}
$pdo->commit();
echo "Вставлено 1000 записей";

Результат: Вставлено 1000 записей

Пояснение:

• Транзакция (beginTransaction / commit) объединяет все вставки в одну атомарную операцию, что значительно быстрее, чем каждая вставка с отдельным коммитом.
• При ошибке можно откатить все изменения (rollback).
• Рекомендуется при вставке более 100 строк.

Как вставить запись или обновить существующую (UPSERT)?

Для реализации "вставь или обнови" используйте INSERT ... ON DUPLICATE KEY UPDATE. Этот запрос вставляет новую строку, а если уже существует запись с таким же уникальным ключом, то обновляет заданные поля.

// Предполагается, что email имеет уникальный индекс
$sql = 'INSERT INTO users (name, email, age) VALUES (:name, :email, :age)
        ON DUPLICATE KEY UPDATE name = VALUES(name), age = VALUES(age)';
$stmt = $pdo->prepare($sql);
$stmt->execute([
    ':name' => 'Обновленный Иван',
    ':email' => 'ivan@example.com',
    ':age' => 31
]);
echo $stmt->rowCount(); // 1 если вставка, 2 если обновление

Важно: VALUES(name) ссылается на предлагаемое значение. Альтернативно можно использовать :name.

Как вставить данные из CSV файла, обрабатывая ошибки?

Пример загрузки CSV в базу с проверкой каждой строки и пропуском некорректных записей.

$pdo = new PDO('mysql:host=localhost;dbname=test;charset=utf8mb4', 'root', '');
$pdo->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

$handle = fopen('users.csv', 'r');
if (!$handle) die('Не удалось открыть файл');

$stmt = $pdo->prepare('INSERT INTO users (name, email, age) VALUES (:name, :email, :age)');
$rowCount = 0;
$errorCount = 0;

while (($row = fgetcsv($handle, 1000, ',')) !== FALSE) {
    $name = $row[0] ?? '';
    $email = $row[1] ?? '';
    $age = isset($row[2]) ? (int)$row[2] : null;
    if (empty($name) || empty($email)) {
        $errorCount++;
        continue;
    }
    try {
        $stmt->execute([':name' => $name, ':email' => $email, ':age' => $age]);
        $rowCount++;
    } catch (PDOException $e) {
        // Логирование ошибки
        error_log("Ошибка вставки строки: " . implode(',', $row) . " - " . $e->getMessage());
        $errorCount++;
    }
}
fclose($handle);
echo "Вставлено: $rowCount, ошибок: $errorCount";

Результат: Вставлено: 950, ошибок: 50

Как вставить NULL в поле базы данных?

Если столбец допускает NULL, передавайте в запросе значение null в PHP. Важно не путать с пустой строкой. Пример:

$sql = 'INSERT INTO users (name, email, age) VALUES (:name, :email, :age)';
$stmt = $pdo->prepare($sql);
$stmt->execute([
    ':name' => 'Пользователь без возраста',
    ':email' => 'noage@test.com',
    ':age' => null  // явно передается null
]);

Если параметр не передавать, PDO может воспринять его как неопределенное значение и вызвать ошибку. Всегда передавайте null явно.

Как использовать INSERT IGNORE для пропуска дубликатов?

Опция INSERT IGNORE позволяет вставить только те строки, которые не вызывают ошибок дублирования по уникальным индексам. Остальные строки игнорируются без генерации исключения.

$sql = 'INSERT IGNORE INTO users (email) VALUES (:email)';
$stmt = $pdo->prepare($sql);
$emails = ['ivan@example.com', 'petr@example.com', 'ivan@example.com']; // дубль
foreach ($emails as $email) {
    $stmt->execute([':email' => $email]);
}
echo 'Вставлено строк: ' . $stmt->rowCount(); // 2 (третий дубль проигнорирован)

Обратите внимание: rowCount() возвращает количество реально вставленных строк.