[9.x] Fix flushdb on cluster (#45544)

* Fix flushdb on cluster * Removes usages of `executeCommandOnNodes` method Co-authored-by: Nuno Maduro <enunomaduro@gmail.com>
laravel · Jan 18, 2023 · af11be5 · af11be5
1 parent e4f05eb
commit af11be5
Showing 1 changed file with 8 additions and 3 deletions.
diff --git a/src/Illuminate/Redis/Connections/PredisClusterConnection.php b/src/Illuminate/Redis/Connections/PredisClusterConnection.php
@@ -2,6 +2,7 @@
 
 namespace Illuminate\Redis\Connections;
 
+use Predis\Command\Redis\FLUSHDB;
 use Predis\Command\ServerFlushDatabase;
 
 class PredisClusterConnection extends PredisConnection
@@ -13,8 +14,12 @@ class PredisClusterConnection extends PredisConnection
      */
     public function flushdb()
     {
-        $this->client->executeCommandOnNodes(
-            tap(new ServerFlushDatabase)->setArguments(func_get_args())
-        );
+        $command = class_exists(ServerFlushDatabase::class)
+            ? ServerFlushDatabase::class
+            : FLUSHDB::class;
+
+        foreach ($this->client as $node) {
+            $node->executeCommand(tap(new $command)->setArguments(func_get_args()));
+        }
     }
 }