refactor: replace usage of removed db query builder method

Signed-off-by: Christoph Wurst <[email protected]>

Author: ChristophWurst

lib/Db/LoginAddressAggregatedMapper.php

@@ -53,7 +53,7 @@ public function hasSufficientIpV4Data(int $start): bool {
 				$qb->expr()->lte('first_seen', $qb->createNamedParameter($start))
 			));
 
-		$result = $query->execute();
+		$result = $query->executeQuery();
 		$count = (int)$result->fetchColumn();
 		$result->closeCursor();
 
@@ -111,7 +111,7 @@ public function hasSufficientIpV6Data(int $start) {
 				$qb->expr()->lte('first_seen', $qb->createNamedParameter($start))
 			));
 
-		$result = $query->execute();
+		$result = $query->executeQuery();
 		$count = (int)$result->fetchColumn();
 		$result->closeCursor();
 
@@ -123,7 +123,7 @@ public function getCount(): int {
 
 		$qb->select($qb->createFunction('COUNT(*)'))
 			->from($this->getTableName());
-		$result = $qb->execute();
+		$result = $qb->executeQuery();
 		$cnt = $result->fetchColumn();
 		$result->closeCursor();
 
@@ -135,7 +135,7 @@ public function getTotalCount(): int {
 
 		$qb->select($qb->createFunction('SUM(seen)'))
 			->from($this->getTableName());
-		$result = $qb->execute();
+		$result = $qb->executeQuery();
 		$cnt = $result->fetchColumn();
 		$result->closeCursor();
 

lib/Db/LoginAddressMapper.php

@@ -25,7 +25,7 @@ public function getCount(): int {
 
 		$qb->select($qb->createFunction('COUNT(*)'))
 			->from($this->getTableName());
-		$result = $qb->execute();
+		$result = $qb->executeQuery();
 		$cnt = $result->fetchColumn();
 		$result->closeCursor();
 

lib/Service/ETLService.php

@@ -38,7 +38,7 @@ private function getRaw(int $max, ?OutputInterface $output = null): Generator {
 			->setMaxResults(100);
 
 		do {
-			$data = $selectQuery->execute();
+			$data = $selectQuery->executeQuery();
 			$rows = $data->fetchAll();
 			foreach ($rows as $row) {
 				yield $row;
@@ -95,27 +95,27 @@ public function extractAndTransform(int $max = self::MAX_BATCH_SIZE, ?OutputInte
 			$select
 				->setParameter('uid', $row['uid'])
 				->setParameter('ip', $row['ip']);
-			$result = $select->execute();
+			$result = $select->executeQuery();
 			$existing = $result->fetch();
 			$result->closeCursor();
 			if (empty($existing)) {
 				$insert->setParameter('uid', $row['uid']);
 				$insert->setParameter('ip', $row['ip']);
 				$insert->setParameter('seen', 1, IQueryBuilder::PARAM_INT);
 				$insert->setParameter('ts', $row['created_at'], IQueryBuilder::PARAM_INT);
-				$insert->execute();
+				$insert->executeStatement();
 			} else {
 				$update
 					->setParameter('uid', $row['uid'])
 					->setParameter('ip', $row['ip'])
 					->setParameter('seen', $existing['seen'] + 1)
 					->setParameter('first_seen', min($existing['first_seen'], $row['created_at']))
 					->setParameter('last_seen', max($existing['last_seen'], $row['created_at']));
-				$update->execute();
+				$update->executeStatement();
 
 				$cleanUp
 					->setParameter('id', $row['id']);
-				$cleanUp->execute();
+				$cleanUp->executeStatement();
 			}
 		}
 		$this->logger->debug('finished login data ETL process, sending transaction commit');