1 | <?php |
||
13 | class MysqlConnectionAdapter |
||
14 | { |
||
15 | |||
16 | const DRIVER_TYPE_PDO = 'pdo'; |
||
17 | const DRIVER_TYPE_MYSQLI = 'mysqli'; |
||
18 | |||
19 | /** |
||
20 | * |
||
21 | * @var string |
||
22 | */ |
||
23 | protected $driver; |
||
24 | |||
25 | /** |
||
26 | * |
||
27 | * @var \mysqli|null |
||
28 | */ |
||
29 | protected $mysqli; |
||
30 | |||
31 | /** |
||
32 | * |
||
33 | * @var \PDO|null |
||
34 | */ |
||
35 | protected $pdo; |
||
36 | |||
37 | /** |
||
38 | * |
||
39 | * @var string |
||
40 | */ |
||
41 | protected $type; |
||
42 | |||
43 | /** |
||
44 | * |
||
45 | * @throws Exception\InvalidArgumentException |
||
46 | * @param \mysqli|\PDO $conn |
||
47 | */ |
||
48 | 39 | public function __construct($conn) |
|
61 | |||
62 | /** |
||
63 | * Return current schema name |
||
64 | * @return string|false |
||
65 | */ |
||
66 | 25 | public function getCurrentSchema() |
|
75 | |||
76 | /** |
||
77 | * |
||
78 | * @param string $value |
||
79 | * @return string |
||
80 | */ |
||
81 | 10 | public function quoteValue($value) |
|
90 | |||
91 | /** |
||
92 | * Execute query and return query as an ArrayObject |
||
93 | * |
||
94 | * @param string $query |
||
95 | * @return ArrayObject |
||
96 | */ |
||
97 | 29 | public function query($query) |
|
106 | |||
107 | /** |
||
108 | * Execute special sql like set names... |
||
109 | * @param string $query |
||
110 | * @return void |
||
111 | */ |
||
112 | 14 | public function execute($query) |
|
120 | |||
121 | /** |
||
122 | * |
||
123 | * @param string $query |
||
124 | * @return void |
||
125 | */ |
||
126 | 10 | protected function executePDO($query) |
|
140 | |||
141 | |||
142 | /** |
||
143 | * |
||
144 | * @param string $query |
||
145 | * @return ArrayObject |
||
146 | */ |
||
147 | 25 | protected function queryPDO($query) |
|
166 | |||
167 | /** |
||
168 | * |
||
169 | * @param string $query |
||
170 | * @return ArrayObject |
||
171 | */ |
||
172 | 6 | protected function queryMysqli($query) |
|
197 | } |
||
198 |