Merge pull request #20 from homersimpsons/feature/multiple-connections

Multiple Connections

Author: moufmouf

.gitignore

@@ -1,4 +1,9 @@
+/Tests/GeneratedDb*
 /vendor/
 /composer.lock
 /build
-/cache
+/cache
+/.phpunit.result.cache
+/var
+/tdbm*.lock.yml
+/phpunit.xml

.travis.yml

@@ -11,6 +11,9 @@ env:
     - COMPOSER_MEMORY_LIMIT=-1
     #- SYMFONY_PHPUNIT_DIR="$HOME/symfony-bridge/.phpunit"
 
+services:
+  - mysql
+
 matrix:
   fast_finish: true
   include:

DependencyInjection/Configuration.php

@@ -3,6 +3,7 @@
 
 namespace TheCodingMachine\TDBM\Bundle\DependencyInjection;
 
+use Symfony\Component\Config\Definition\Builder\NodeBuilder;
 use Symfony\Component\Config\Definition\Builder\TreeBuilder;
 use Symfony\Component\Config\Definition\ConfigurationInterface;
 
@@ -13,11 +14,27 @@ public function getConfigTreeBuilder()
         $treeBuilder = new TreeBuilder('tdbm');
         $rootNode = $treeBuilder->getRootNode();
 
-        $rootNode
-            ->children()
+        $rootNodeChildren = $rootNode->children();
+
+        $this->buildServiceNode($rootNodeChildren);
+
+        $rootNodeServices = $rootNodeChildren->arrayNode('databases')->arrayPrototype()->children();
+        $this->buildServiceNode($rootNodeServices);
+        $rootNodeServices->end()->end()->end();
+
+        $rootNodeChildren->end();
+
+        return $treeBuilder;
+    }
+
+    private function buildServiceNode(NodeBuilder $serviceNode): void
+    {
+        $serviceNode
             ->scalarNode('dao_namespace')->defaultValue('App\\Daos')->end()
             ->scalarNode('bean_namespace')->defaultValue('App\\Beans')->end()
+            ->scalarNode('connection')->defaultValue('doctrine.dbal.default_connection')->end()
             ->arrayNode('naming')
+                ->addDefaultsIfNotSet()
                 ->children()
                     ->scalarNode('bean_prefix')->defaultValue('')->end()
                     ->scalarNode('bean_suffix')->defaultValue('')->end()
@@ -29,11 +46,8 @@ public function getConfigTreeBuilder()
                     ->scalarNode('base_dao_suffix')->defaultValue('Dao')->end()
                     ->arrayNode('exceptions')
                         ->prototype('scalar')->end()
+                    ->end()
                 ->end()
-            ->end()
-            ->end()
-        ;
-
-        return $treeBuilder;
+            ->end();
     }
 }

DependencyInjection/ConnectionConfiguration.php

@@ -0,0 +1,116 @@
+<?php
+
+declare(strict_types=1);
+
+namespace TheCodingMachine\TDBM\Bundle\DependencyInjection;
+
+
+class ConnectionConfiguration
+{
+    /** @var string */
+    private $daoNamespace;
+    /** @var string */
+    private $beanNamespace;
+    /** @var string */
+    private $connection;
+    /** @var string */
+    private $namingBeanPrefix;
+    /** @var string */
+    private $namingBeanSuffix;
+    /** @var string */
+    private $namingBaseBeanPrefix;
+    /** @var string */
+    private $namingBaseBeanSuffix;
+    /** @var string */
+    private $namingDaoPrefix;
+    /** @var string */
+    private $namingDaoSuffix;
+    /** @var string */
+    private $namingBaseDaoPrefix;
+    /** @var string */
+    private $namingBaseDaoSuffix;
+    /** @var array<string, string> */
+    private $namingExceptions;
+
+    /**
+     * @param array<string, mixed> $connectionParams
+     */
+    public function __construct(array $connectionParams)
+    {
+        $this->daoNamespace = $connectionParams['dao_namespace'];
+        $this->beanNamespace = $connectionParams['bean_namespace'];
+        $this->connection = $connectionParams['connection'];
+        $this->namingBeanPrefix = $connectionParams['naming']['bean_prefix'];
+        $this->namingBeanSuffix = $connectionParams['naming']['bean_suffix'];
+        $this->namingBaseBeanPrefix = $connectionParams['naming']['base_bean_prefix'];
+        $this->namingBaseBeanSuffix = $connectionParams['naming']['base_bean_suffix'];
+        $this->namingDaoPrefix = $connectionParams['naming']['dao_prefix'];
+        $this->namingDaoSuffix = $connectionParams['naming']['dao_suffix'];
+        $this->namingBaseDaoPrefix = $connectionParams['naming']['base_dao_prefix'];
+        $this->namingBaseDaoSuffix = $connectionParams['naming']['base_dao_suffix'];
+        $this->namingExceptions = $connectionParams['naming']['exceptions'];
+    }
+
+    public function getDaoNamespace(): string
+    {
+        return $this->daoNamespace;
+    }
+
+    public function getBeanNamespace(): string
+    {
+        return $this->beanNamespace;
+    }
+
+    public function getConnection(): string
+    {
+        return $this->connection;
+    }
+
+    public function getNamingBeanPrefix(): string
+    {
+        return $this->namingBeanPrefix;
+    }
+
+    public function getNamingBeanSuffix(): string
+    {
+        return $this->namingBeanSuffix;
+    }
+
+    public function getNamingBaseBeanPrefix(): string
+    {
+        return $this->namingBaseBeanPrefix;
+    }
+
+    public function getNamingBaseBeanSuffix(): string
+    {
+        return $this->namingBaseBeanSuffix;
+    }
+
+    public function getNamingDaoPrefix(): string
+    {
+        return $this->namingDaoPrefix;
+    }
+
+    public function getNamingDaoSuffix(): string
+    {
+        return $this->namingDaoSuffix;
+    }
+
+    public function getNamingBaseDaoPrefix(): string
+    {
+        return $this->namingBaseDaoPrefix;
+    }
+
+    public function getNamingBaseDaoSuffix(): string
+    {
+        return $this->namingBaseDaoSuffix;
+    }
+
+    /**
+     * @return array<string, string>
+     */
+    public function getNamingExceptions(): array
+    {
+        return $this->namingExceptions;
+    }
+}