如何在 Propel 中启用 LOAD DATA LOCAL INFILE？

Question

我已经尝试了其他答案的解决方案，但到目前为止都没有解决：

PDOException 42000 SQLSTATE[42000]: Syntax error or access violation: 
1148 The used command is not allowed with this MySQL version

我正在使用PropelPDO 准备查询。我试过了：

$cnct = \Propel::getConnection();
$cnct->setAttribute(\PDO::MYSQL_ATTR_LOCAL_INFILE, true);

但这并没有阻止错误，所以我也尝试了：

$prepare = $cnct->prepare($sql, array(
    \PDO::MYSQL_ATTR_LOCAL_INFILE => true,
));
$prepare->execute();

最后，我在 Propel 的 runtime-conf.xml 中设置：

<options>
    <option id="MYSQL_ATTR_LOCAL_INFILE">true</option>
</options>

我也尝试将其定义为属性：

<attributes>
    <option id="MYSQL_ATTR_LOCAL_INFILE">true</option>
</attributes>

这是尝试使用此命令的代码块：

foreach ($files as $filename => $file) {
    error_log('[' . date('Y-m-d h:i:s') . '] Importing ' . $filename . '... ');
    $sql = <<<SQL
LOAD DATA LOCAL INFILE '$filename' REPLACE 
INTO TABLE `my_table`  
FIELDS TERMINATED BY ',' OPTIONALLY ENCLOSED BY '\"' 
LINES TERMINATED BY '\n' 
(...);
SQL;
    error_log($sql);
    $prepare = $cnct->prepare($sql, array(
        \PDO::MYSQL_ATTR_LOCAL_INFILE => true,
    ));
    $prepare->execute();
}

$files 是通过从 Amazon S3 下载文件而创建的临时 PHP 文件列表。文件名如下所示：/tmp/php7U5bgd

我无权访问 my.cnf。相同的数据库和用户允许LOAD DATA LOCAL INFILE 在Java 中运行。我还使用了 MySQL CLI，它允许我运行这个命令。

这可以防止 PDOException 被抛出，但它不会将任何数据保存到我的数据库中：\

$conf = include 'runtime-conf.php';
$cnct = new \PDO(
    $conf['datasources']['my_database']['connection']['dsn'], 
    $conf['datasources']['my_database']['connection']['user'], 
    $conf['datasources']['my_database']['connection']['password'], 
    array(
        \PDO::MYSQL_ATTR_LOCAL_INFILE => true,
    )
);

最有帮助的相关问题：

1. LOAD DATA LOCAL INFILE forbidden in... PHP
2. MySQL: Enable LOAD DATA LOCAL INFILE

Answer 1

将PDO::MYSQL_ATTR_LOCAL_INFILE 属性设置为true 的唯一有效位置是在构造新的Connection 句柄时。您尝试在构造句柄后设置它：getConnection() 方法只是从 Propel 运行时检索句柄。

Propel 似乎在幕后构造了那个把手。

在不更改 Propel 源代码的情况下，最好的办法是直接使用 PDO 创建自己的连接句柄，然后执行 LOAD DATA INFILE，然后关闭该句柄。换句话说，围绕 Propel 进行这种批量加载操作。

Answer 2

这是唯一对我有用的解决方案：

$conf = include 'runtime-conf.php';

$dsn = $conf['datasources']['adstudio']['connection']['dsn'];
$user = $conf['datasources']['adstudio']['connection']['user'];
$password = $conf['datasources']['adstudio']['connection']['password'];

$hoststart = strpos($dsn, 'host=') + 5;
$hostend = strpos($dsn, ';', $hoststart);
$hostname = substr($dsn, $hoststart, $hostend - $hoststart);

$portstart = strpos($dsn, 'port=') + 5;
$portend = strpos($dsn, ';', $portstart);
$port = substr($dsn, $portstart, $portend - $portstart);

exec('mysql -h ' . $hostname . ' -P ' . $port . ' -u ' . $user . ' ' .
    '-p' . $password . ' --local-infile=1 ' .
    '-e "USE my_database;LOAD DATA LOCAL INFILE \'' . $tmp . '\' REPLACE INTO TABLE my_table FIELDS TERMINATED BY \',\' OPTIONALLY ENCLOSED BY \'\\"\' LINES TERMINATED BY \'\n\' (...);"');

基于this answer。