更新

在我发布这个问题后的第二个，由于结果查询的语法突出显示，我看到了问题所在:$pl 字符串没有打开并带有关闭的反勾号。现在我将其更改为:

$pk = ',`%1$sUSER`,`%1$sTYPE`,`%1$sCODE`,`%1$sVALUE`,`%1$s';//WRONG
$pk = '`,`%1$sUSER`,`%1$sTYPE`,`%1$sCODE`,`%1$sVALUE`,`%1$s';//OK

然而，这提出了一个新问题:为什么 PDO 对象没有为此向我吐出错误？手动执行查询肯定会返回一个错误，指出没有名为 fld2_AGE, 的字段，末尾有一个逗号。为什么我没有收到任何错误？有什么想法吗？

PS:知道如何通过 SO 的语法高亮来解决我的问题吗？ :-)

我将原始问题作为引用/示例，尽管它不再需要解决

好的，我一直在使用前一段时间编写的脚本来从一个巨大的文件中导入生成多个 csv 文件，以快速将数据导入多个 mysql 表中。这个脚本在过去(我认为)一直运行良好，直到我写了第二个脚本，在这个脚本中我不小心截断了我的表(愚蠢，我知道)。 “没什么大不了的”我想，因为我有脚本，恢复我的数据只是几秒钟的事情。不幸的是，我发现现在只导入了一个文件，而且没有显示任何错误。下面我粘贴了脚本的整个数据库部分。当我执行这段代码时，我得到的只是输出 files imported successfully，这是最后一行代码...

我知道这是一个失败的大块代码，有很多字符串格式打印，这不会提高可读性，所以我还在下面提供了生成的查询字符串。据我所知，它们看起来格式正确，文件也是如此(我检查过)。谁能告诉我还应该在哪里寻找错误？这将是一个很大的帮助...谢谢!

<?php
$files = array_fill_keys(array('filename1','filename2','filename3','filename4'),'');
//$files === array of handles fputcsv($files['filename1'],array('values','from','other','files'),';');
$tbls = array_combine($files,array('tblname1','tblname2','tblname3','tblname4'));
$path = dirname(__FILE__)'/';
$qf = 'LOAD DATA LOCAL INFILE \'%s%s.csv\' INTO TABLE my_db.tbl_prefix_%s FIELDS TERMINATED BY \';\' OPTIONALLY ENCLOSED BY \'"\' LINES TERMINATED BY \'\n\'';
$pref = array_combine($files,array('fld1_','fld2_','fld3_','fld3_'));
$pkA = ' (`%1$sNAME`,`%1$sAGE';
$pk = '`,`%1$sUSER`,`%1$sTYPE`,`%1$sCODE`,`%1$sVALUE`,`%1$s';
try
{
    $db = new PDO('mysql:host=mysqlhostn','user','pass');
    foreach($files as $f)
    {
        $db->beginTransaction();
        $db->exec(sprintf('TRUNCATE TABLE my_db.tbl_prefix_%s',$tbls[$f]));
        $db->commit();
    }
}
catch(PDOException $e)
{
    if ($db)
    {
        $db->rollBack();
        $db = null;
    }
    die('DB connection/truncate failed: '.$e->getMessage()."\n");
}
try
{
    while($f = array_shift($files))
    {
        $db->beginTransaction();
        $q = sprintf($qf,$path,$f,$tbls[$f]).sprintf($pkA.($f !== 'agent' ? $pk : ''),$pref[$f]);
        switch($f)
        {
            case 'filename3':
                $q .= 'tbl3_specific_field';
            break;
            case 'filename2':
                $q .= sprintf('tbl2_specific_field`,`%1$tbl2_specific_field2',$pref[$f]);
            break;
            case 'filename4':
                $q .= sprintf('tbl4_specific_field`,`%1$tbl4_specific_field2`,`%1$tbl4_specific_field3`,`%1$tbl4_specific_field4',$pref[$f]);
            break;
        }
        $stmt = $db->prepare($q.'`)');
        $stmt->execute();
        $db->commit();
    }
}
catch(PDOException $e)
{
    $db->rollBack();
    $e = 'CSV import Failed: '.$e->getMessage();
    $db=null;
    die($e."\n");
}
$db = null;
exit('files imported successfully'."\n");
?>

生成的查询 - 执行输出:

TRUNCATE TABLE my_db.tbl_prefix_tblname1
TRUNCATE TABLE my_db.tbl_prefix_tblname2
TRUNCATE TABLE my_db.tbl_prefix_tblname3
TRUNCATE TABLE my_db.tbl_prefix_tblname4

LOAD DATA LOCAL INFILE '/local/path/to/files/filename1.csv' INTO TABLE my_db.tbl_prefix_tblname1 FIELDS TERMINATED BY ';' OPTIONALLY ENCLOSED BY '"' LINES TERMINATED BY '\n' (`fld1_NAME`,`fld1_AGE`)
LOAD DATA LOCAL INFILE '/local/path/to/files/filename2.csv' INTO TABLE my_db.tbl_prefix_tblname2 FIELDS TERMINATED BY ';' OPTIONALLY ENCLOSED BY '"' LINES TERMINATED BY '\n' (`fld2_NAME`,`fld2_AGE,`fld2_USER`,`fld2_TYPE`,`fld2_CODE`,`fld2_VALUE`,`fld2_tbl2_specific_field`,`fld2_tbl2_specific_field2`)
LOAD DATA LOCAL INFILE '/local/path/to/files/filename3.csv' INTO TABLE my_db.tbl_prefix_tblname3 FIELDS TERMINATED BY ';' OPTIONALLY ENCLOSED BY '"' LINES TERMINATED BY '\n' (`fld3_NAME`,`fld3_AGE,`fld3_USER`,`fld3_TYPE`,`fld3_CODE`,`fld3_VALUE`,`fld3_tbl3_specific_field`)
LOAD DATA LOCAL INFILE '/local/path/to/files/filename4.csv' INTO TABLE my_db.tbl_prefix_tblname4 FIELDS TERMINATED BY ';' OPTIONALLY ENCLOSED BY '"' LINES TERMINATED BY '\n' (`fld4_NAME`,`fld4_AGE,`fld4_USER`,`fld4_TYPE`,`fld4_CODE`,`fld4_VALUE`,`fld4_tbl4_specific_field`,`fld4_tbl4_specific_field2`,`fld4_tbl4_specific_field3`,`fld4_tbl4_specific_field4`)

csv imported successfully

File1 正在按照我的需要导入，第一个文件的示例:

11;9

虽然 file2 的实际内容(未导入)如下所示:

11;9;25;5;FOOBAR;Z;333;321;123

两个第一个字段包含相同的数据，因为它们应该包含相同的数据，两个表具有相同的字段定义，相同的存储引擎(InnoDB)，排序规则(UTF-8)......我不知道是什么导致了问题，所以任何建议将不胜感激。

最佳答案

why didn't the PDO object spew errors back at me for this?

因为 MySQL 没有任何错误地执行了您的查询。仅仅因为您编写了错误的查询，这并不意味着查询是错误的以至于 MySQL 不会接受它。

每当您以编程方式生成 SQL 查询时，请验证(通过调试或更好的单元测试)是否已针对您想要执行的操作正确创建查询。

如果你想在每次发生错误时都得到一个异常，启用:

$db->setAttribute(PDO::ATTR_ERRMODE, PDO::ERRMODE_EXCEPTION);

关于php - 将多个 csv 文件导入 mysql 表，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/10478861/