Symfony 2 Comando della console per la creazione del database personalizzato

Question

Sto lavorando a un progetto Symfony 2 in cui ogni utente ha il proprio database. Nel mio file config.yml ho una dottrina: dbal: orm impostata per un client ma nessuna proprietà di connessione perché sono impostate in fase di esecuzione e fanno riferimento a tutti gli utenti. Io ho solo una connessione dbb predefinita e due connessioni orm e il numero di utenti è illimitato.

Questo funziona correttamente ma è necessario creare il database e lo schema quando l'utente è registrato (FOS UserBundle). Nel controller esteso di userbundle posso mettere la mia logica. Il problema è che non riesco a eseguire la 'app/console di php doctrine: database: creare' poiché non ci sono parametri impostati per il nuovo utente.

Esiste un modo per specificare un parametro del database personalizzato per i comandi della console? Probabilmente potrei aggirare questo con alcuni comandi di mysql molto brutti ma preferirei non farlo. Molte grazie in anticipo!

Answer 1

È possibile creare il proprio comando utilizzando il codice qui sotto come un contorno:

namespace Doctrine\Bundle\DoctrineBundle\Command; 

use Symfony\Component\Console\Input\InputOption; 
use Symfony\Component\Console\Input\InputInterface; 
use Symfony\Component\Console\Output\OutputInterface; 
use Doctrine\DBAL\DriverManager; 

class CreateDatabaseDoctrineCommandDynamically extends DoctrineCommand 
{ 

    protected function configure() 
    { 
     $this 
      ->setName('doctrine:database:createdynamic') 
      ->setDescription('Creates the configured databases'); 
    } 

    /** 
    * {@inheritDoc} 
    */ 
    protected function execute(InputInterface $input, OutputInterface $output) 
    { 
    /*** 
     ** Edit this part below to get the database configuration however you want 
     **/ 
     $connectionFactory = $this->container->get('doctrine.dbal.connection_factory'); 
     $connection = $connectionFactory->createConnection(array(
     'driver' => 'pdo_mysql', 
     'user' => 'root', 
     'password' => '', 
     'host' => 'localhost', 
     'dbname' => 'foo_database', 
     )); 

     $params = $connection->getParams(); 
     $name = isset($params['path']) ? $params['path'] : $params['dbname']; 

     unset($params['dbname']); 

     $tmpConnection = DriverManager::getConnection($params); 

     // Only quote if we don't have a path 
     if (!isset($params['path'])) { 
      $name = $tmpConnection->getDatabasePlatform()->quoteSingleIdentifier($name); 
     } 

     $error = false; 
     try { 
      $tmpConnection->getSchemaManager()->createDatabase($name); 
      $output->writeln(sprintf('<info>Created database for connection named <comment>%s</comment></info>', $name)); 
     } catch (\Exception $e) { 
      $output->writeln(sprintf('<error>Could not create database for connection named <comment>%s</comment></error>', $name)); 
      $output->writeln(sprintf('<error>%s</error>', $e->getMessage())); 
      $error = true; 
     } 

     $tmpConnection->close(); 

     return $error ? 1 : 0; 
    } 
}