| @@ 1390-1409 (lines=20) @@ | ||
| 1387 | * {@inheritDoc} |
|
| 1388 | * |
|
| 1389 | */ |
|
| 1390 | public function getDecoratedConnection() |
|
| 1391 | { |
|
| 1392 | $options = $this->getOptions(); |
|
| 1393 | $options = [ |
|
| 1394 | 'username' => $options['user'], |
|
| 1395 | 'password' => $options['pass'], |
|
| 1396 | 'database' => $options['name'], |
|
| 1397 | 'quoteIdentifiers' => true, |
|
| 1398 | ] + $options; |
|
| 1399 | ||
| 1400 | $driver = new PostgresDriver($options); |
|
| 1401 | ||
| 1402 | if (method_exists($driver, 'setConnection')) { |
|
| 1403 | $driver->setConnection($this->connection); |
|
| 1404 | } else { |
|
| 1405 | $driver->connection($this->connection); |
|
| 1406 | } |
|
| 1407 | ||
| 1408 | return new Connection(['driver' => $driver] + $options); |
|
| 1409 | } |
|
| 1410 | } |
|
| 1411 | ||
| @@ 1262-1280 (lines=19) @@ | ||
| 1259 | * {@inheritDoc} |
|
| 1260 | * |
|
| 1261 | */ |
|
| 1262 | public function getDecoratedConnection() |
|
| 1263 | { |
|
| 1264 | $options = $this->getOptions(); |
|
| 1265 | $options = [ |
|
| 1266 | 'username' => $options['user'], |
|
| 1267 | 'password' => $options['pass'], |
|
| 1268 | 'database' => $options['name'], |
|
| 1269 | 'quoteIdentifiers' => true, |
|
| 1270 | ] + $options; |
|
| 1271 | ||
| 1272 | $driver = new MysqlDriver($options); |
|
| 1273 | if (method_exists($driver, 'setConnection')) { |
|
| 1274 | $driver->setConnection($this->connection); |
|
| 1275 | } else { |
|
| 1276 | $driver->connection($this->connection); |
|
| 1277 | } |
|
| 1278 | ||
| 1279 | return new Connection(['driver' => $driver] + $options); |
|
| 1280 | } |
|
| 1281 | } |
|
| 1282 | ||
| @@ 1263-1282 (lines=20) @@ | ||
| 1260 | * {@inheritDoc} |
|
| 1261 | * |
|
| 1262 | */ |
|
| 1263 | public function getDecoratedConnection() |
|
| 1264 | { |
|
| 1265 | $options = $this->getOptions(); |
|
| 1266 | $options = [ |
|
| 1267 | 'username' => $options['user'], |
|
| 1268 | 'password' => $options['pass'], |
|
| 1269 | 'database' => $options['name'], |
|
| 1270 | 'quoteIdentifiers' => true, |
|
| 1271 | ] + $options; |
|
| 1272 | ||
| 1273 | $driver = new SqlServerDriver($options); |
|
| 1274 | ||
| 1275 | if (method_exists($driver, 'setConnection')) { |
|
| 1276 | $driver->setConnection($this->connection); |
|
| 1277 | } else { |
|
| 1278 | $driver->connection($this->connection); |
|
| 1279 | } |
|
| 1280 | ||
| 1281 | return new Connection(['driver' => $driver] + $options); |
|
| 1282 | } |
|
| 1283 | } |
|
| 1284 | ||