1

我使用以下代码遍历文件夹中的文件并将数据加载到 MYSQL 表中。我无法完成这项工作。有没有更好的解决方案？

if ($handle = opendir('C:\Documents and Settings\Desktop\CSV Files')) {
while(false !== ($entry = readdir($handle)))
{
mysql_query("LOAD DATA LOCAL INFILE %handle
                          INTO TABLE main_table
                          FIELDS
                          TERMINATED BY ','
                          OPTIONALLY ENCLOSED BY '"'
                          ESCAPED BY '"'
                          LINES TERMINATED BY '\r\n'
                          IGNORE 1 LINES")
}
}
4

1 回答 1

1

您的代码有很多错误，很难选择从哪里开始......

  • 您的目录路径未转义。
  • 您没有任何信息可以告诉您该目录无法打开。
  • %handle不是 PHP 变量，而且它是错误的变量。
  • $entry只是文件名，而不是完整路径。
  • mysql_query()通话结束时没有分号。
  • 您的 'enclose' 和 'escape' 字符都是"，两者都没有被转义。
  • echo查询而不是运行它以确保它在不工作时正确形成。
  • 您从未真正检查查询是否成功。
  • 打开错误报告，因为你有一些明显的解析错误应该使这个脚本在它运行之前就失败。
  • 和流行的：mysql_*函数已被弃用，您应该使用 PDO 或 MySQLi。

所以这应该可以工作：

<?php
error_reporting(E_ALL);
define('DEBUG', true);

$basedir = 'C:\\Documents and Settings\\Desktop\\CSV Files\\';
if ($handle = opendir($basedir)) {
  while(false !== ($entry = readdir($handle))) {
    $query = "LOAD DATA LOCAL INFILE $basedir$entry
                INTO TABLE main_table
                FIELDS
                TERMINATED BY ','
                OPTIONALLY ENCLOSED BY '\"'
                ESCAPED BY '\\'
                LINES TERMINATED BY '\r\n'
                IGNORE 1 LINES");
    if(DEBUG) { echo $query . "\n"; }
    if(!mysql_query($query)) {
      die('Query failed: ' . mysql_error());
    }
  }
} else {
  echo "Could not open $basedir";
}
于 2013-04-11T19:55:12.903 回答