CakePHP 3原始SQL查询

Question

我正在使用CakePHP 3,我需要在多个表上运行原始SQL查询.在CakePHP 2中,可以通过在任何模型($this->Messages->query("select.."))上使用query()方法来完成.

我需要允许我在CakePHP 3中运行SQL查询的方法.以下是我正在使用的代码片段:

$aumTable = TableRegistry::get('Messages');
$sql = "SELECT (SELECT COUNT(*) FROM `messages`) AS `Total_Count`,
        (SELECT COUNT(*) FROM `messages_output`) AS `Total_Output_Count`,
        (SELECT COUNT(*) FROM `messages_output` WHERE `is_success`=1) AS `Total_Successful_Output_Count`,
        (SELECT COUNT(*) FROM `messages_output` WHERE `is_success`=0) AS `Total_Error_Output_Count`,
        (SELECT COUNT(*) FROM `users`) AS `Total_User_Count`;";

// to run this raw SQL query what method should i use? query() doesn't work..
// $result = $aumTable->query($sql); ??
// $result = $aumTable->sql($sql); ??

如果您可以提供CakePHP 3模型文档的链接,我可以在其中找到此信息,这也会有所帮助.我尝试在谷歌上搜索,但只能找到与CakePHP 2相关的问题.

Answer 1

首先,您需要添加ConnectionManager:

use Cake\Datasource\ConnectionManager;

然后你需要像这样得到你的连接:

// my_connection is defined in your database config
$conn = ConnectionManager::get('my_connection');

更多信息:http://book.cakephp.org/3.0/en/orm/database-basics.html#creating-connections-at-runtime

之后,您可以运行如下自定义查询:

$stmt = $conn->execute('UPDATE posts SET published = ? WHERE id = ?', [1, 2]);

更多信息:http://book.cakephp.org/3.0/en/orm/database-basics.html#executing-queries

然后你准备好像这样获取行:

// Read one row.
$row = $stmt->fetch('assoc');

// Read all rows.
$rows = $stmt->fetchAll('assoc');

// Read rows through iteration.
foreach ($rows as $row) {
    // Do work
}

更多信息:http://book.cakephp.org/3.0/en/orm/database-basics.html#executing-fetching-rows

Answer 2

相关文档如下:http://book.cakephp.org/3.0/en/orm/database-basics.html#executing-queries

但是那里没有写的是如何执行它.因为它花了我一段时间,这里是解决方案:

你需要补充一下

use Cake\Datasource\ConnectionManager;

2.init ConnectionManager(如上所述)

$conn = ConnectionManager::get('my_connection');

3.用这样的东西执行你的SQL

$firstName = $conn->execute('SELECT firstname FROM users WHERE id = 1');