fix deprecated method fetch()

synolia · Dec 20, 2023 · 5bfb811 · 5bfb811
1 parent b65f412
commit 5bfb811
Show file tree

Hide file tree

Showing 6 changed files with 6 additions and 6 deletions.
diff --git a/src/Task/AbstractProcessTask.php b/src/Task/AbstractProcessTask.php
@@ -133,7 +133,7 @@ protected function process(PipelinePayloadInterface $initialPayload): void
             /** @var Result $queryResult */
             $queryResult = $query->executeQuery();
 
-            while ($results = $queryResult->fetchAll()) {
+            while ($results = $queryResult->fetchAllAssociative()) {
                 $ids = [];
                 foreach ($results as $result) {
                     $ids[] = $result['id'];

diff --git a/src/Task/Asset/BatchAssetTask.php b/src/Task/Asset/BatchAssetTask.php
@@ -34,7 +34,7 @@ public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInte
         /** @var Result $queryResult */
         $queryResult = $query->executeQuery();
 
-        while ($results = $queryResult->fetchAll()) {
+        while ($results = $queryResult->fetchAllAssociative()) {
             foreach ($results as $result) {
                 try {
                     $resource = \json_decode($result['values'], true, 512, \JSON_THROW_ON_ERROR);

diff --git a/src/Task/AssociationType/BatchAssociationTypesTask.php b/src/Task/AssociationType/BatchAssociationTypesTask.php
@@ -55,7 +55,7 @@ public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInte
             /** @var Result $queryResult */
             $queryResult = $query->executeQuery();
 
-            while ($results = $queryResult->fetchAll()) {
+            while ($results = $queryResult->fetchAllAssociative()) {
                 foreach ($results as $result) {
                     /** @var array{code: string, labels: array} $resource */
                     $resource = json_decode($result['values'], true, 512, \JSON_THROW_ON_ERROR);

diff --git a/src/Task/Attribute/BatchAttributesTask.php b/src/Task/Attribute/BatchAttributesTask.php
@@ -64,7 +64,7 @@ public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInte
             $queryResult = $query->executeQuery();
 
             $variationAxes = array_unique($this->getVariationAxes($payload));
-            while ($results = $queryResult->fetchAll()) {
+            while ($results = $queryResult->fetchAllAssociative()) {
                 foreach ($results as $result) {
                     $resource = json_decode($result['values'], true, 512, \JSON_THROW_ON_ERROR);
 

diff --git a/src/Task/Product/BatchProductsTask.php b/src/Task/Product/BatchProductsTask.php
@@ -33,7 +33,7 @@ public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInte
         /** @var Result $queryResult */
         $queryResult = $query->executeQuery();
 
-        while ($results = $queryResult->fetchAll()) {
+        while ($results = $queryResult->fetchAllAssociative()) {
             foreach ($results as $result) {
                 try {
                     /** @var array{identifier: string,parent: string|null} $resource */

diff --git a/src/Task/ProductModel/BatchProductModelTask.php b/src/Task/ProductModel/BatchProductModelTask.php
@@ -60,7 +60,7 @@ public function __invoke(PipelinePayloadInterface $payload): PipelinePayloadInte
         /** @var Result $queryResult */
         $queryResult = $query->executeQuery();
 
-        while ($results = $queryResult->fetchAll()) {
+        while ($results = $queryResult->fetchAllAssociative()) {
             foreach ($results as $result) {
                 /** @var array $resource */
                 $resource = json_decode($result['values'], true);