如何通过上传 CSV 文件使用 php 更新数据库？

Question

我这里有一些代码可以根据 CSV 中的两列更新我的数据库。 CSV 文件如下所示：

ID 响应

1 你好1

2 你好2

3 你好3

在我的数据库中，我有一个表，其中还包含一个 id 列和一个与响应匹配的额外列。想法是上传此 CSV 文件，并将填充与 ID 号匹配的响应。

基本上是这样的：“UPDATE tbl_data SET response = {$response} WHERE id = {$id}”

执行此操作的表单如下所示：

<form method="post" name="uploadCSV" enctype="multipart/form-data">
    <label>Choose CSV File</label>
    <input type="file" name="csv_file" id="file" accept=".csv" />
    <button type="submit" name="import" class="read-more smaller">Upload</button>
</form>

但是，我认为我不明白如何正确执行此操作，因为我收到 SQL 错误，或者表单只是坐在那里，好像什么都没发生一样。请参阅下面的代码。

if (isset($_POST["import"])) {

    if($_FILES["csv_file"]["name"]){

        $filename = explode(".", $_FILES["csv_file"]["name"]);

        if(end($filename) == "csv"){

            $handle = fopen($_FILES["csv_file"]["tmp_name"], "r");

            while ($data = fgetcsv($handle)){

                $id = $data[0];
                $response = $data[1];

                $query ="UPDATE tbl_data SET response = {$response} WHERE id = {$id}";
                $update_data = mysqli_query($connection,$query);

                if (!$update_data) {
                    $message = "There was a problem updating your CSV file. If this problem reoccurs, please contact admin";
                    die (mysqli_error($connection));
                }

            }

            fclose($handle);

            header("Location: upload.php?uploaded=1");

        } else {
            $message = "You can only upload a CSV file.";
        }

    } else {
        $message = "Please select a CSV file.";
    }

}

我有 $message 来显示消息。但它没有显示任何消息，并且数据库中的更新似乎也没有发生。

我的代码中是否有任何我可能忽略的错误？还是有更好的方法来做到这一点？

Answer 1

通过以下方式让它工作

if(isset($_POST["importcsv"])){

        $file = $_FILES["csv_file"]["tmp_name"];
        $handle = fopen($file,"r");

        while ($row = fgetcsv($handle)) {

            $id = $row[0];
            $response = $row[1];

            $sql = "UPDATE table SET response = ? WHERE id = ?";
            $update_data_stmt = mysqli_stmt_init($connection);

            if (!mysqli_stmt_prepare($update_data_stmt, $sql)){
                die("Something went wrong with the upload. " . mysqli_error($connection));
            } else {
                mysqli_stmt_bind_param($update_data_stmt, "ss", $response, $id);
                mysqli_stmt_execute($update_data_stmt);
                if ($id == "ID" && $response == "Response"){
                    echo "";
                } else {
                    echo "Lead <b>{$id}</b>'s response was updated to <b>{$response}</b>.</p>";
                }
            }

        }

    }