Ensure that the post update doesn't end prematurely (#5684)

[friendica.git] / src / Database / PostUpdate.php

diff --git a/src/Database/PostUpdate.php b/src/Database/PostUpdate.php
index 09e940b149d1ae9f45e92b4bd9e12b49aba11327..674fe05531c6d128f69c75fb80c42bd70d36d12b 100644 (file)
--- a/src/Database/PostUpdate.php
+++ b/src/Database/PostUpdate.php
@@ -253,6 +253,12 @@ class PostUpdate
                $condition = ["`id` > ?", $id];
                $params = ['order' => ['id'], 'limit' => 10000];
                $items = Item::select($fields, $condition, $params);
+
+               if (DBA::errorNo() != 0) {
+                       logger('Database error ' . DBA::errorNo() . ':' . DBA::errorMessage());
+                       return false;
+               }
+
                while ($item = Item::fetch($items)) {
                        $id = $item['id'];
 
@@ -394,6 +400,12 @@ class PostUpdate
                $condition = ["`id` > ?", $id];
                $params = ['order' => ['id'], 'limit' => 10000];
                $items = DBA::select('item', $fields, $condition, $params);
+
+               if (DBA::errorNo() != 0) {
+                       logger('Database error ' . DBA::errorNo() . ':' . DBA::errorMessage());
+                       return false;
+               }
+
                while ($item = DBA::fetch($items)) {
                        $id = $item['id'];