fix for create table engine ReplicatedReplacingMergeTree

Nikolay Ermolovich · Nikolay Ermolovich · commit 16cb3137a3e6 · 2024-09-18T22:36:26.000+05:00
diff --git a/database/clickhouse/clickhouse.go b/database/clickhouse/clickhouse.go
@@ -248,8 +248,8 @@ func (ch *ClickHouse) ensureVersionTable() (err error) {
 			) Engine=%s`, ch.config.MigrationsTable, ch.config.MigrationsTableEngine)
 	}
 
-	if strings.HasSuffix(ch.config.MigrationsTableEngine, "Tree") {
-		query = fmt.Sprintf(`%s ORDER BY sequence`, query)
+	if strings.Contains(ch.config.MigrationsTableEngine, "Tree") {
+		query = fmt.Sprintf(`%s PRIMARY KEY sequence ORDER BY sequence`, query)
 	}
 
 	if _, err := ch.conn.Exec(query); err != nil {

Original file line number	Diff line number	Diff line change
`@@ -248,8 +248,8 @@ func (ch *ClickHouse) ensureVersionTable() (err error) {`
`248`	`248`	) Engine=%s`, ch.config.MigrationsTable, ch.config.MigrationsTableEngine)
`249`	`249`	`}`
`250`	`250`
`251`		`- if strings.HasSuffix(ch.config.MigrationsTableEngine, "Tree") {`
`252`		- query = fmt.Sprintf(`%s ORDER BY sequence`, query)
	`251`	`+ if strings.Contains(ch.config.MigrationsTableEngine, "Tree") {`
	`252`	+ query = fmt.Sprintf(`%s PRIMARY KEY sequence ORDER BY sequence`, query)
`253`	`253`	`}`
`254`	`254`
`255`	`255`	`if _, err := ch.conn.Exec(query); err != nil {`