doctrine / dbal

     *

     * @return \Doctrine\DBAL\Driver

     */

    protected function connectTo($connectionName)

    {

        $params = $this->getParams();

        $driverOptions = isset($params['driverOptions']) ? $params['driverOptions'] : [];

        $connectionParams = $this->chooseConnectionConfiguration($connectionName, $params);

        $user = isset($connectionParams['user']) ? $connectionParams['user'] : null;

        $password = isset($connectionParams['password']) ? $connectionParams['password'] : null;

        return $this->_driver->connect($connectionParams, $user, $password, $driverOptions);

    }

    /**

     * @param string $connectionName

     *

     * @return \Doctrine\DBAL\Driver\Connection

     */

    protected function connectTo($shardId)

    {

        $params = $this->getParams();

        $driverOptions = isset($params['driverOptions']) ? $params['driverOptions'] : [];

        $connectionParams = $this->connections[$shardId];

        $user = isset($connectionParams['user']) ? $connectionParams['user'] : null;

        $password = isset($connectionParams['password']) ? $connectionParams['password'] : null;

        return $this->_driver->connect($connectionParams, $user, $password, $driverOptions);

    }

    /**

     * @param string|null $shardId