php写入mysql大量数据

$sql = "INSERT INTO table_name (column1, column2) VALUES ";
$values = [];

foreach ($data as $row) {
    $values[] = "('" . implode("', '", $row) . "')";
}

$sql .= implode(', ', $values);

if ($conn->query($sql) === TRUE) {
    echo "Records inserted successfully";
} else {
    echo "Error: " . $sql . "<br>" . $conn->error;
}

$conn->begin_transaction();

try {
    foreach ($data as $row) {
        $sql = "INSERT INTO table_name (column1, column2) VALUES ('" . implode("', '", $row) . "')";
        if (!$conn->query($sql)) {
            throw new Exception($conn->error);
        }
    }
    $conn->commit();
    echo "Records inserted successfully";
} catch (Exception $e) {
    $conn->rollback();
    echo "Error: " . $e->getMessage();
}

$batchSize = 1000;
$totalRows = count($data);
$numBatches = ceil($totalRows / $batchSize);

for ($i = 0; $i < $numBatches; $i++) {
    $start = $i * $batchSize;
    $end = min($start + $batchSize, $totalRows);
    $batchData = array_slice($data, $start, $end - $start);

    // 执行批量插入或事务处理
}

$conn->query("SET SESSION MAX_EXECUTION_TIME = 3600"); // 设置为3600秒

$conn = new mysqli('localhost', 'username', 'password', 'database', null, null, MYSQLI_CLIENT_FOUND_ROWS | MYSQLI_USE_RESULT);
$conn->query("SET SESSION MAX_EXECUTION_TIME = 3600");