| @@ 143-149 (lines=7) @@ | ||
| 140 | } |
|
| 141 | ||
| 142 | $connection = $connectionPool->getConnectionByName($connectionName); |
|
| 143 | foreach ($statementsToExecute as $hash => $statement) { |
|
| 144 | try { |
|
| 145 | $connection->executeUpdate($statement); |
|
| 146 | } catch (DBALException $e) { |
|
| 147 | $result[$hash] = $e->getPrevious()->getMessage(); |
|
| 148 | } |
|
| 149 | } |
|
| 150 | } |
|
| 151 | ||
| 152 | return $result; |
|
| @@ 224-231 (lines=8) @@ | ||
| 221 | $connection->truncate($tableName); |
|
| 222 | } |
|
| 223 | ||
| 224 | foreach ((array)$perTableStatements as $statement) { |
|
| 225 | try { |
|
| 226 | $connection->executeUpdate($statement); |
|
| 227 | $result[$statement] = ''; |
|
| 228 | } catch (DBALException $e) { |
|
| 229 | $result[$statement] = $e->getPrevious()->getMessage(); |
|
| 230 | } |
|
| 231 | } |
|
| 232 | } |
|
| 233 | ||
| 234 | return $result; |
|
| @@ 227-234 (lines=8) @@ | ||
| 224 | $this->connection->getDatabasePlatform() |
|
| 225 | ); |
|
| 226 | ||
| 227 | foreach ($statements as $statement) { |
|
| 228 | try { |
|
| 229 | $this->connection->executeUpdate($statement); |
|
| 230 | $result[$statement] = ''; |
|
| 231 | } catch (DBALException $e) { |
|
| 232 | $result[$statement] = $e->getPrevious()->getMessage(); |
|
| 233 | } |
|
| 234 | } |
|
| 235 | ||
| 236 | return $result; |
|
| 237 | } |
|