| @@ 181-189 (lines=9) @@ | ||
| 178 | * @param $query |
|
| 179 | * @throws \Doctrine\DBAL\DBALException |
|
| 180 | */ |
|
| 181 | protected function executeQuery(LoggerInterface $logger, $dryRun, $def, $row, $query) |
|
| 182 | { |
|
| 183 | $params = ['definition' => json_encode($def), 'id' => $row['id']]; |
|
| 184 | $types = ['definition' => 'text', 'id' => 'integer']; |
|
| 185 | $this->logQuery($logger, $query, $params, $types); |
|
| 186 | if (!$dryRun) { |
|
| 187 | $this->connection->executeUpdate($query, $params, $types); |
|
| 188 | } |
|
| 189 | } |
|
| 190 | ||
| 191 | /** |
|
| 192 | * @param $def |
|
| @@ 216-224 (lines=9) @@ | ||
| 213 | * @param string $query |
|
| 214 | * @throws \Doctrine\DBAL\DBALException |
|
| 215 | */ |
|
| 216 | protected function executeQuery(LoggerInterface $logger, $dryRun, $def, $row, $query) |
|
| 217 | { |
|
| 218 | $params = ['definition' => json_encode($def), 'id' => $row['id']]; |
|
| 219 | $types = ['definition' => 'text', 'id' => 'integer']; |
|
| 220 | $this->logQuery($logger, $query, $params, $types); |
|
| 221 | if (!$dryRun) { |
|
| 222 | $this->connection->executeUpdate($query, $params, $types); |
|
| 223 | } |
|
| 224 | } |
|
| 225 | ||
| 226 | /** |
|
| 227 | * @param array $def |
|