Начало работы с FluentPDO

Вы знаете историю: написание SQL-запросов так скучно. Особенно, когда у тебя нет времени на это. Если вы чувствуете себя как я, сегодня мы увидим что-то действительно классное: Свободный PDO . Если термин «PDO» звучит для вас новым, не волнуйтесь. Это действительно простая концепция: в мире PHP PDO расшифровывается как Persistent Data Object и помогает вам абстрагироваться от некоторых основных операций, связанных с базой данных (таких как вставка, обновление, удаление и т. Д.). Это слой между вами и базой данных.

Результат? Нет больше запросов SQL. Может быть, это не первый, который вы видели: есть много подобных проектов, и у каждого есть свои ключевые особенности. Основной особенностью Fluent является отличный JOIN Query Builder.

Наш тестовый проект FluentPDO

Прежде всего, нам понадобится пример проекта для работы. Давайте подумаем … а как насчет простого многопользовательского списка пожеланий?

Будет много пользователей, и у каждого будут свои любимые продукты. Для каждого пользователя мы будем хранить имя, фамилию и дату регистрации. Для каждого элемента мы будем хранить название, марку, цену и идентификатор соответствующего пользователя.

Я собираюсь использовать простую базу данных MySQL. Вот структура наших данных:

… И вот дамп SQL (с некоторыми фиктивными данными).

CREATE TABLE IF NOT EXISTS items ( id int(11) NOT NULL AUTO_INCREMENT, name varchar(100) NOT NULL, brand varchar(100) NOT NULL, price decimal(10,2) NOT NULL, user_id int(10) unsigned NOT NULL, PRIMARY KEY (id), KEY user_id (user_id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=5 ; INSERT INTO items (id, name, brand, price, user_id) VALUES (1, 'Last Awesome Phone', 'Awesome Brand', '550.00', 1), (2, 'Last Awesome TV', 'Awesome Brand', '1200.00', 1), (3, 'Fantastic E-Car', 'E-Cars Inc.', '80000.00', 2), (4, 'Fantastic E-Bike', 'E-Bikes Co. Ltd.', '16000.00', 2); CREATE TABLE IF NOT EXISTS users ( id int(10) unsigned NOT NULL AUTO_INCREMENT, first_name varchar(100) NOT NULL, last_name varchar(100) NOT NULL, signup_date datetime NOT NULL, PRIMARY KEY (id) ) ENGINE=InnoDB DEFAULT CHARSET=utf8 AUTO_INCREMENT=3; INSERT INTO users (id, first_name, last_name, signup_date) VALUES (1, 'Francesco', 'Malatesta', '2014-06-29 13:00:00'), (2, 'John', 'Foo Bar', '2014-06-20 11:16:39'); ALTER TABLE items ADD CONSTRAINT items_ibfk_1 FOREIGN KEY (user_id) REFERENCES users (id); 

Примечание. Как вы можете легко представить, это не будет «завершенный» проект. Мы просто пробуем FluentPDO, поэтому мы не собираемся охватывать такие вещи, как вход в систему, регистрация или структура приложения.

Установка

Вы устанавливаете Fluent с Composer, включая библиотеку как зависимость:

 "require": { ... "lichtner/fluentpdo": "dev-master" } 

После того, как вы сделали, вам нужно создать экземпляр как это:

 $pdo = new PDO("mysql:dbname=wishlist", "root", "password"); $fpdo = new FluentPDO($pdo); 

Вам нужно будет указать детали вашего соединения в методе конструктора PDO. Введите имя вашей базы данных после dbname= piece в первом параметре, затем введите имя пользователя и пароль в качестве второго и третьего аргументов.

Затем вы передадите объект PDO в качестве параметра для конструктора объекта FluentPDO.

Вот и все, FluentPDO больше ничего не нужно для работы. Никаких дополнительных настроек.

Основные операции выбора

У нас уже есть некоторые фиктивные данные. Давайте начнем с «Hello World» SQL-запросов. Простой выбор с использованием где и id первичного ключа пользователя в качестве параметра для получения основной информации.

 $user_id = 1; $query = $fpdo->from('users')->where('id', $user_id); foreach($query as $row){ echo 'Hello, ' . $row['first_name'] . ' ' . $row['last_name'] . '!'; } 

 $fpdo->from('items')->where('price >', 1000); 

 $query = fpdo->from('users', $user_id); // will be the same thing as... $query = $fpdo->from('users')->where('id', $user_id); 

 $query = $fpdo->from('users')->select(array('first_name', 'last_name'))->where('id', $user_id); 

 // selecting the first ten results... $query = $fpdo->from('users')->where('id', $user_id)->limit(10)->offset(0); 

 $query = $fpdo->from('items')->orderBy('price'); 

 $query = $fpdo->from('items')->orderBy('price DESC'); 

 $query = $fpdo->from('items')->having('price < 2000'); 

 $query = $fpdo->from('items')->select('brand, COUNT(*) AS c')->groupBy('brand'); 

 $query = $fpdo->from('users'); $row = $query->fetch(); var_dump($row); // will output: // array(4) { ["id"]=> string(1) "1" ["first_name"]=> string(9) "Francesco" ["last_name"]=> string(9) "Malatesta" ["signup_date"]=> string(19) "2014-06-29 13:00:00" } 

 $query = $fpdo->from('users'); $firstName = $query->fetch('first_name'); var_dump($firstName); // will output: // string(9) "Francesco" 

 fetchPairs($column1, $column2); 

 // [column1_value] => "column2_value" 

 $query = $fpdo->from('users'); $row = $query->fetchPairs('id', 'first_name'); var_dump($row); // will output: // array(2) { [1]=> string(9) "Francesco" [2]=> string(4) "John" } 

 fetchAll($index = '', $selectOnly = '') 

 $query = $fpdo->from('users'); $row = $query->fetchAll('id', 'first_name, last_name'); var_dump($row); // will output: // array(2) { [1]=> array(3) { ["id"]=> string(1) "1" ["first_name"]=> string(9) "Francesco" ["last_name"]=> string(9) "Malatesta" } [2]=> array(3) { ["id"]=> string(1) "2" ["first_name"]=> string(4) "John" ["last_name"]=> string(7) "Foo Bar" } } 

 $values = array('first_name' => 'Joe', 'last_name' => 'Doe', 'signup_date' => '2014-06-30 11:00:00'); $query = $fpdo->insertInto('users')->values(values); $insert = $query->execute(); var_dump($insert); // will output: // string(1) "3" 

 $query = $fpdo->insertInto('users', $values); 

 $set = array('last_name' => 'Foo Foo Bar'); $query = $fpdo->update('users')->set($set)->where('id', 2); // you can also use this shortcut: $query = $fpdo->update('users', $set, 1); $query->execute(); 

 $query = $fpdo->deleteFrom('users')->where('id', 3); // ... or you can use this: $query = $fpdo->deleteFrom('users', 3); $query->execute(); 

 $query = $fpdo->from('items')->leftJoin('user ON user.id = items.user_id')->select('user.first_name'); 

 $query = $fpdo->from('article')->leftJoin('user')->select('user.name'); 

 $query = $fpdo->from('items')->select('users.first_name'); 

 SELECT items.*, users.first_name FROM items LEFT JOIN users ON users.id = items.user_id 

 $query = $fpdo->from('items')->select('users.first_name AS user_first_name'); 

 $fpdo->debug = function($BaseQuery) { echo "query: " . $BaseQuery->getQuery(false) . "<br/>"; echo "parameters: " . implode(', ', $BaseQuery->getParameters()) . "<br/>"; echo "rowCount: " . $BaseQuery->getResult()->rowCount() . "<br/>"; };