From 4616841c63e9ce8eafb9c7862e7f5f1563426d13 Mon Sep 17 00:00:00 2001
From: Adam Hegyi <ahegyi@gitlab.com>
Date: Mon, 22 Jan 2024 16:21:24 +0100
Subject: [PATCH] Use ALTER TABLE when deleting records form CH
---
.../click_house/event_paths_consistency_cron_worker.rb | 4 ++--
1 file changed, 2 insertions(+), 2 deletions(-)
diff --git a/app/workers/click_house/event_paths_consistency_cron_worker.rb b/app/workers/click_house/event_paths_consistency_cron_worker.rb
index 71a1fb0995fb..e115aa6b7e91 100644
--- a/app/workers/click_house/event_paths_consistency_cron_worker.rb
+++ b/app/workers/click_house/event_paths_consistency_cron_worker.rb
@@ -83,13 +83,13 @@ def delete_records_from_click_house(id_paths)
paths = id_paths.map(&:second).map { |value| "'#{value}'" }.join(',')
query = ClickHouse::Client::Query.new(
- raw_query: "DELETE FROM events WHERE path IN (#{paths})"
+ raw_query: "ALTER TABLE events DELETE WHERE path IN (#{paths})"
)
connection.execute(query)
query = ClickHouse::Client::Query.new(
- raw_query: 'DELETE FROM event_namespace_paths WHERE namespace_id IN ({namespace_ids:Array(UInt64)})',
+ raw_query: 'ALTER TABLE event_namespace_paths DELETE WHERE namespace_id IN ({namespace_ids:Array(UInt64)})',
placeholders: { namespace_ids: id_paths.map(&:first).to_json }
)
--
GitLab