@@ -26,7 +26,7 @@ |
||
| 26 | 26 | } |
| 27 | 27 | |
| 28 | 28 | /** |
| 29 | - * @return \Doctrine\DBAL\Query\Builder |
|
| 29 | + * @return \Doctrine\DBAL\Query\QueryBuilder |
|
| 30 | 30 | */ |
| 31 | 31 | public function builder() |
| 32 | 32 | { |
@@ -85,6 +85,9 @@ discard block |
||
| 85 | 85 | */ |
| 86 | 86 | protected $id_counter = 0; |
| 87 | 87 | |
| 88 | + /** |
|
| 89 | + * @param \Doctrine\DBAL\Connection $connection |
|
| 90 | + */ |
|
| 88 | 91 | public function __construct($connection) |
| 89 | 92 | { |
| 90 | 93 | parent::__construct($connection); |
@@ -243,6 +246,9 @@ discard block |
||
| 243 | 246 | $which = []; |
| 244 | 247 | } |
| 245 | 248 | |
| 249 | + /** |
|
| 250 | + * @param string $table |
|
| 251 | + */ |
|
| 246 | 252 | protected function append_and_maybe_flush($table, $values) |
| 247 | 253 | { |
| 248 | 254 | if ($values[0] === null) { |
@@ -260,6 +266,10 @@ discard block |
||
| 260 | 266 | |
| 261 | 267 | return $id; |
| 262 | 268 | } |
| 269 | + |
|
| 270 | + /** |
|
| 271 | + * @param string $str |
|
| 272 | + */ |
|
| 263 | 273 | protected function esc_str($str) |
| 264 | 274 | { |
| 265 | 275 | assert('is_string($str)'); |
@@ -315,6 +325,9 @@ discard block |
||
| 315 | 325 | |
| 316 | 326 | // INIT DATABASE |
| 317 | 327 | |
| 328 | + /** |
|
| 329 | + * @param string $name |
|
| 330 | + */ |
|
| 318 | 331 | public function init_table($name, Schema\Schema $schema, Schema\Table $file_table = null, Schema\Table $namespace_table = null) |
| 319 | 332 | { |
| 320 | 333 | assert('array_key_exists($name, $this->tables)'); |
@@ -13,8 +13,6 @@ |
||
| 13 | 13 | use Lechimp\Dicto\Graph; |
| 14 | 14 | use Lechimp\Dicto\Indexer\Insert; |
| 15 | 15 | use Doctrine\DBAL\Schema; |
| 16 | -use Doctrine\DBAL\Schema\Synchronizer\SingleDatabaseSynchronizer; |
|
| 17 | -use Doctrine\DBAL\Statement; |
|
| 18 | 16 | |
| 19 | 17 | class IndexDB extends DB implements Insert |
| 20 | 18 | { |
@@ -242,6 +242,9 @@ |
||
| 242 | 242 | return (int) $this->connection->lastInsertId(); |
| 243 | 243 | } |
| 244 | 244 | |
| 245 | + /** |
|
| 246 | + * @param integer $var_id |
|
| 247 | + */ |
|
| 245 | 248 | protected function update_variable($var_id) |
| 246 | 249 | { |
| 247 | 250 | assert('is_integer($var_id)'); |
@@ -17,7 +17,6 @@ |
||
| 17 | 17 | use Lechimp\Dicto\Rules\Rule; |
| 18 | 18 | use Lechimp\Dicto\Variables\Variable; |
| 19 | 19 | use Doctrine\DBAL\Schema; |
| 20 | -use Doctrine\DBAL\Schema\Synchronizer\SingleDatabaseSynchronizer; |
|
| 21 | 20 | |
| 22 | 21 | class ResultDB extends DB implements Listener |
| 23 | 22 | { |