From 4c1a2dd09b6af08891808a34d41ff38cfe29907d Mon Sep 17 00:00:00 2001
From: Adrian Gruntkowski <adrian.gruntkowski@gmail.com>
Date: Thu, 25 Jun 2026 10:30:13 +0200
Subject: [PATCH] Add migration renaming `recovery_id` CH columns to
 `replay_session_id`

---
 ...ename_recovery_id_to_replay_session_id.exs | 40 +++++++++++++++++++
 1 file changed, 40 insertions(+)
 create mode 100644 priv/ingest_repo/migrations/20260625082529_rename_recovery_id_to_replay_session_id.exs

diff --git a/priv/ingest_repo/migrations/20260625082529_rename_recovery_id_to_replay_session_id.exs b/priv/ingest_repo/migrations/20260625082529_rename_recovery_id_to_replay_session_id.exs
new file mode 100644
index 000000000000..fecf8375cd0e
--- /dev/null
+++ b/priv/ingest_repo/migrations/20260625082529_rename_recovery_id_to_replay_session_id.exs
@@ -0,0 +1,40 @@
+defmodule Plausible.IngestRepo.Migrations.RenameRecoveryIdToReplaySessionId do
+  use Ecto.Migration
+
+  import Plausible.MigrationUtils
+
+  @on_cluster_sessions on_cluster_statement("sessions_v2")
+  @on_cluster_events on_cluster_statement("events_v2")
+
+  def up do
+    if enterprise_edition?() do
+      execute """
+      ALTER TABLE sessions_v2
+      #{@on_cluster_sessions}
+      RENAME COLUMN IF EXISTS recovery_id TO replay_session_id
+      """
+
+      execute """
+      ALTER TABLE events_v2
+      #{@on_cluster_events}
+      RENAME COLUMN IF EXISTS recovery_id TO replay_session_id
+      """
+    end
+  end
+
+  def down do
+    if enterprise_edition?() do
+      execute """
+      ALTER TABLE sessions_v2
+      #{@on_cluster_sessions}
+      RENAME COLUMN IF EXISTS replay_session_id TO recovery_id
+      """
+
+      execute """
+      ALTER TABLE events_v2
+      #{@on_cluster_events}
+      RENAME COLUMN IF EXISTS replay_session_id TO recovery_id
+      """
+    end
+  end
+end