CakePHP 3原始SQL查詢

Question

我正在使用CakePHP 3，我需要在多個表上運行原始SQL查詢。在CakePHP 2中，這可以通過在任何模型上使用query（）方法來完成（$this->Messages->query("select..")）。

我需要讓我來運行的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模型文檔在那裏我可以找到這個信息，這也會有幫助。我試圖尋找對谷歌，但只能找到你需要添加的ConnectionManager有關CakePHP的2

Answer 1

第一個問題：

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

然後你就可以獲取這樣的行（S）：

// 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

但是沒有寫的是如何執行它。因爲它花了我一會，這裏是該解決方案：

1.You需要添加

use Cake\Datasource\ConnectionManager; 

2.init的的ConnectionManager（如上所述）

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

3。像這樣執行你的SQL

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