Symfony 3.4 и Doctrine: как получить соединения, определенные в config.yml, из службы, используя имя соединения

Question

У меня есть две базы данных, одна для производства и одна для резервного копирования.Я хочу иметь службу в Symfony, вызываемую из команды, которая может выполнять некоторые SQL-запросы в одной из этих двух баз данных в зависимости от имени соединения, переданного командой.Проблема в том, что я не знаю, как получить соединение DBAL, используя имя соединения в качестве параметра.

Я использую Symfony 3.4.

Файл config.yml:

#config.yml
doctrine:
    dbal:
        default_connection: prod
        connections:
        prod:
            driver: '%database_driver1%'
            host: '%database_host1%'
            port: '%database_port1%'
            dbname: '%database_name1%'
            user: '%database_user1%'
            password: '%database_password1%'
            charset: UTF8

        backup:
            driver: '%database_driver2%'
            host: '%database_host2%'
            port: '%database_port2%'
            dbname: '%database_name2%'
            user: '%database_user2%'
            password: '%database_password2%'
            charset: UTF8

Идея Mi заключается в том, чтобы иметь такой сервис:

<?php

namespace ErqBundle\Services;

use Doctrine\DBAL\Driver\Connection;

class ProcSQL {

    public function exSQL($conn_name)
    {
        // How to obtain the connection ???? 
        $conn=$this->getDoctrine()->getConnection($conn_name);
        // This doesn't work !!!

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

}

Но я не смог получить соединение с именем соединения, таким как "prod" или "backup" (что-то вроде: $ conn = $ this-> getDoctrine () -> getConnection ($ conn_name))

Единственный способ заставить его работать, это снова определить параметры соединения и установить соединение следующим образом:

public 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 !!!


}

Заранее спасибо.

Answer 1

Если у вас есть доступ к доктрине, вы можете сделать что-то вроде

$this->getDoctrine()->getManager('backup');

Но, как говорит @AlessandroMinoccheri, лучше вводить его / их напрямую.

Если вам нужно ввестипо умолчанию, просто используйте doctrine.orm.entity_manager, если вам нужно ввести backup, используйте doctrine.orm.backup_entity_manager

Answer 2

Спасибо вам обоим.Подумав в ваших ответах, я попробовал:

Я добавил:

use \Doctrine\ORM\EntityManager;

и вызвал Doctrine 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);
    }   

} 

и это работает!!!!!

Большое спасибо !!!

Answer 3

Вы можете использовать внедрение зависимости следующим образом:

use \Doctrine\ORM\EntityManager;
class ProcSQL {
    private $entityManager
    public function __construct(EntityManager $entityManager)
    {
        $this->entityManager = $entityManager;
    }

    public function exSQL($conn_name)
    {
        $conn = $this->entityManager->getConnection($conn_name);
    }
}

Вам необходимо объявить свой сервис следующим образом (я не знаю, используете ли вы автоматическую разводку или нет):

ErqBundle\Services\ProcSql:
    class:     ErqBundle\Services\ProcSql
    arguments:
         - '@doctrine.orm.entity_manager'