|
1
|
|
|
<?php |
|
2
|
|
|
|
|
3
|
|
|
/** |
|
4
|
|
|
* This file is part of Fabrica. |
|
5
|
|
|
* |
|
6
|
|
|
* (c) Alexandre Salomé <[email protected]> |
|
7
|
|
|
* (c) Julien DIDIER <[email protected]> |
|
8
|
|
|
* |
|
9
|
|
|
* This source file is subject to the GPL license that is bundled |
|
10
|
|
|
* with this source code in the file LICENSE. |
|
11
|
|
|
*/ |
|
12
|
|
|
|
|
13
|
|
|
namespace Fabrica\Component\Config; |
|
14
|
|
|
|
|
15
|
|
|
use Doctrine\DBAL\Connection; |
|
16
|
|
|
|
|
17
|
|
|
use Fabrica\Component\Config\Exception\RuntimeException; |
|
18
|
|
|
|
|
19
|
|
|
/** |
|
20
|
|
|
* Bulk MySQL version of Config: deletes and reinsert rows. |
|
21
|
|
|
* |
|
22
|
|
|
* @author Alexandre Salomé <[email protected]> |
|
23
|
|
|
*/ |
|
24
|
|
|
class MysqlConfig extends AbstractConfig |
|
25
|
|
|
{ |
|
26
|
|
|
/** |
|
27
|
|
|
* @var Connection |
|
28
|
|
|
*/ |
|
29
|
|
|
protected $connection; |
|
30
|
|
|
protected $tableName; |
|
31
|
|
|
protected $tableExists; |
|
32
|
|
|
|
|
33
|
|
|
public function __construct(Connection $connection, $tableName = '_config') |
|
34
|
|
|
{ |
|
35
|
|
|
$this->connection = $connection; |
|
36
|
|
|
$this->tableName = $tableName; |
|
37
|
|
|
} |
|
38
|
|
|
|
|
39
|
|
|
/** |
|
40
|
|
|
* {@inheritDoc} |
|
41
|
|
|
*/ |
|
42
|
|
|
public function doGetAll() |
|
43
|
|
|
{ |
|
44
|
|
|
$stmt = $this->runSql('SELECT `key`, `value` FROM `'. $this->tableName.'`'); |
|
45
|
|
|
|
|
46
|
|
|
$result = array(); |
|
47
|
|
|
while ($row = $stmt->fetch(\PDO::FETCH_ASSOC)) { |
|
|
|
|
|
|
48
|
|
|
$result[$row['key']] = json_decode($row['value']); |
|
49
|
|
|
} |
|
50
|
|
|
|
|
51
|
|
|
return $result; |
|
52
|
|
|
} |
|
53
|
|
|
|
|
54
|
|
|
/** |
|
55
|
|
|
* {@inheritDoc} |
|
56
|
|
|
*/ |
|
57
|
|
|
protected function doSetAll(array $values) |
|
58
|
|
|
{ |
|
59
|
|
|
$this->runSQL('DELETE FROM `'.$this->tableName.'`'); |
|
60
|
|
|
|
|
61
|
|
|
$rows = array(); |
|
|
|
|
|
|
62
|
|
|
foreach ($values as $key => $value) { |
|
63
|
|
|
$this->runSQL('INSERT INTO '.$this->tableName.' (`key`, `value`) VALUES ('.$this->connection->quote($key).','.$this->connection->quote(json_encode($value)).');'); |
|
64
|
|
|
} |
|
65
|
|
|
} |
|
66
|
|
|
|
|
67
|
|
|
/** |
|
68
|
|
|
* Proxy method to connection object. If an error occurred because of unfound table, tries to create table and rerun request. |
|
69
|
|
|
* |
|
70
|
|
|
* @param string $query SQL query |
|
71
|
|
|
* @param array $parameters query parameters |
|
72
|
|
|
*/ |
|
73
|
|
View Code Duplication |
protected function runSQL($query, array $parameters = array()) |
|
|
|
|
|
|
74
|
|
|
{ |
|
75
|
|
|
try { |
|
76
|
|
|
return $this->connection->executeQuery($query, $parameters); |
|
77
|
|
|
} catch (\Exception $e) { |
|
78
|
|
|
$this->connection->executeQuery(sprintf('CREATE TABLE %s (`key` VARCHAR(40), `value` TEXT);', $this->tableName)); |
|
79
|
|
|
} |
|
80
|
|
|
|
|
81
|
|
|
return $this->connection->executeQuery($query, $parameters); |
|
82
|
|
|
} |
|
83
|
|
|
} |
|
84
|
|
|
|
This method has been deprecated. The supplier of the class has supplied an explanatory message.
The explanatory message should give you some clue as to whether and when the method will be removed from the class and what other method or class to use instead.