doctrine /
dbal
| @@ 201-213 (lines=13) @@ | ||
| 198 | * |
|
| 199 | * @return \Doctrine\DBAL\Driver |
|
| 200 | */ |
|
| 201 | protected function connectTo($connectionName) |
|
| 202 | { |
|
| 203 | $params = $this->getParams(); |
|
| 204 | ||
| 205 | $driverOptions = $params['driverOptions'] ?? []; |
|
| 206 | ||
| 207 | $connectionParams = $this->chooseConnectionConfiguration($connectionName, $params); |
|
| 208 | ||
| 209 | $user = $connectionParams['user'] ?? null; |
|
| 210 | $password = $connectionParams['password'] ?? null; |
|
| 211 | ||
| 212 | return $this->_driver->connect($connectionParams, $user, $password, $driverOptions); |
|
| 213 | } |
|
| 214 | ||
| 215 | /** |
|
| 216 | * @param string $connectionName |
|
| @@ 235-247 (lines=13) @@ | ||
| 232 | * |
|
| 233 | * @return \Doctrine\DBAL\Driver\Connection |
|
| 234 | */ |
|
| 235 | protected function connectTo($shardId) |
|
| 236 | { |
|
| 237 | $params = $this->getParams(); |
|
| 238 | ||
| 239 | $driverOptions = $params['driverOptions'] ?? []; |
|
| 240 | ||
| 241 | $connectionParams = $this->connections[$shardId]; |
|
| 242 | ||
| 243 | $user = $connectionParams['user'] ?? null; |
|
| 244 | $password = $connectionParams['password'] ?? null; |
|
| 245 | ||
| 246 | return $this->_driver->connect($connectionParams, $user, $password, $driverOptions); |
|
| 247 | } |
|
| 248 | ||
| 249 | /** |
|
| 250 | * @param string|null $shardId |
|
