- $rr = DBA::select($table, ['id', 'data', 'backend-class', 'backend-ref'], ['`backend-class` != ?', $dest]);
- if (DBA::isResult($rr)) {
- while($r = $rr->fetch()) {
- $id = $r['id'];
- $data = $r['data'];
- $backendClass = $r['backend-class'];
- $backendRef = $r['backend-ref'];
- if ($backendClass !== '') {
- $data = $backendClass::get($backendRef);
- }
- $ref = $dest::put($data);
-
- if ($ref !== '') {
- $ru = DBA::update($table, ['backend-class' => $dest, 'backend-ref' => $ref, 'data' => ''], ['id' => $id]);
- if ($ru) {
- if ($backendClass !== '') {
- $backendClass::delete($backendRef);
- }
- $moved++;
+ // Get the rows where backend class is not the destination backend class
+ $resources = DBA::select(
+ $table,
+ ['id', 'data', 'backend-class', 'backend-ref'],
+ ['`backend-class` IS NULL or `backend-class` != ?', $destination],
+ ['limit' => $limit]
+ );
+
+ while ($resource = DBA::fetch($resources)) {
+ $id = $resource['id'];
+ $data = $resource['data'];
+ /** @var IStorage $backendClass */
+ $backendClass = $resource['backend-class'];
+ $backendRef = $resource['backend-ref'];
+ if (!empty($backendClass)) {
+ Logger::log("get data from old backend " . $backendClass . " : " . $backendRef);
+ $data = $backendClass::get($backendRef);
+ }
+
+ Logger::log("save data to new backend " . $destination);
+ /** @var IStorage $destination */
+ $ref = $destination::put($data);
+ Logger::log("saved data as " . $ref);
+
+ if ($ref !== '') {
+ Logger::log("update row");
+ if (DBA::update($table, ['backend-class' => $destination, 'backend-ref' => $ref, 'data' => ''], ['id' => $id])) {
+ if (!empty($backendClass)) {
+ Logger::log("delete data from old backend " . $backendClass . " : " . $backendRef);
+ $backendClass::delete($backendRef);