| @@ 1270-1288 (lines=19) @@ | ||
| 1267 | * {@inheritDoc} |
|
| 1268 | * |
|
| 1269 | */ |
|
| 1270 | public function getDecoratedConnection() |
|
| 1271 | { |
|
| 1272 | $options = $this->getOptions(); |
|
| 1273 | $options = [ |
|
| 1274 | 'username' => $options['user'], |
|
| 1275 | 'password' => $options['pass'], |
|
| 1276 | 'database' => $options['name'], |
|
| 1277 | 'quoteIdentifiers' => true, |
|
| 1278 | ] + $options; |
|
| 1279 | ||
| 1280 | $driver = new MysqlDriver($options); |
|
| 1281 | if (method_exists($driver, 'setConnection')) { |
|
| 1282 | $driver->setConnection($this->connection); |
|
| 1283 | } else { |
|
| 1284 | $driver->connection($this->connection); |
|
| 1285 | } |
|
| 1286 | ||
| 1287 | return new Connection(['driver' => $driver] + $options); |
|
| 1288 | } |
|
| 1289 | } |
|
| 1290 | ||
| @@ 1401-1420 (lines=20) @@ | ||
| 1398 | * {@inheritDoc} |
|
| 1399 | * |
|
| 1400 | */ |
|
| 1401 | public function getDecoratedConnection() |
|
| 1402 | { |
|
| 1403 | $options = $this->getOptions(); |
|
| 1404 | $options = [ |
|
| 1405 | 'username' => $options['user'], |
|
| 1406 | 'password' => $options['pass'], |
|
| 1407 | 'database' => $options['name'], |
|
| 1408 | 'quoteIdentifiers' => true, |
|
| 1409 | ] + $options; |
|
| 1410 | ||
| 1411 | $driver = new PostgresDriver($options); |
|
| 1412 | ||
| 1413 | if (method_exists($driver, 'setConnection')) { |
|
| 1414 | $driver->setConnection($this->connection); |
|
| 1415 | } else { |
|
| 1416 | $driver->connection($this->connection); |
|
| 1417 | } |
|
| 1418 | ||
| 1419 | return new Connection(['driver' => $driver] + $options); |
|
| 1420 | } |
|
| 1421 | } |
|
| 1422 | ||
| @@ 1275-1294 (lines=20) @@ | ||
| 1272 | * {@inheritDoc} |
|
| 1273 | * |
|
| 1274 | */ |
|
| 1275 | public function getDecoratedConnection() |
|
| 1276 | { |
|
| 1277 | $options = $this->getOptions(); |
|
| 1278 | $options = [ |
|
| 1279 | 'username' => $options['user'], |
|
| 1280 | 'password' => $options['pass'], |
|
| 1281 | 'database' => $options['name'], |
|
| 1282 | 'quoteIdentifiers' => true, |
|
| 1283 | ] + $options; |
|
| 1284 | ||
| 1285 | $driver = new SqlServerDriver($options); |
|
| 1286 | ||
| 1287 | if (method_exists($driver, 'setConnection')) { |
|
| 1288 | $driver->setConnection($this->connection); |
|
| 1289 | } else { |
|
| 1290 | $driver->connection($this->connection); |
|
| 1291 | } |
|
| 1292 | ||
| 1293 | return new Connection(['driver' => $driver] + $options); |
|
| 1294 | } |
|
| 1295 | } |
|
| 1296 | ||