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.

Author: Bahrom, 2014-10-11
Source

2 answers

Сначала вам нужно добавить 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

 24
Author: Tijme, 2016-12-13 18:49:42

Документация для этого находится здесь: http://book.cakephp.org/3.0/en/orm/database-basics.html#executing-queries

Но чего там не написано, так это как это выполнить. Поскольку это стоило мне некоторого времени, вот решение для этого:

1. Вам нужно добавить 

use Cake\Datasource\ConnectionManager;

2. запустите ConnectionManager (как упоминалось выше)

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

3. Выполните свой SQL с помощью чего-то вроде этого

$firstName = $conn->execute('SELECT firstname FROM users WHERE id = 1');
 9
Author: Tobias Gaertner, 2016-10-27 20:30:01