From 68f714346bae756e3f4462bf0e3ecb826d31a5d5 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?Christian=20B=C3=BClter?= <christian.buelter@web.de>
Date: Fri, 19 Apr 2024 09:34:34 +0200
Subject: [PATCH] [TASK] Add BEGIN and COMMIT statements, see #222

Add statements needed to run ke_search in a
Percona-Database-Cluster with strict-mode.
---
 Classes/Indexer/IndexerRunner.php | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/Classes/Indexer/IndexerRunner.php b/Classes/Indexer/IndexerRunner.php
index 8feeedd7..5674d2e1 100644
--- a/Classes/Indexer/IndexerRunner.php
+++ b/Classes/Indexer/IndexerRunner.php
@@ -849,8 +849,10 @@ public function insertRecordIntoIndex($fieldValues)
             . $addQueryPartFor['execute'] . ';';
 
         try {
+            Db::getDatabaseConnection('tx_kesearch_index')->executeStatement('BEGIN;');
             Db::getDatabaseConnection('tx_kesearch_index')->executeStatement($queryArray['set']);
             Db::getDatabaseConnection('tx_kesearch_index')->executeStatement($queryArray['execute']);
+            Db::getDatabaseConnection('tx_kesearch_index')->executeStatement('COMMIT;');
         } catch (Exception $e) {
             $this->logger->error($e->getMessage());
         }
@@ -903,8 +905,10 @@ public function updateRecordInIndex($fieldValues)
             . ', @uid;';
 
         try {
+            Db::getDatabaseConnection('tx_kesearch_index')->executeStatement('BEGIN;');
             Db::getDatabaseConnection('tx_kesearch_index')->executeStatement($queryArray['set']);
             Db::getDatabaseConnection('tx_kesearch_index')->executeStatement($queryArray['execute']);
+            Db::getDatabaseConnection('tx_kesearch_index')->executeStatement('COMMIT;');
         } catch (Exception $e) {
             // @extensionScannerIgnoreLine
             $this->logger->error($e->getMessage());