Merge pull request #1156 from frankverhoeven/primary-read-replica-con…

…nection-connect
doctrine · Apr 30, 2021 · c925cd5 · c925cd5
2 parents 1c2780d + 5df115c
commit c925cd5
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 3 deletions.
diff --git a/lib/Doctrine/Migrations/Metadata/Storage/TableMetadataStorage.php b/lib/Doctrine/Migrations/Metadata/Storage/TableMetadataStorage.php
@@ -198,7 +198,7 @@ private function isInitialized(): bool
         }
 
         if ($this->connection instanceof PrimaryReadReplicaConnection) {
-            $this->connection->connect('master');
+            $this->connection->ensureConnectedToPrimary();
         }
 
         return $this->schemaManager->tablesExist([$this->configuration->getTableName()]);

diff --git a/tests/Doctrine/Migrations/Tests/Metadata/Storage/ExistingTableMetadataStorageTest.php b/tests/Doctrine/Migrations/Tests/Metadata/Storage/ExistingTableMetadataStorageTest.php
@@ -83,8 +83,7 @@ public function testPrimaryReadReplicaConnectionGetsConnected(): void
         $connection = $this->createMock(PrimaryReadReplicaConnection::class);
         $connection
             ->expects(self::atLeastOnce())
-            ->method('connect')
-            ->with('master');
+            ->method('ensureConnectedToPrimary');
 
         $connection
             ->expects(self::atLeastOnce())