update

pipelane · Mar 4, 2025 · b43f421 · b43f421
1 parent ffd0294
commit b43f421
Show file tree

Hide file tree

Showing 2 changed files with 5 additions and 2 deletions.
diff --git 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
@@ -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(