From b43f421c8497392e09a4aa8679027d5817b68297 Mon Sep 17 00:00:00 2001
From: Alexey Khokhlov <alexeyxo@gmail.com>
Date: Tue, 4 Mar 2025 17:41:07 +0300
Subject: [PATCH] update

---
 internal/migrator/clickhouse.go | 3 ++-
 internal/migrator/migration.go  | 4 +++-
 2 files changed, 5 insertions(+), 2 deletions(-)

diff --git a/internal/migrator/clickhouse.go b/internal/migrator/clickhouse.go
index aeae500..711cb1b 100644
--- a/internal/migrator/clickhouse.go
+++ b/internal/migrator/clickhouse.go
@@ -49,6 +49,7 @@ type ClickHouse struct {
 	conn     *sql.DB
 	config   *Config
 	isLocked atomic.Bool
+	engine   string
 }
 
 func (ch *ClickHouse) Open(dsn string) (database.Driver, error) {
@@ -76,7 +77,7 @@ func (ch *ClickHouse) Open(dsn string) (database.Driver, error) {
 		}
 	}
 
-	migrationsTableEngine := ch.config.MigrationsTableEngine
+	migrationsTableEngine := ch.engine
 	if s := purl.Query().Get("x-migrations-table-engine"); len(s) > 0 {
 		migrationsTableEngine = s
 	}
diff --git a/internal/migrator/migration.go b/internal/migrator/migration.go
index af6a0ae..c48d605 100644
--- a/internal/migrator/migration.go
+++ b/internal/migrator/migration.go
@@ -30,7 +30,9 @@ func NewMigrateClick(cfg migrations.Clickhouse) *Click {
 }
 
 func (m *Click) Run(migrationsDir string) error {
-	p := &ClickHouse{}
+	p := &ClickHouse{
+		engine: m.cfg.GetEngine(),
+	}
 	a := strings.Split(m.cfg.GetCredentials().Address, ":")
 	e := m.cfg.GetEngine()
 	addr := clickhouseConnectionString(