1
|
|
|
<?php |
2
|
|
|
/** |
3
|
|
|
* Phinx |
4
|
|
|
* |
5
|
|
|
* (The MIT license) |
6
|
|
|
* Copyright (c) 2015 Rob Morgan |
7
|
|
|
* |
8
|
|
|
* Permission is hereby granted, free of charge, to any person obtaining a copy |
9
|
|
|
* of this software and associated * documentation files (the "Software"), to |
10
|
|
|
* deal in the Software without restriction, including without limitation the |
11
|
|
|
* rights to use, copy, modify, merge, publish, distribute, sublicense, and/or |
12
|
|
|
* sell copies of the Software, and to permit persons to whom the Software is |
13
|
|
|
* furnished to do so, subject to the following conditions: |
14
|
|
|
* |
15
|
|
|
* The above copyright notice and this permission notice shall be included in |
16
|
|
|
* all copies or substantial portions of the Software. |
17
|
|
|
* |
18
|
|
|
* THE SOFTWARE IS PROVIDED "AS IS", WITHOUT WARRANTY OF ANY KIND, EXPRESS OR |
19
|
|
|
* IMPLIED, INCLUDING BUT NOT LIMITED TO THE WARRANTIES OF MERCHANTABILITY, |
20
|
|
|
* FITNESS FOR A PARTICULAR PURPOSE AND NONINFRINGEMENT. IN NO EVENT SHALL THE |
21
|
|
|
* AUTHORS OR COPYRIGHT HOLDERS BE LIABLE FOR ANY CLAIM, DAMAGES OR OTHER |
22
|
|
|
* LIABILITY, WHETHER IN AN ACTION OF CONTRACT, TORT OR OTHERWISE, ARISING |
23
|
|
|
* FROM, OUT OF OR IN CONNECTION WITH THE SOFTWARE OR THE USE OR OTHER DEALINGS |
24
|
|
|
* IN THE SOFTWARE. |
25
|
|
|
* |
26
|
|
|
* @package Phinx |
27
|
|
|
* @subpackage Phinx\Db\Adapter |
28
|
|
|
*/ |
29
|
|
|
namespace Phinx\Db\Adapter; |
30
|
|
|
|
31
|
|
|
use BadMethodCallException; |
32
|
|
|
use Phinx\Db\Table; |
33
|
|
|
use Phinx\Migration\MigrationInterface; |
34
|
|
|
|
35
|
|
|
/** |
36
|
|
|
* Phinx PDO Adapter. |
37
|
|
|
* |
38
|
|
|
* @author Rob Morgan <[email protected]> |
39
|
|
|
*/ |
40
|
|
|
abstract class PdoAdapter extends AbstractAdapter |
41
|
|
|
{ |
42
|
|
|
/** |
43
|
|
|
* @var \PDO|null |
44
|
|
|
*/ |
45
|
|
|
protected $connection; |
46
|
|
|
|
47
|
|
|
/** |
48
|
|
|
* {@inheritdoc} |
49
|
|
|
*/ |
50
|
|
|
public function setOptions(array $options) |
51
|
287 |
|
{ |
52
|
|
|
parent::setOptions($options); |
53
|
287 |
|
|
54
|
|
|
if (isset($options['connection'])) { |
55
|
287 |
|
$this->setConnection($options['connection']); |
56
|
3 |
|
} |
57
|
3 |
|
|
58
|
|
|
return $this; |
59
|
287 |
|
} |
60
|
|
|
|
61
|
|
|
/** |
62
|
|
|
* Sets the database connection. |
63
|
|
|
* |
64
|
|
|
* @param \PDO $connection Connection |
65
|
|
|
* @return \Phinx\Db\Adapter\AdapterInterface |
66
|
|
|
*/ |
67
|
|
|
public function setConnection(\PDO $connection) |
68
|
193 |
|
{ |
69
|
|
|
$this->connection = $connection; |
70
|
193 |
|
|
71
|
|
|
// Create the schema table if it doesn't already exist |
72
|
|
|
if (!$this->hasSchemaTable()) { |
73
|
193 |
|
$this->createSchemaTable(); |
74
|
191 |
|
} else { |
75
|
191 |
|
$table = new Table($this->getSchemaTableName(), [], $this); |
76
|
74 |
|
if (!$table->hasColumn('migration_name')) { |
77
|
74 |
|
$table |
78
|
|
|
->addColumn( |
79
|
|
|
'migration_name', |
80
|
|
|
'string', |
81
|
|
|
['limit' => 100, 'after' => 'version', 'default' => null, 'null' => true] |
82
|
|
|
) |
83
|
|
|
->save(); |
84
|
|
|
} |
85
|
|
|
if (!$table->hasColumn('breakpoint')) { |
86
|
74 |
|
$table |
87
|
|
|
->addColumn('breakpoint', 'boolean', ['default' => false]) |
88
|
|
|
->save(); |
89
|
|
|
} |
90
|
|
|
} |
91
|
|
|
|
92
|
|
|
return $this; |
93
|
193 |
|
} |
94
|
|
|
|
95
|
|
|
/** |
96
|
|
|
* Gets the database connection |
97
|
|
|
* |
98
|
|
|
* @return \PDO |
99
|
|
|
*/ |
100
|
|
|
public function getConnection() |
101
|
191 |
|
{ |
102
|
|
|
if ($this->connection === null) { |
103
|
191 |
|
$this->connect(); |
104
|
189 |
|
} |
105
|
189 |
|
|
106
|
191 |
|
return $this->connection; |
107
|
|
|
} |
108
|
|
|
|
109
|
|
|
/** |
110
|
|
|
* {@inheritdoc} |
111
|
|
|
*/ |
112
|
1 |
|
public function connect() |
113
|
|
|
{ |
114
|
1 |
|
} |
115
|
|
|
|
116
|
|
|
/** |
117
|
|
|
* {@inheritdoc} |
118
|
|
|
*/ |
119
|
|
|
public function disconnect() |
120
|
|
|
{ |
121
|
|
|
} |
122
|
|
|
|
123
|
|
|
/** |
124
|
|
|
* {@inheritdoc} |
125
|
|
|
*/ |
126
|
218 |
|
public function execute($sql) |
127
|
|
|
{ |
128
|
218 |
|
if ($this->isDryRunEnabled()) { |
129
|
3 |
|
$this->getOutput()->writeln($sql); |
130
|
3 |
|
|
131
|
|
|
return 0; |
132
|
|
|
} |
133
|
217 |
|
|
134
|
|
|
return $this->getConnection()->exec($sql); |
135
|
|
|
} |
136
|
|
|
|
137
|
|
|
/** |
138
|
|
|
* Executes a query and returns PDOStatement. |
139
|
|
|
* |
140
|
|
|
* @param string $sql SQL |
141
|
|
|
* @return \PDOStatement |
142
|
220 |
|
*/ |
143
|
|
|
public function query($sql) |
144
|
220 |
|
{ |
145
|
|
|
return $this->getConnection()->query($sql); |
146
|
|
|
} |
147
|
|
|
|
148
|
|
|
/** |
149
|
|
|
* {@inheritdoc} |
150
|
151 |
|
*/ |
151
|
|
|
public function fetchRow($sql) |
152
|
151 |
|
{ |
153
|
151 |
|
$result = $this->query($sql); |
154
|
|
|
|
155
|
|
|
return $result->fetch(); |
156
|
|
|
} |
157
|
|
|
|
158
|
|
|
/** |
159
|
213 |
|
* {@inheritdoc} |
160
|
|
|
*/ |
161
|
213 |
|
public function fetchAll($sql) |
162
|
213 |
|
{ |
163
|
213 |
|
$rows = []; |
164
|
208 |
|
$result = $this->query($sql); |
165
|
208 |
|
while ($row = $result->fetch()) { |
166
|
213 |
|
$rows[] = $row; |
167
|
|
|
} |
168
|
|
|
|
169
|
|
|
return $rows; |
170
|
|
|
} |
171
|
|
|
|
172
|
1 |
|
/** |
173
|
|
|
* {@inheritdoc} |
174
|
1 |
|
*/ |
175
|
1 |
|
public function insert(Table $table, $row) |
176
|
1 |
|
{ |
177
|
1 |
|
$sql = sprintf( |
178
|
|
|
'INSERT INTO %s ', |
179
|
1 |
|
$this->quoteTableName($table->getName()) |
180
|
1 |
|
); |
181
|
1 |
|
$columns = array_keys($row); |
182
|
|
|
$sql .= '(' . implode(', ', array_map([$this, 'quoteColumnName'], $columns)) . ')'; |
183
|
1 |
|
|
184
|
1 |
|
if ($this->isDryRunEnabled()) { |
185
|
1 |
|
$sql .= ' VALUES (' . implode(', ', array_map([$this, 'quoteValue'], $row)) . ');'; |
186
|
|
|
$this->output->writeln($sql); |
187
|
|
|
} else { |
188
|
|
|
$sql .= ' VALUES (' . implode(', ', array_fill(0, count($columns), '?')) . ')'; |
189
|
|
|
$stmt = $this->getConnection()->prepare($sql); |
190
|
11 |
|
$stmt->execute(array_values($row)); |
191
|
|
|
} |
192
|
11 |
|
} |
193
|
11 |
|
|
194
|
11 |
|
/** |
195
|
11 |
|
* Quotes a database value. |
196
|
|
|
* |
197
|
11 |
|
* @param mixed $value The value to quote |
198
|
11 |
|
* @return mixed |
199
|
11 |
|
*/ |
200
|
|
|
private function quoteValue($value) |
201
|
11 |
|
{ |
202
|
11 |
|
if (is_numeric($value)) { |
203
|
11 |
|
return $value; |
204
|
11 |
|
} |
205
|
11 |
|
|
206
|
11 |
|
if ($value === null) { |
207
|
|
|
return 'null'; |
208
|
11 |
|
} |
209
|
11 |
|
|
210
|
|
|
return $this->getConnection()->quote($value); |
211
|
11 |
|
} |
212
|
11 |
|
|
213
|
11 |
|
/** |
214
|
|
|
* {@inheritdoc} |
215
|
11 |
|
*/ |
216
|
11 |
|
public function bulkinsert(Table $table, $rows) |
217
|
11 |
|
{ |
218
|
|
|
$sql = sprintf( |
219
|
|
|
'INSERT INTO %s ', |
220
|
|
|
$this->quoteTableName($table->getName()) |
221
|
|
|
); |
222
|
5 |
|
$current = current($rows); |
223
|
|
|
$keys = array_keys($current); |
224
|
5 |
|
$sql .= '(' . implode(', ', array_map([$this, 'quoteColumnName'], $keys)) . ') VALUES '; |
225
|
|
|
|
226
|
5 |
|
if ($this->isDryRunEnabled()) { |
227
|
|
|
$values = array_map(function ($row) { |
228
|
|
|
return '(' . implode(', ', array_map([$this, 'quoteValue'], $row)) . ')'; |
229
|
|
|
}, $rows); |
230
|
|
|
$sql .= implode(', ', $values) . ';'; |
231
|
|
|
$this->output->writeln($sql); |
232
|
8 |
|
} else { |
233
|
|
|
$count_keys = count($keys); |
234
|
8 |
|
$query = '(' . implode(', ', array_fill(0, $count_keys, '?')) . ')'; |
235
|
|
|
$count_vars = count($rows); |
236
|
8 |
|
$queries = array_fill(0, $count_vars, $query); |
237
|
8 |
|
$sql .= implode(',', $queries); |
238
|
6 |
|
$stmt = $this->getConnection()->prepare($sql); |
239
|
6 |
|
$vals = []; |
240
|
2 |
|
|
241
|
1 |
|
foreach ($rows as $row) { |
242
|
1 |
|
foreach ($row as $v) { |
243
|
1 |
|
$vals[] = $v; |
244
|
1 |
|
} |
245
|
8 |
|
} |
246
|
|
|
|
247
|
7 |
|
$stmt->execute($vals); |
248
|
7 |
|
} |
249
|
7 |
|
} |
250
|
7 |
|
|
251
|
|
|
/** |
252
|
7 |
|
* {@inheritdoc} |
253
|
|
|
*/ |
254
|
|
|
public function getVersions() |
255
|
|
|
{ |
256
|
|
|
$rows = $this->getVersionLog(); |
257
|
|
|
|
258
|
5 |
|
return array_keys($rows); |
259
|
|
|
} |
260
|
5 |
|
|
261
|
|
|
/** |
262
|
5 |
|
* {@inheritdoc} |
263
|
5 |
|
*/ |
264
|
5 |
|
public function getVersionLog() |
265
|
5 |
|
{ |
266
|
5 |
|
$result = []; |
267
|
5 |
|
|
268
|
5 |
|
switch ($this->options['version_order']) { |
269
|
5 |
|
case \Phinx\Config\Config::VERSION_ORDER_CREATION_TIME: |
270
|
5 |
|
$orderBy = 'version ASC'; |
271
|
5 |
|
break; |
272
|
5 |
|
case \Phinx\Config\Config::VERSION_ORDER_EXECUTION_TIME: |
273
|
5 |
|
$orderBy = 'start_time ASC, version ASC'; |
274
|
5 |
|
break; |
275
|
5 |
|
default: |
276
|
|
|
throw new \RuntimeException('Invalid version_order configuration option'); |
277
|
5 |
|
} |
278
|
5 |
|
|
279
|
|
|
$rows = $this->fetchAll(sprintf('SELECT * FROM %s ORDER BY %s', $this->getSchemaTableName(), $orderBy)); |
280
|
3 |
|
foreach ($rows as $version) { |
281
|
3 |
|
$result[$version['version']] = $version; |
282
|
3 |
|
} |
283
|
3 |
|
|
284
|
3 |
|
return $result; |
285
|
3 |
|
} |
286
|
|
|
|
287
|
3 |
|
/** |
288
|
|
|
* {@inheritdoc} |
289
|
|
|
*/ |
290
|
5 |
|
public function migrated(MigrationInterface $migration, $direction, $startTime, $endTime) |
291
|
|
|
{ |
292
|
|
|
if (strcasecmp($direction, MigrationInterface::UP) === 0) { |
293
|
|
|
// up |
294
|
|
|
$sql = sprintf( |
295
|
|
|
"INSERT INTO %s (%s, %s, %s, %s, %s) VALUES ('%s', '%s', '%s', '%s', %s);", |
296
|
1 |
|
$this->quoteTableName($this->getSchemaTableName()), |
297
|
|
|
$this->quoteColumnName('version'), |
298
|
1 |
|
$this->quoteColumnName('migration_name'), |
299
|
1 |
|
$this->quoteColumnName('start_time'), |
300
|
1 |
|
$this->quoteColumnName('end_time'), |
301
|
1 |
|
$this->quoteColumnName('breakpoint'), |
302
|
1 |
|
$migration->getVersion(), |
303
|
1 |
|
substr($migration->getName(), 0, 100), |
304
|
1 |
|
$startTime, |
305
|
1 |
|
$endTime, |
306
|
1 |
|
$this->castToBool(false) |
307
|
1 |
|
); |
308
|
1 |
|
|
309
|
1 |
|
$this->execute($sql); |
310
|
|
|
} else { |
311
|
1 |
|
// down |
312
|
|
|
$sql = sprintf( |
313
|
|
|
"DELETE FROM %s WHERE %s = '%s'", |
314
|
|
|
$this->quoteTableName($this->getSchemaTableName()), |
315
|
|
|
$this->quoteColumnName('version'), |
316
|
|
|
$migration->getVersion() |
317
|
1 |
|
); |
318
|
|
|
|
319
|
1 |
|
$this->execute($sql); |
320
|
1 |
|
} |
321
|
1 |
|
|
322
|
1 |
|
return $this; |
323
|
1 |
|
} |
324
|
1 |
|
|
325
|
1 |
|
/** |
326
|
1 |
|
* @inheritDoc |
327
|
1 |
|
*/ |
328
|
|
|
public function toggleBreakpoint(MigrationInterface $migration) |
329
|
|
|
{ |
330
|
|
|
$this->query( |
331
|
|
|
sprintf( |
332
|
|
|
'UPDATE %1$s SET %2$s = CASE %2$s WHEN %3$s THEN %4$s ELSE %3$s END, %7$s = %7$s WHERE %5$s = \'%6$s\';', |
333
|
|
|
$this->getSchemaTableName(), |
334
|
|
|
$this->quoteColumnName('breakpoint'), |
335
|
|
|
$this->castToBool(true), |
336
|
|
|
$this->castToBool(false), |
337
|
|
|
$this->quoteColumnName('version'), |
338
|
|
|
$migration->getVersion(), |
339
|
|
|
$this->quoteColumnName('start_time') |
340
|
|
|
) |
341
|
|
|
); |
342
|
|
|
|
343
|
|
|
return $this; |
344
|
|
|
} |
345
|
|
|
|
346
|
|
|
/** |
347
|
|
|
* @inheritDoc |
348
|
|
|
*/ |
349
|
208 |
|
public function resetAllBreakpoints() |
350
|
|
|
{ |
351
|
|
|
return $this->execute( |
352
|
208 |
|
sprintf( |
353
|
208 |
|
'UPDATE %1$s SET %2$s = %3$s, %4$s = %4$s WHERE %2$s <> %3$s;', |
354
|
208 |
|
$this->getSchemaTableName(), |
355
|
208 |
|
$this->quoteColumnName('breakpoint'), |
356
|
208 |
|
$this->castToBool(false), |
357
|
208 |
|
$this->quoteColumnName('start_time') |
358
|
208 |
|
) |
359
|
208 |
|
); |
360
|
208 |
|
} |
361
|
208 |
|
|
362
|
208 |
|
/** |
363
|
208 |
|
* {@inheritdoc} |
364
|
208 |
|
*/ |
365
|
208 |
|
public function createSchema($schemaName = 'public') |
366
|
208 |
|
{ |
367
|
208 |
|
throw new BadMethodCallException('Creating a schema is not supported'); |
368
|
|
|
} |
369
|
208 |
|
|
370
|
208 |
|
/** |
371
|
208 |
|
* {@inheritdoc} |
372
|
208 |
|
*/ |
373
|
208 |
|
public function dropSchema($name) |
374
|
|
|
{ |
375
|
|
|
throw new BadMethodCallException('Dropping a schema is not supported'); |
376
|
|
|
} |
377
|
|
|
|
378
|
|
|
/** |
379
|
121 |
|
* {@inheritdoc} |
380
|
|
|
*/ |
381
|
121 |
|
public function getColumnTypes() |
382
|
|
|
{ |
383
|
|
|
return [ |
384
|
|
|
'string', |
385
|
|
|
'char', |
386
|
|
|
'text', |
387
|
|
|
'integer', |
388
|
|
|
'biginteger', |
389
|
|
|
'bit', |
390
|
|
|
'float', |
391
|
|
|
'decimal', |
392
|
|
|
'datetime', |
393
|
|
|
'timestamp', |
394
|
|
|
'time', |
395
|
|
|
'date', |
396
|
|
|
'blob', |
397
|
|
|
'binary', |
398
|
|
|
'varbinary', |
399
|
|
|
'boolean', |
400
|
|
|
'uuid', |
401
|
|
|
// Geospatial data types |
402
|
|
|
'geometry', |
403
|
|
|
'point', |
404
|
|
|
'linestring', |
405
|
|
|
'polygon', |
406
|
|
|
]; |
407
|
|
|
} |
408
|
|
|
|
409
|
|
|
/** |
410
|
|
|
* {@inheritdoc} |
411
|
|
|
*/ |
412
|
|
|
public function castToBool($value) |
413
|
|
|
{ |
414
|
|
|
return (bool)$value ? 1 : 0; |
415
|
|
|
} |
416
|
|
|
|
417
|
|
|
/** |
418
|
|
|
* Retrieve a database connection attribute |
419
|
|
|
* @see http://php.net/manual/en/pdo.getattribute.php |
420
|
|
|
* |
421
|
|
|
* @param int $attribute One of the PDO::ATTR_* constants |
422
|
|
|
* @return mixed |
423
|
|
|
*/ |
424
|
|
|
public function getAttribute($attribute) |
425
|
|
|
{ |
426
|
|
|
return $this->connection->getAttribute($attribute); |
427
|
|
|
} |
428
|
|
|
|
429
|
|
|
/** |
430
|
|
|
* Get the defintion for a `DEFAULT` statement. |
431
|
|
|
* |
432
|
|
|
* @param mixed $default Default value |
433
|
|
|
* @return string |
434
|
|
|
*/ |
435
|
|
|
protected function getDefaultValueDefinition($default) |
436
|
|
|
{ |
437
|
|
|
if (is_string($default) && 'CURRENT_TIMESTAMP' !== $default) { |
438
|
|
|
$default = $this->getConnection()->quote($default); |
439
|
|
|
} elseif (is_bool($default)) { |
440
|
|
|
$default = $this->castToBool($default); |
441
|
|
|
} |
442
|
|
|
|
443
|
|
|
return isset($default) ? " DEFAULT $default" : ''; |
444
|
|
|
} |
445
|
|
|
} |
446
|
|
|
|