Обновил репозиторий. Как и обещал, показываю свою обёртку для PDO. (привет с Java) https://github.com/ebalazhabagadyuku/dbc
Пример настройки (надеюсь понятно):

Открыть спойлер

Закрыть спойлер

[копировать] [скачать]

1. $app = new App(function($c) {
2.     $c['_dbcUrl']   =   'mysql://root:@localhost/lol';
3.     $c->register(new \framework\providers\DbcServiceProvider());
4. });

Открыть спойлер

Закрыть спойлер

[копировать] [скачать]

1. //  register mysql driver
2.         DriverManager::register('mysql', \framework\dbc\Driver\MysqlDriver::class);
3.         $app['dbc'] =   $app->singleton(
4.             function($c) {
5.                 return DriverManager::getConnection($c['_dbcUrl']);
6.             });
7.         //$app['dbc']->getPdo()->setAttribute(\PDO::ATTR_DEFAULT_FETCH_MODE, \PDO::FETCH_ASSOC);
8.         $app['dbc']->getPdo()->setAttribute(\PDO::ATTR_CURSOR, \PDO::CURSOR_SCROLL);
9.         $app['dbc']->executeQuery('SET NAMES utf8;');

Пример использования (внутри моего приложения):

Открыть спойлер

Закрыть спойлер

[копировать] [скачать]

1. /** @var string */
2.         $token  =   $this->request->cookies()->get('user');
3.         if (null !== $token) {
4.  
5.             /** @var \framework\dbc\ResultSet */
6.             $rs =   $this->app['dbc']->executeQuery('SELECT u.* FROM sessions s
7.                 LEFT JOIN users u ON u.id=s.user_id WHERE s.token=?;', [
8.                 _e((string)$token)
9.             ]);
10.  
11.             if (0 != $rs->getCount()) {
12.  
13.                 $user       =   [
14.                     'id'    =>  $rs->getInt('id'),
15.                     'login' =>  $rs->getString('login'),
16.                     'password'  =>  $rs->getString('password')
17.                 ];
18.                 $this->user =   $user;
19.  
20.                 if ( ! $rs->isNull('block') ) {
21.                     $this->response->setCookie(new Cookie('user', null, 0));
22.                     $this->redirect('/user/signIn');
23.                 }
24.  
25.                 $this->app['dbc']->executeQuery('UPDATE users
26.                     SET last_updated_at=UNIX_TIMESTAMP() WHERE id=?;', [
27.                     $user['id']
28.                 ]);
29.  
30.                 $this->assign('user', $user);
31.  
32.             }
33.  
34.         }

Спасибо за внимание!

Были мысли по поводу того, чтобы создать отдельные скалярные типы.

GreeNLine, это же самая примитивная обёртка. Берём объект PDO, оборачиваем его, затем берём ResultSet, оборачиваем и его. При этом навешиваем в оба класса пару методов для удобства и всё.
Такое каждый велосипедист писал и пишет, что уникального-то?

Цитата GreeNLine:

---

Я всегда был одного мнения о буилдере - бред Билдеры запросов упрощают работу с SQL. Одно дело тупо писать голый запрос, а другое - при написании запроса использовать всю мощь IDE и языка, т.е. автодополнение, подсветка, соответствие названий полей и их типов (если речь о некотором подобии ORM).

Цитата Дневник_Володи:

---

GreeNLine, это же самая примитивная обёртка. Берём объект PDO, оборачиваем его, затем берём ResultSet, оборачиваем и его. При этом навешиваем в оба класса пару методов для удобства и всё.
Такое каждыТвоя правда.

GreeNLine, сам PDO удобный, вот Mysqli кривой, особенно при работе с plaseholders

aRiGaTo, вот и я про то же

Koenig, idiORM смотрел? Нравилась мне эта штука. Может почерпнёшь что.
Там поверх idiORM потом Active Record реализацию сделали http://j4mie.github.io/idiormandparis/

Цитата Дневник_Володи:

---

Koenig, idiORM смотрел? Нравилась мне эта штука. Может почерпнёшь что.
Там поверх idiORM потом Active Record реализацию сделали http://j4mie.github.io/idiorхм) интересная вещь)

Дневник_Володи, конечно смотрел, еще во времена mysqli, но она уже старенькая

Написал небольшую конструкцию. Простенько конечно, извиняюсь.
// Модель

Открыть спойлер

Закрыть спойлер

[копировать] [скачать]

1. <?php
2.  
3. namespace framework;
4. use framework\db\builder;
5.  
6. /**
7.  *  @author 3kZO
8.  */
9. class Model
10. {
11.  
12.     /** @var \framework\db\Connection */
13.     protected $db;
14.     /** @var string */
15.     protected $table;
16.     /** @var string */
17.     protected $persistenceClass;
18.     /** @var \framework\db\Builder */
19.     private $builder;
20.  
21.     public function __construct() {
22.         /** @var \framework\Container */
23.         $container = Framework::app()->getContainer();
24.         $this->db = $container['db'];
25.     }
26.  
27.     public function getBuilder() {
28.         if (null === $this->builder) {
29.             $this->builder = new Builder($this->db);
30.             $this->builder->persist($this->persistenceClass);
31.             $this->builder->from([
32.                 $this->table
33.             ]);
34.         }
35.         return $this->builder;
36.     }
37.  
38.     public function find() {
39.         return $this->getBuider()
40.                     ->select([
41.                         $this->table . '.*'
42.                     ]);
43.     }
44.  
45.     public function findBy($expr, array $args = []) {
46.         return $this->find()
47.                         ->where()
48.                             ->expr($expr, $args)
49.                         ->find();
50.     }
51.  
52.     public function findById($id) {
53.         return $this->findBy($this->table . '.id = ?', [
54.             (int)$id
55.         ]);
56.     }
57.  
58.     public function update($id, array $values = []) {
59.         $expr   =   [];
60.         $bindArgs   =   [];
61.         foreach($values as $column => $value) {
62.             $expr[] =   $column . ' = ?';
63.             $bindArgs[] =   $value;
64.         }
65.         return $this->getBuilder()
66.                     ->expr(implode(', ', $expr), $bindArgs)
67.                     ->where()
68.                         ->expr('id = ?', [
69.                             (int)$id
70.                         ])
71.                 ->update();
72.     }
73.  
74.     public function delete($id) {
75.         return $this->getBuider()
76.                         ->where()
77.                             ->expr('id = ?', [
78.                                 (int)$id
79.                             ])
80.                         ->delete();
81.     }
82.  
83. }

// Буилдер

Открыть спойлер

Закрыть спойлер

[копировать] [скачать]

1. <?php
2.  
3. namespace framework\db;
4. use framework\db\Connection;
5.  
6. /**
7.  *  @author 3kZO
8.  */
9. class Builder
10. {
11.  
12.     /** @var \framework\db\Connection */
13.     private $db;
14.     /** @var string[] */
15.     private $from;
16.     /** @var string[] */
17.     private $columns;
18.     /** @var string[] */
19.     private $bindArgs = [];
20.     /** @var string[] */
21.     private $breadcrumbs = [];
22.     /** @var string */
23.     private $persistenceClass;
24.  
25.     public function __construct(
26.         Connection $db
27.     ) {
28.         $this->db   =   $db;
29.     }
30.  
31.     public function persist($class) {
32.         $this->persistenceClass =   (string)$class;
33.         return $this;
34.     }
35.  
36.     public function select(array $columns) {
37.         $this->columns  =   [];
38.         foreach($columns as $column)
39.             $this->columns[]    =   (string)$column;
40.         return $this;
41.     }
42.  
43.     public function from(array $tables) {
44.         $this->from =   [];
45.         foreach($tables as $table)
46.             $this->from[]   =   (string)$table;
47.         return $this;
48.     }
49.  
50.     public function leftJoin(...$args) {
51.         $this->breadcrumbs[]    =   'LEFT JOIN ' . (string)$args[0] . ' ON';
52.         return $this;
53.     }
54.  
55.     public function where() {
56.         $this->breadcrumbs[]    =   'WHERE';
57.         return $this;
58.     }
59.  
60.     public function expr(...$args) {
61.         $this->breadcrumbs[]    =   (string)$args[0];
62.         if (isset($args[1]))
63.             foreach($args[1] as $value)
64.                 $this->bindArgs[]   =   (string)$value;
65.         return $this;
66.     }
67.  
68.     public function having() {
69.         $this->breadcrumbs[]    =   'HAVING';
70.         return $this;
71.     }
72.  
73.     public function orderBy($string) {
74.         $this->breadcrumbs[]    =   'ORDER BY ' . (string)$string;
75.         return $this;
76.     }
77.     public function groupBy($string) {
78.         $this->breadcrumbs[]    =   'GROUP BY ' . (string)$string;
79.         return $this;
80.     }
81.  
82.     public function limit($offset, $maxRows = false) {
83.         $this->breadcrumbs[]    =   'LIMIT '
84.             . ($maxRows
85.                     ? $offset . ', ' . $maxRows
86.                     : $offset);
87.         return $this;
88.     }
89.  
90.     public function getGeneratedSql() {
91.         $sql    =   [];
92.         $sql[]  =   implode(' ', $this->breadcrumbs);
93.         return implode(' ', $sql) . ';';
94.     }
95.  
96.     public function find() {
97.         $sql    =   [];
98.         $sql[]  =   'SELECT ' . implode(', ', $this->columns) . ' FROM ' . implode(', ', $this->from);
99.         $sql[]  =   $this->getGeneratedSql();
100.         $rs = $this->db->executeQuery(implode(' ', $sql), $this->bindArgs);
101.         if (0 == $rs->getRowCount())
102.             return;
103.         $rs->first();
104.         $persistenceClass = $this->persistenceClass;
105.         $persistence = new $persistenceClass();
106.         foreach($persistence->keys() as $key)
107.             $persistence->__data[$key] = $rs->get($key);
108.         return $persistence;
109.     }
110.  
111.     public function findAll() {
112.         $sql    =   [];
113.         $sql[]  =   'SELECT ' . implode(', ', $this->columns) . ' FROM ' . implode(', ', $this->from);
114.         $sql[]  =   $this->getGeneratedSql();
115.         $rs = $this->db->executeQuery(implode(' ', $sql), $this->bindArgs);
116.         if (0 == $rs->getRowCount())
117.             return;
118.         $list = [];
119.         while($rs->next()) {
120.             $persistenceClass = $this->persistenceClass;
121.             $persistence = new $persistenceClass();
122.             foreach($persistence->keys() as $key)
123.                 $persistence->__data[$key] = $rs->get($key);
124.             $list[] =   $persistence;
125.         }
126.         return $list;
127.     }
128.  
129.     public function update() {
130.         $sql    =   [];
131.         $sql[]  =   'UPDATE ' . implode(', ', $this->from) . ' SET';
132.         $sql[]  =   $this->getGeneratedSql();
133.         $rs = $this->db->executeQuery(implode(' ', $sql), $this->bindArgs);
134.         return $rs->getRowCount();
135.     }
136.  
137.     public function delete() {
138.         $sql    =   [];
139.         $sql[]  =   'DELETE FROM ' . implode(', ', $this->from);
140.         $sql[]  =   $this->getGeneratedSql();
141.         $rs = $this->db->executeQuery(implode(' ', $sql), $this->bindArgs);
142.         return $rs->getRowCount();
143.     }
144.  
145. }

// Сущность

Открыть спойлер

Закрыть спойлер

[копировать] [скачать]

1. <?php
2.  
3. namespace framework\db;
4.  
5. /**
6.  *  @author 3kZO
7.  */
8. class Entity
9. {
10.  
11.     public $__data;
12.  
13.     public function keys() {
14.         return array_keys($this->__data);
15.     }
16.  
17.     public function __get($key) {
18.         return array_key_exists($key, $this->__data) ? $this->__data[$key] : null;
19.     }
20.  
21.     public function __set($key, $val) {
22.         if (array_key_exists($key, $this->__data))
23.             $this->__data[$key] = $val;
24.     }
25.  
26. }

// Пример сущности

Открыть спойлер

Закрыть спойлер

[копировать] [скачать]

1. <?php
2.  
3. namespace entities;
4. use framework\db\Entity;
5.  
6. /**
7.  *  @author 3kZO
8.  */
9. class User extends Entity
10. {
11.     public $__data = [
12.         'id'        =>  null,
13.         'login'     =>  null,
14.         'password'  =>  null,
15.     ];
16. }

// Пример модели

Открыть спойлер

Закрыть спойлер

[копировать] [скачать]

1. <?php
2.  
3. namespace models;
4. use framework\Model;
5.  
6. /**
7.  *  @author 3kZO
8.  */
9. class User extends Model
10. {
11.  
12.     protected $table    =   'users';
13.     protected $persistenceClass = \entities\User::class;
14.  
15. }

Пытался повторить java ebean на php.