使用 PHP 脚本将 CSV 上传到 MySQL。问题答案

【问题标题】：Upload CSV to MySQL with PHP script. Issues使用 PHP 脚本将 CSV 上传到 MySQL。问题
【发布时间】：2013-06-18 09:05:57
【问题描述】：

让我的 PHP 脚本正常工作有点麻烦。

我想要完成的工作： 在一个子页面上，我想要一个非常简单的 CSV 文件上传到 MySQL 数据库。它需要 DROP 或 TRUNCATE 表以及 CREATE 或 INSERT INTO，具体取决于之前的解决方案，此 CSV 文件中的一些数据。

我现在的问题是： 我是 PHP 和 MySQL 的初学者，因此无法弄清楚我的脚本为什么不起作用。

我的代码：

PHP：

$connect = mysql_connect("host","user","pass");  
mysql_select_db("database",$connect); //select the table 

if ($_FILES[csv][size] > 0) { 

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

mysql_query (" 
CREATE TABLE IF NOT EXISTS `database`.`table` (
`item_number` VARCHAR( 50 ) CHARACTER SET utf8 COLLATE utf8_danish_ci NOT NULL ,
`item_desq` VARCHAR( 200 ) CHARACTER SET utf8 COLLATE utf8_danish_ci NOT NULL ,
`item_img_path` VARCHAR( 200 ) CHARACTER SET utf8 COLLATE utf8_danish_ci NULL ,
`item_id` INT( 11 ) UNSIGNED NOT NULL AUTO_INCREMENT ,
PRIMARY KEY (  `item_id` )
) ENGINE = MYISAM CHARACTER SET utf8 COLLATE utf8_danish_ci                      
        ");

do { 
if ($data[0]) { 
   mysql_query("
                INSERT INTO strand_items1 (item_number, item_desq, item_img_path) 
                VALUES 
                      ( 
                      '".addslashes($data[0])."', 
                      '".addslashes($data[1])."',
          '".addslashes($data[2])."
                      ) 
              "); 
} 
} while ($data = fgetcsv($handle,1000,";","\"")); 

header('Location: import_old.php?success=1'); die; 
}

HTML：

<body>
    <form action="" method="post" enctype="multipart/form-data" name="form1" id="form1">
        Choose your file: <br />
        <input name="csv" type="file" id="csv" />
        <input type="submit" name="Submit" value="Submit" />
    </form>
</body>

CSV：CSV 中的普通行如下所示

"13371337";"Some description of the item";"NULL";

现在，结果：由此，我得到了一个“成功”的流程，但表中没有数据，据我猜测，数据库上出现了某种无限循环，因为它创建的数量越来越多表中只有 item_id 自动递增的空条目。我哪里出错了，有没有简单的方法来解决这个问题？

这是我在这里的第一个问题，我希望我能满足所有要求。（指出我的新手；问题首先发布在 meta.stackoverflow.com 上；））如果没有，请耐心等待 - 我会密切关注这个问题并迅速回答任何回复和要求。

提前谢谢你:)

【问题讨论】：

您使用的是an obsolete database API，应该使用modern replacement。 addslashes 不足以抵御 SQL injection attacks（现代 API 可以更轻松地从他们那里 defend 自己）。
感谢昆汀的回复。我知道我缺乏支持的 SQL 和 PHP。然而，由于这不是我的专业领域，我没有，也无法更新我对这些主题的知识。因此，我希望您忽略所有安全性和老式功能使用。我（和我的雇主）决定不雇用开发人员，因此不关心这些问题 :-)

标签： php mysql csv upload

【解决方案1】：

每次只截断你的表就容易多了。

这是我昨晚为朋友写的一个基本的导入器，它只是简单的，但你应该明白这个想法。显然我在这里使用 mysqli 所以你需要改变那个位以适合你的，你还必须在顶部添加截断（就在开始导入位之后就可以了。

if (isset($_POST['action']) && $_POST['action']=="beginimport") {
    echo "<h4>Starting Import</h4><br />";
    // Ignore user abort and expand time limit 
    //ignore_user_abort(true);
    set_time_limit(60);
    $result = @move_uploaded_file($_FILES['clientimport']['tmp_name'], getcwd()."/tmp/siccodes.csv");
    if(empty($result)){
        echo "<span style=\"font-weight:bold;color:red;\">There was an error moving the uploaded file</span><br />";
    } else {
        echo "<span style=\"font-weight:bold;color:green;\">Temp file created begining data parse<br /><br /></span>";
        if (($handle = fopen(getcwd()."/tmp/siccodes.csv", "r")) !== FALSE) {
            $row = 0;
            while (($data = fgetcsv($handle, 10000, ",")) !== FALSE) {  
                $client = $db->queryUniqueObject("SELECT ClientID FROM tblcreditchecks WHERE RegNumber='".mysqli_real_escape_string($db->mysqli,$data[0])."'",ENABLE_DEBUG);
                if ($data[2]>0) {
                    $db->execute("UPDATE tblcreditchecks SET TurnOver='".mysqli_real_escape_string($db->mysqli,$data[2])."' WHERE RegNumber='".mysqli_real_escape_string($db->mysqli,$data[0])."'",ENABLE_DEBUG);
                } else {
                    echo "Turnover fail - ".$data[0];
                }
                if ($client->ClientID>0) {
                    $db->execute("UPDATE tblclients SET SICCodes='".mysqli_real_escape_string($db->mysqli,$data[1])."' WHERE ID=".$client->ClientID,ENABLE_DEBUG);
                } else {
                    echo " SIC fail - ".$data[0];
                }

                echo " - IMPORTED - ".$data[0]."<br />";
                fcflush();
                set_time_limit(60); // reset timer on loop
            } 
        }
        fclose($handle);
        unlink(getcwd()."/tmp/siccodes.csv");
    }
    echo "COMPLETE";
}

【讨论】：

感谢您的回答戴夫。我正在努力让它在我们说话的时候发挥作用。会回来提供反馈:)
HINT 看起来您正在使用分号分隔符，因此请更改 fgetcsv($handle, 10000, ";")

【解决方案2】：

您正在使用 ;分隔符所以修复我用这样的东西它应该工作，这不是最好的方法，但感谢@Dave提示如何做到这一点......

if (isset($_POST['process'])) 
    {
        echo "<h2>Importing...</h2>";

        set_time_limit(60);
        $fileResult = move_uploaded_file($_FILES['csv']['tmp_name'], getcwd()."/tmp/somefile.csv");
        if(empty($fileResult))
        {
            echo "<h1>Some error</h1>";
        }
        else
        {
            if(($handle = fopen(getcwd()."/tmp/somefile.csv", "r")) !== false)
            {
                require_once 'dbController.php';
                $db_controller = new dbController();
                $db_connection = $db_controller->connectToDb();
                if($db_controller->conections_check == true)
                {   
                    $truncateTable = "
                        truncate table strand_items3
                    ";
                    $truncateTable = mysql_query($truncateTable);
                    $row = 1;
                    while (($data = fgetcsv($handle, 1000, ";")) !== false) 
                    {
                      $itiemId = $data[0];
                      $itemDescription = $data[1];

                      $insertQuery = "
                        INSERT INTO `tablename` (`value`, `value`, `value`) 
                        VALUES ('$itiemId', '$itemDescription', NULL)
                      ";

                       $insertQuery = mysql_query($insertQuery);
                    }
                }
                else
                {
                    echo "Error connecting to the server";
                }

            }
            fclose($handle);
            unlink(getcwd()."/tmp/somefile.csv");
        }
        echo "Done...";
    }
?>

【讨论】：