Merge pull request #10 from coingaming/fix/migration-clickhouse-cloud

Fix/migration clickhouse cloud
coingaming · Aug 28, 2024 · 10be0cf · 10be0cf
2 parents 49270c8 + 664e204
commit 10be0cf
Show file tree

Hide file tree

Showing 2 changed files with 12 additions and 118 deletions.
diff --git a/lib/plausible/migration_utils.ex b/lib/plausible/migration_utils.ex
@@ -4,7 +4,7 @@ defmodule Plausible.MigrationUtils do
   """
 
   def on_cluster_statement(table) do
-    if(clustered_table?(table), do: "ON CLUSTER '{cluster}'", else: "")
+    if(clustered_table?(table), do: "ON CLUSTER '#{cluster_name()}'", else: "")
   end
 
   def clustered_table?(table) do
@@ -13,4 +13,14 @@ defmodule Plausible.MigrationUtils do
       {:ok, _} -> true
     end
   end
+
+  def cluster_name do
+    case Plausible.IngestRepo.query(
+           "SELECT cluster FROM system.clusters where cluster != 'default' limit 1;"
+         ) do
+      {:ok, %{rows: [[cluster]]}} -> cluster
+      {:ok, _} -> raise "No cluster defined."
+      {:error, _} -> raise "Cluster not found"
+    end
+  end
 end
diff --git a/priv/tracker/js/plausible.live-view.js b/priv/tracker/js/plausible.live-view.js