Revert "fix(db): Set transaction isolation level for replica connections too"

ChristophWurst · ChristophWurst · commit b7353895ca6f · 2024-05-24T12:01:29.000+02:00
This reverts commit db0fa54.
diff --git a/lib/private/DB/SetTransactionIsolationLevel.php b/lib/private/DB/SetTransactionIsolationLevel.php
@@ -39,9 +39,11 @@ class SetTransactionIsolationLevel implements EventSubscriber {
 	 */
 	public function postConnect(ConnectionEventArgs $args) {
 		$connection = $args->getConnection();
-		$connection->setTransactionIsolation(TransactionIsolationLevel::READ_COMMITTED);
-		if ($connection->getDatabasePlatform() instanceof MySQLPlatform) {
-			$connection->executeStatement('SET SESSION AUTOCOMMIT=1');
+		if ($connection instanceof PrimaryReadReplicaConnection && $connection->isConnectedToPrimary()) {
+			$connection->setTransactionIsolation(TransactionIsolationLevel::READ_COMMITTED);
+			if ($connection->getDatabasePlatform() instanceof MySQLPlatform) {
+				$connection->executeStatement('SET SESSION AUTOCOMMIT=1');
+			}
 		}
 	}
 

Original file line number	Diff line number	Diff line change
`@@ -39,9 +39,11 @@ class SetTransactionIsolationLevel implements EventSubscriber {`
`39`	`39`	`*/`
`40`	`40`	`public function postConnect(ConnectionEventArgs $args) {`
`41`	`41`	`$connection = $args->getConnection();`
`42`		`- $connection->setTransactionIsolation(TransactionIsolationLevel::READ_COMMITTED);`
`43`		`- if ($connection->getDatabasePlatform() instanceof MySQLPlatform) {`
`44`		`- $connection->executeStatement('SET SESSION AUTOCOMMIT=1');`
	`42`	`+ if ($connection instanceof PrimaryReadReplicaConnection && $connection->isConnectedToPrimary()) {`
	`43`	`+ $connection->setTransactionIsolation(TransactionIsolationLevel::READ_COMMITTED);`
	`44`	`+ if ($connection->getDatabasePlatform() instanceof MySQLPlatform) {`
	`45`	`+ $connection->executeStatement('SET SESSION AUTOCOMMIT=1');`
	`46`	`+ }`
`45`	`47`	`}`
`46`	`48`	`}`
`47`	`49`