php - 如何设置 PDO::MYSQL_ATTR_USE_BUFFERED_QUERY

Question

我正在使用 CakePHP3.2.3 编写一个平台。我需要在特定服务器上创建一个数据库和近 100 个表。我为每个表创建了一个sql文件，并通过读取sql文件并在其中执行sql在远程服务器上创建表。但是我从 CakePHP DebugKit 得到了一些错误。如下所示

Documentation API
Error: SQLSTATE[HY000]: General error: 2014 Cannot execute queries     
while other unbuffered queries are active. Consider using PDOStatement::fetchAll(). 
Alternatively, if your code is only ever going to run against mysql, you may 
enable query buffering by setting the 
PDO::MYSQL_ATTR_USE_BUFFERED_QUERY attribute.

我认为 fetchAll 不适合我。但我不知道如何通过 CakePHP 的连接启用查询缓冲。请告诉我怎么做。

Answer 1

我从 CakePHP 的源代码中得到了答案。我们可以调用 prepare 函数，然后执行 sql 来启用缓冲区。

    $path = ROOT . DS . APP_DIR . DS . 'config' . DS . 'sql';
    $dir = new Folder($path);
    $files = $dir->read(true);
    $files = $files[1];
    foreach ($files as $file) {
        $file = new File($dir->pwd() . DS . $file);
        $sql = str_replace('%s', $tablePrefix, $file->read());

        $buffer = $connection->prepare($sql);
        $buffer->execute();
    }