clickhouse: Fixed get db version query

pressly · Feb 7, 2021 · f752f46 · f752f46
1 parent 7dd9c10
commit f752f46
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/dialect.go b/dialect.go
@@ -304,7 +304,7 @@ func (m ClickHouseDialect) createVersionTableSQL() string {
 }
 
 func (m ClickHouseDialect) dbVersionQuery(db *sql.DB) (*sql.Rows, error) {
-	rows, err := db.Query(fmt.Sprintf("SELECT version_id, is_applied FROM %s ORDER BY tstamp DESC LIMIT 1", TableName()))
+	rows, err := db.Query(fmt.Sprintf("SELECT version_id, is_applied FROM %s ORDER BY version_id DESC", TableName()))
 	if err != nil {
 		return nil, err
 	}