From 481cd6acf7e46673b7d141246387d1c874a36d38 Mon Sep 17 00:00:00 2001
From: Carl Schwan <carlschwan@kde.org>
Date: Thu, 22 Jan 2026 17:08:57 +0100
Subject: [PATCH] fix(Propagator): rollback transaction if it fails

Signed-off-by: Carl Schwan <carlschwan@kde.org>
---
 lib/private/Files/Cache/Propagator.php | 55 ++++++++++++++------------
 1 file changed, 30 insertions(+), 25 deletions(-)

diff --git a/lib/private/Files/Cache/Propagator.php b/lib/private/Files/Cache/Propagator.php
index a6ba87896f4de..065bb3cd67173 100644
--- a/lib/private/Files/Cache/Propagator.php
+++ b/lib/private/Files/Cache/Propagator.php
@@ -184,40 +184,45 @@ public function commitBatch() {
 		}
 		$this->inBatch = false;
 
-		$this->connection->beginTransaction();
+		try {
+			$this->connection->beginTransaction();
 
-		$query = $this->connection->getQueryBuilder();
-		$storageId = (int)$this->storage->getStorageCache()->getNumericId();
+			$query = $this->connection->getQueryBuilder();
+			$storageId = (int)$this->storage->getStorageCache()->getNumericId();
 
-		$query->update('filecache')
-			->set('mtime', $query->func()->greatest('mtime', $query->createParameter('time')))
-			->set('etag', $query->expr()->literal(uniqid()))
-			->where($query->expr()->eq('storage', $query->createNamedParameter($storageId, IQueryBuilder::PARAM_INT)))
-			->andWhere($query->expr()->eq('path_hash', $query->createParameter('hash')));
+			$query->update('filecache')
+				->set('mtime', $query->func()->greatest('mtime', $query->createParameter('time')))
+				->set('etag', $query->expr()->literal(uniqid()))
+				->where($query->expr()->eq('storage', $query->createNamedParameter($storageId, IQueryBuilder::PARAM_INT)))
+				->andWhere($query->expr()->eq('path_hash', $query->createParameter('hash')));
 
-		$sizeQuery = $this->connection->getQueryBuilder();
-		$sizeQuery->update('filecache')
-			->set('size', $sizeQuery->func()->add('size', $sizeQuery->createParameter('size')))
-			->where($query->expr()->eq('storage', $sizeQuery->createNamedParameter($storageId, IQueryBuilder::PARAM_INT)))
-			->andWhere($query->expr()->eq('path_hash', $sizeQuery->createParameter('hash')))
-			->andWhere($sizeQuery->expr()->gt('size', $sizeQuery->createNamedParameter(-1, IQueryBuilder::PARAM_INT)));
+			$sizeQuery = $this->connection->getQueryBuilder();
+			$sizeQuery->update('filecache')
+				->set('size', $sizeQuery->func()->add('size', $sizeQuery->createParameter('size')))
+				->where($query->expr()->eq('storage', $sizeQuery->createNamedParameter($storageId, IQueryBuilder::PARAM_INT)))
+				->andWhere($query->expr()->eq('path_hash', $sizeQuery->createParameter('hash')))
+				->andWhere($sizeQuery->expr()->gt('size', $sizeQuery->createNamedParameter(-1, IQueryBuilder::PARAM_INT)));
 
-		foreach ($this->batch as $item) {
-			$query->setParameter('time', $item['time'], IQueryBuilder::PARAM_INT);
-			$query->setParameter('hash', $item['hash']);
+			foreach ($this->batch as $item) {
+				$query->setParameter('time', $item['time'], IQueryBuilder::PARAM_INT);
+				$query->setParameter('hash', $item['hash']);
 
-			$query->executeStatement();
+				$query->executeStatement();
 
-			if ($item['size']) {
-				$sizeQuery->setParameter('size', $item['size'], IQueryBuilder::PARAM_INT);
-				$sizeQuery->setParameter('hash', $item['hash']);
+				if ($item['size']) {
+					$sizeQuery->setParameter('size', $item['size'], IQueryBuilder::PARAM_INT);
+					$sizeQuery->setParameter('hash', $item['hash']);
 
-				$sizeQuery->executeStatement();
+					$sizeQuery->executeStatement();
+				}
 			}
-		}
 
-		$this->batch = [];
+			$this->batch = [];
 
-		$this->connection->commit();
+			$this->connection->commit();
+		} catch (\Exception $e) {
+			$this->connection->rollback();
+			throw $e;
+		}
 	}
 }