handle mysql master / slave connection

liuggio · Oct 9, 2020 · 4e7329c · 4e7329c
1 parent dd1814e
commit 4e7329c
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;
         }