[TASK] Add BEGIN and COMMIT statements, see #222

Add statements needed to run ke_search in a Percona-Database-Cluster with strict-mode.
tpwd · Apr 19, 2024 · 68f7143 · 68f7143
1 parent 039e0b9
commit 68f7143
Showing 1 changed file with 4 additions and 0 deletions.
diff --git 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());