diff --git a/mod/msearch.php b/mod/msearch.php
index b02a036ae4..14dfd1ef7c 100644
--- a/mod/msearch.php
+++ b/mod/msearch.php
@@ -68,7 +68,7 @@ function msearch_post(App $a)
 		$perpage
 	);
 
-	while($search_result = DBA::fetch($search_stmt)) {
+	while ($search_result = DBA::fetch($search_stmt)) {
 		$results[] = [
 			'name'  => $search_result['name'],
 			'url'   => DI::baseUrl() . '/profile/' . $search_result['nickname'],
@@ -77,6 +77,8 @@ function msearch_post(App $a)
 		];
 	}
 
+	DBA::close($search_stmt);
+
 	$output = ['total' => $total, 'items_page' => $perpage, 'page' => $page, 'results' => $results];
 
 	echo json_encode($output);
diff --git a/src/Core/Worker.php b/src/Core/Worker.php
index 6fb8bd40ff..24febf3bc4 100644
--- a/src/Core/Worker.php
+++ b/src/Core/Worker.php
@@ -614,6 +614,7 @@ class Worker
 				}
 			}
 		}
+		DBA::close($entries);
 	}
 
 	/**
diff --git a/src/Model/Contact.php b/src/Model/Contact.php
index 2435b54f9c..becc80c0c3 100644
--- a/src/Model/Contact.php
+++ b/src/Model/Contact.php
@@ -2057,6 +2057,7 @@ class Contact
 
 			Worker::add(PRIORITY_HIGH, 'MergeContact', $first, $duplicate['id'], $uid);
 		}
+		DBA::close($duplicates);
 		Logger::info('Duplicates handled', ['uid' => $uid, 'nurl' => $nurl]);
 		return true;
 	}
@@ -2732,6 +2733,7 @@ class Contact
 				);
 			}
 		}
+		DBA::close($contacts);
 	}
 
 	/**
diff --git a/src/Model/GContact.php b/src/Model/GContact.php
index 553976296f..becfd61b08 100644
--- a/src/Model/GContact.php
+++ b/src/Model/GContact.php
@@ -113,6 +113,7 @@ class GContact
 
 			$gcontacts[] = Contact::getDetailsByURL($result['nurl'], local_user());
 		}
+		DBA::close($results);
 		return $gcontacts;
 	}
 
@@ -563,6 +564,7 @@ class GContact
 				PortableContact::loadWorker(0, 0, 0, $base);
 			}
 		}
+		DBA::close($contacts);
 	}
 
 	/**
diff --git a/src/Model/Process.php b/src/Model/Process.php
index 2652929681..18b5f785a1 100644
--- a/src/Model/Process.php
+++ b/src/Model/Process.php
@@ -85,7 +85,7 @@ class Process
 				self::deleteByPid($process['pid']);
 			}
 		}
-
+		DBA::close($processes);
 		DBA::commit();
 	}
 }
diff --git a/src/Model/Search.php b/src/Model/Search.php
index 9e00bbe308..ca8960ef35 100644
--- a/src/Model/Search.php
+++ b/src/Model/Search.php
@@ -44,7 +44,7 @@ class Search
 		while ($term = DBA::fetch($termsStmt)) {
 			$tags[] = trim($term['term'], '#');
 		}
-
+		DBA::close($termsStmt);
 		return $tags;
 	}
 }
diff --git a/src/Model/User.php b/src/Model/User.php
index be71bcf645..89574e7609 100644
--- a/src/Model/User.php
+++ b/src/Model/User.php
@@ -1298,6 +1298,7 @@ class User
 				$statistics['active_users_monthly']++;
 			}
 		}
+		DBA::close($userStmt);
 
 		return $statistics;
 	}
diff --git a/src/Model/UserItem.php b/src/Model/UserItem.php
index 6a228c098a..72db1005d1 100644
--- a/src/Model/UserItem.php
+++ b/src/Model/UserItem.php
@@ -214,6 +214,7 @@ class UserItem
 				return true;
 			}
 		}
+		DBA::close($tags);
 
 		return false;
 	}
diff --git a/src/Module/Admin/DBSync.php b/src/Module/Admin/DBSync.php
index 8892c29691..dd7febcc59 100644
--- a/src/Module/Admin/DBSync.php
+++ b/src/Module/Admin/DBSync.php
@@ -102,6 +102,7 @@ class DBSync extends BaseAdmin
 				$failed[] = $upd;
 			}
 		}
+		DBA::close($configStmt);
 
 		if (!count($failed)) {
 			$o = Renderer::replaceMacros(Renderer::getMarkupTemplate('admin/dbsync/structure_check.tpl'), [
diff --git a/src/Module/Admin/Site.php b/src/Module/Admin/Site.php
index cf3fee31b1..f3086856b3 100644
--- a/src/Module/Admin/Site.php
+++ b/src/Module/Admin/Site.php
@@ -121,6 +121,7 @@ class Site extends BaseAdmin
 			while ($user = DBA::fetch($usersStmt)) {
 				Worker::add(PRIORITY_HIGH, 'Notifier', Delivery::RELOCATION, $user['uid']);
 			}
+			DBA::close($usersStmt);
 
 			info("Relocation started. Could take a while to complete.");
 
diff --git a/src/Module/Settings/Delegation.php b/src/Module/Settings/Delegation.php
index e70dee8908..e590d6ea77 100644
--- a/src/Module/Settings/Delegation.php
+++ b/src/Module/Settings/Delegation.php
@@ -125,6 +125,7 @@ class Delegation extends BaseSettings
 		while ($contact = DBA::fetch($contacts)) {
 			$nicknames[] = $contact['nick'];
 		}
+		DBA::close($contacts);
 
 		// get user records for all potential page delegates who are not already delegates or managers
 		$potentialDelegateUsers = DBA::selectToArray('user', ['uid', 'username', 'nickname'], ['nickname' => $nicknames]);
diff --git a/src/Protocol/ActivityPub/Transmitter.php b/src/Protocol/ActivityPub/Transmitter.php
index 0e5056dbe5..8928b9435a 100644
--- a/src/Protocol/ActivityPub/Transmitter.php
+++ b/src/Protocol/ActivityPub/Transmitter.php
@@ -96,6 +96,7 @@ class Transmitter
 			while ($contact = DBA::fetch($contacts)) {
 				$list[] = $contact['url'];
 			}
+			DBA::close($contacts);
 
 			if (!empty($list)) {
 				$data['next'] = DI::baseUrl() . '/followers/' . $owner['nickname'] . '?page=' . ($page + 1);
@@ -145,6 +146,7 @@ class Transmitter
 			while ($contact = DBA::fetch($contacts)) {
 				$list[] = $contact['url'];
 			}
+			DBA::close($contacts);
 
 			if (!empty($list)) {
 				$data['next'] = DI::baseUrl() . '/following/' . $owner['nickname'] . '?page=' . ($page + 1);
diff --git a/src/Protocol/Diaspora.php b/src/Protocol/Diaspora.php
index 7c4e19d923..6282295011 100644
--- a/src/Protocol/Diaspora.php
+++ b/src/Protocol/Diaspora.php
@@ -124,6 +124,7 @@ class Diaspora
 			while ($server = DBA::fetch($servers)) {
 				$serverlist[$server['url']] = $server['url'];
 			}
+			DBA::close($servers);
 
 			// All tags of the current post
 			$condition = ['otype' => Term::OBJECT_TYPE_POST, 'type' => Term::HASHTAG, 'oid' => $parent['parent']];
@@ -132,6 +133,7 @@ class Diaspora
 			while ($tag = DBA::fetch($tags)) {
 				$taglist[] = $tag['term'];
 			}
+			DBA::close($tags);
 
 			// All servers who wants content with this tag
 			$tagserverlist = [];
@@ -140,6 +142,7 @@ class Diaspora
 				while ($server = DBA::fetch($tagserver)) {
 					$tagserverlist[] = $server['gserver-id'];
 				}
+				DBA::close($tagserver);
 			}
 
 			// All adresses with the given id
@@ -148,6 +151,7 @@ class Diaspora
 				while ($server = DBA::fetch($servers)) {
 					$serverlist[$server['url']] = $server['url'];
 				}
+				DBA::close($servers);
 			}
 		}
 
@@ -1720,6 +1724,7 @@ class Diaspora
 		while ($contact = DBA::fetch($contacts)) {
 			Contact::remove($contact["id"]);
 		}
+		DBA::close($contacts);
 
 		DBA::delete('gcontact', ['addr' => $author]);
 
diff --git a/src/Worker/CronJobs.php b/src/Worker/CronJobs.php
index 2a6c97e842..319a369d1f 100644
--- a/src/Worker/CronJobs.php
+++ b/src/Worker/CronJobs.php
@@ -128,6 +128,7 @@ class CronJobs
 		while ($user = DBA::fetch($users)) {
 			User::remove($user['uid']);
 		}
+		DBA::close($users);
 
 		// delete user records for recently removed accounts
 		$users = DBA::select('user', ['uid'], ["`account_removed` AND `account_expires_on` < UTC_TIMESTAMP() "]);
@@ -140,6 +141,7 @@ class CronJobs
 
 			DBA::delete('user', ['uid' => $user['uid']]);
 		}
+		DBA::close($users);
 	}
 
 	/**
diff --git a/src/Worker/UpdateGContacts.php b/src/Worker/UpdateGContacts.php
index 80c0ef524e..9d9519241b 100644
--- a/src/Worker/UpdateGContacts.php
+++ b/src/Worker/UpdateGContacts.php
@@ -96,5 +96,6 @@ class UpdateGContacts
 				return;
 			}
 		}
+		DBA::close($contacts);
 	}
 }
diff --git a/src/Worker/UpdateGServers.php b/src/Worker/UpdateGServers.php
index 2200d02e92..5a45138462 100644
--- a/src/Worker/UpdateGServers.php
+++ b/src/Worker/UpdateGServers.php
@@ -52,5 +52,6 @@ class UpdateGServers
 				return;
 			}
 		}
+		DBA::close($gservers);
 	}
 }