handle mysql master / slave connection

liuggio · Oct 7, 2020 · e144592 · e144592
1 parent ea1f102
commit e144592
Showing 1 changed file with 14 additions and 0 deletions.
diff --git a/adapters/Doctrine/DBAL/ConnectionFactory.php b/adapters/Doctrine/DBAL/ConnectionFactory.php
@@ -44,6 +44,20 @@ public function createConnection(array $params, Configuration $config = null, Ev
                     $slave['path'] = str_replace('__DBNAME__', $dbName, $slave['path']);
                 }
             }
+        } elseif ('pdo_mysql' === $params['driver']) {
+            if (isset($params['dbname'])) {
+                $params['dbname'] = $this->getDbNameFromEnv($params['dbname']);
+            }
+
+            if (isset($params['master']['dbname'])) {
+                $params['master']['dbname'] = $this->getDbNameFromEnv($params['master']['dbname']);
+            }
+
+            if (!empty($params['slaves'])) {
+                foreach ($params['slaves'] as &$slave) {
+                    $slave['dbname'] = $this->getDbNameFromEnv($slave['dbname']);
+                }
+            }
         } else {
             $params['dbname'] = $dbName;
         }