14

我正在使用 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 相关的问题。

4

3 回答 3

28

首先，您需要添加 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

于 2014-10-11T22:13:48.093 回答
13

这方面的文档在这里：http ://book.cakephp.org/3.0/en/orm/database-basics.html#executing-queries

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

1.您需要添加

use Cake\Datasource\ConnectionManager;

2.init ConnectionManager（如上所述）

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

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

$firstName = $conn->execute('SELECT firstname FROM users WHERE id = 1');
于 2015-06-02T15:20:32.517 回答
1

这个问题已经很老了，但我仍然经常发现它。这是 CAKEPHP 3.6 和（简称）较新 PHP 版本的解决方案。

没有必要使用 ConnectionManager 的 get 函数，而且它通常没有意义，因为可能根本不知道连接名称。每个表都有它的 / 一个可以通过 getConnection() 获得的连接。

如果您已经在 Messages Table ( src/Model/Table/MessagesTable.php) 中，您可以简单地使用 Connection

$con = $this->Messages->getConnection();

如果您不在那里（您的代码建议使用TableRegistry::get()，您也可以使用此表执行此操作

// $aumTable is declared in question
$con = $aumTable->getConnection();

然后您可以执行 RAW 查询，如上所示：

$result = $con->execute ();
// short 
$result = $this->Messages->getConnection()->execute ('Select * from ...')
// or ($aumTable is declared in question)
$result = $aumTable->getConnection()->execute ('Select * from ...');
于 2018-12-05T10:52:44.333 回答