CakePHP 3 Необработанный SQL-запрос

Я использую CakePHP 3, мне нужно запустить необработанный SQL-запрос на нескольких таблицах. В CakePHP 2 это можно сделать, используя метод query () для любой модели ( $this->Messages->query("select..") ).

Мне нужен метод, который позволяет мне запускать SQL-запрос в CakePHP 3. Ниже приведен фрагмент кода, который я использую:

 $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, где я могу найти эту информацию, это тоже будет полезно. Я пробовал искать в google, но мог найти только вопросы, связанные с CakePHP 2.

Solutions Collecting From Web of "CakePHP 3 Необработанный SQL-запрос"

Сначала вам нужно добавить ConnectionManager:

 use Cake\Datasource\ConnectionManager; 

Затем вам нужно подключиться так:

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

Дополнительная информация: http://book.cakephp.org/3.0/ru/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/ru/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/ru/orm/database-basics.html#executing-fetching-rows

Документация для этого находится здесь: http://book.cakephp.org/3.0/ru/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');