PdoWrapper Класс помощника PDO
Flight поставляется с классом помощника для PDO. Он позволяет легко выполнять запросы к базе данных с использованием всех этих заморочек с подготовкой/выполнением/fetchAll(). Это значительно упрощает ваш способ выполнения запросов к базе данных. Каждая строка результата возвращается как класс Flight Collection, который позволяет вам получать доступ к данным с использованием синтаксиса массива или объекта.
Регистрация класса помощника PDO
// Регистрация класса помощника PDO
Flight::register('db', \flight\database\PdoWrapper::class, ['mysql:host=localhost;dbname=cool_db_name', 'user', 'pass', [
PDO::MYSQL_ATTR_INIT_COMMAND => 'SET NAMES \'utf8mb4\'',
PDO::ATTR_EMULATE_PREPARES => false,
PDO::ATTR_STRINGIFY_FETCHES => false,
PDO::ATTR_DEFAULT_FETCH_MODE => PDO::FETCH_ASSOC
]
]);
Применение
Этот объект расширяет PDO, поэтому все обычные методы PDO доступны. Для упрощения выполнения запросов к базе данных были добавлены следующие методы:
runQuery(string $sql, array $params = []): PDOStatement
Используйте это для INSERTS, UPDATES или если вы планируете использовать SELECT в цикле while
$db = Flight::db();
$statement = $db->runQuery("SELECT * FROM table WHERE something = ?", [ $something ]);
while($row = $statement->fetch()) {
// ...
}
// Или запись в базу данных
$db->runQuery("INSERT INTO table (name) VALUES (?)", [ $name ]);
$db->runQuery("UPDATE table SET name = ? WHERE id = ?", [ $name, $id ]);
fetchField(string $sql, array $params = []): mixed
Извлекает первое поле из запроса
$db = Flight::db();
$count = $db->fetchField("SELECT COUNT(*) FROM table WHERE something = ?", [ $something ]);
fetchRow(string $sql, array $params = []): array
Извлекает одну строку из запроса
$db = Flight::db();
$row = $db->fetchRow("SELECT id, name FROM table WHERE id = ?", [ $id ]);
echo $row['name'];
// или
echo $row->name;
fetchAll(string $sql, array $params = []): array
Извлекает все строки из запроса
$db = Flight::db();
$rows = $db->fetchAll("SELECT id, name FROM table WHERE something = ?", [ $something ]);
foreach($rows as $row) {
echo $row['name'];
// или
echo $row->name;
}
Примечание к синтаксису IN()
Здесь также есть удобная оболочка для оператора IN()
. Просто передайте один вопросительный знак в качестве заполнителя для IN()
, а затем массив значений. Вот пример того, как это может выглядеть:
$db = Flight::db();
$name = 'Bob';
$company_ids = [1,2,3,4,5];
$rows = $db->fetchAll("SELECT id, name FROM table WHERE name = ? AND company_id IN (?)", [ $name, $company_ids ]);
Полный пример
// Пример маршрута и как использовать эту оболочку
Flight::route('/users', function () {
// Получить всех пользователей
$users = Flight::db()->fetchAll('SELECT * FROM users');
// Отправить всех пользователей
$statement = Flight::db()->runQuery('SELECT * FROM users');
while ($user = $statement->fetch()) {
echo $user['name'];
// или echo $user->name;
}
// Получить одного пользователя
$user = Flight::db()->fetchRow('SELECT * FROM users WHERE id = ?', [123]);
// Получить одно значение
$count = Flight::db()->fetchField('SELECT COUNT(*) FROM users');
// Особый синтаксис IN() для помощи (убедитесь, что IN написано заглавными буквами)
$users = Flight::db()->fetchAll('SELECT * FROM users WHERE id IN (?)', [[1,2,3,4,5]]);
// вы также можете сделать так
$users = Flight::db()->fetchAll('SELECT * FROM users WHERE id IN (?)', [ '1,2,3,4,5']);
// Вставить нового пользователя
Flight::db()->runQuery("INSERT INTO users (name, email) VALUES (?, ?)", ['Bob', 'bob@example.com']);
$insert_id = Flight::db()->lastInsertId();
// Обновить пользователя
Flight::db()->runQuery("UPDATE users SET name = ? WHERE id = ?", ['Bob', 123]);
// Удалить пользователя
Flight::db()->runQuery("DELETE FROM users WHERE id = ?", [123]);
// Получить количество затронутых строк
$statement = Flight::db()->runQuery("UPDATE users SET name = ? WHERE name = ?", ['Bob', 'Sally']);
$affected_rows = $statement->rowCount();
});