From be4351bd2770b668ffcb5949cd5ee1a291d53b7a Mon Sep 17 00:00:00 2001 From: raoptimus Date: Tue, 3 Dec 2024 16:18:52 +0300 Subject: [PATCH] adding experimental replicated function to clickhouse #40 --- internal/migrator/db_service_integration_test.go | 12 ++++++++---- 1 file changed, 8 insertions(+), 4 deletions(-) diff --git a/internal/migrator/db_service_integration_test.go b/internal/migrator/db_service_integration_test.go index 5d26bc3..a40c710 100644 --- a/internal/migrator/db_service_integration_test.go +++ b/internal/migrator/db_service_integration_test.go @@ -30,7 +30,8 @@ func TestIntegrationDBService_UpDown_Successfully(t *testing.T) { options *Options }{ { - name: "postgres", + name: "postgres", + selectQuery: "select * from test", options: &Options{ DSN: os.Getenv("POSTGRES_DSN"), Directory: migrationsPathAbs(os.Getenv("POSTGRES_MIGRATIONS_PATH")), @@ -40,7 +41,8 @@ func TestIntegrationDBService_UpDown_Successfully(t *testing.T) { }, }, { - name: "mysql", + name: "mysql", + selectQuery: "select * from test", options: &Options{ DSN: os.Getenv("MYSQL_DSN"), Directory: migrationsPathAbs(os.Getenv("MYSQL_MIGRATIONS_PATH")), @@ -50,7 +52,8 @@ func TestIntegrationDBService_UpDown_Successfully(t *testing.T) { }, }, { - name: "clickhouse", + name: "clickhouse", + selectQuery: "select * from test", options: &Options{ DSN: os.Getenv("CLICKHOUSE_DSN"), Directory: migrationsPathAbs(os.Getenv("CLICKHOUSE_MIGRATIONS_PATH")), @@ -60,7 +63,8 @@ func TestIntegrationDBService_UpDown_Successfully(t *testing.T) { }, }, { - name: "clickhouse_cluster", + name: "clickhouse_cluster", + selectQuery: "select * from raw.test", options: &Options{ DSN: os.Getenv("CLICKHOUSE_CLUSTER_DSN"), Directory: migrationsPathAbs(os.Getenv("CLICKHOUSE_CLUSTER_MIGRATIONS_PATH")),