Create a Doctrine DBAL Connection for Another Database

Copy/** @var \Doctrine\Bundle\DoctrineBundle\ConnectionFactory $connectionFactory */
$connectionFactory = $this->getContainer()->get('doctrine.dbal.connection_factory');
$connection = $connectionFactory->createConnection([
	'pdo' => new \PDO(
		"mysql:host=$hostname;dbname=$dbname", 
		$username, 
		$password)
]);

$connection->executeQuery('SELECT * FROM your_table');

Copy/**
 * Creates connection based on application configuration.
 */
function createConnection(): \Doctrine\DBAL\Connection
{
    $config = new \Doctrine\DBAL\Configuration();
    $parser = new \Symfony\Component\Yaml\Parser();
    $configParams = $parser->parse(file_get_contents(getcwd() . '/config/parameters.yml'));
    $configParams = $configParams['parameters'];

    return \Doctrine\DBAL\DriverManager::getConnection([
        'dbname' => $configParams['database_name'],
        'user' => $configParams['database_user'],
        'password' => $configParams['database_password'],
        'host' => $configParams['database_host'],
        'driver' => $configParams['database_driver']
    ], $config);
}

Copypublic function exSQL()
{


    $config = new \Doctrine\DBAL\Configuration();

    $connectionParams = array(
        'dbname' => 'dbname',
        'user' => 'user',
        'password' => 'password',
        'host' => 'prod_host',
        'driver' => 'pdo_mysql',
    );
    $conn = \Doctrine\DBAL\DriverManager::getConnection($connectionParams, $config);


    $sql = "SELECT ...";
    $stmt = $conn->query($sql); 

    while ($row = $stmt->fetch()) {
        var_dump($row);
    }

    // This works !!!


}

Copydoctrine:
    dbal:
        connections:
            emgsihe:
                driver:   pdo_mysql
                host:     '%database_host%'
                port:     '%database_port%'
                dbname:   emgsihe
                user:     '%database_user%'
                password: '%database_password%'
                charset:  UTF8
    orm:
        entity_managers:
            emgsihe:
                connection: emgsihe

Copy// ...

use \Doctrine\ORM\EntityManager;
//...

public function __construct(EntityManager $entityManager)
{
    $this->entityManager = $entityManager;
}

public function exSQL($conn_name)
{

    $conn = $this->entityManager->getConnection($conn_name);

    $sql = "SELECT ...";
    $stmt = $conn->query($sql); 

    while ($row = $stmt->fetch()) {
        var_dump($row);
    }   

}