From 7ce31f437a39bacc785a97c66d733f7bd997d1b0 Mon Sep 17 00:00:00 2001 From: Qu Xuan Date: Wed, 7 May 2025 19:54:47 +0800 Subject: [PATCH] fix: clickhouse table --- backends/clickhouse/clickhouse.go | 12 ++++++------ 1 file changed, 6 insertions(+), 6 deletions(-) diff --git a/backends/clickhouse/clickhouse.go b/backends/clickhouse/clickhouse.go index 66599d7..4195d54 100644 --- a/backends/clickhouse/clickhouse.go +++ b/backends/clickhouse/clickhouse.go @@ -123,17 +123,17 @@ func (click *SClickhouseBackend) GetCreateSQLs(ts sqlchemy.ITableSpec) []string var ttlCol IClickhouseColumnSpec for _, c := range ts.Columns() { cols = append(cols, c.DefinitionString()) + if c.IsPrimary() { + primaries = append(primaries, fmt.Sprintf("`%s`", c.Name())) + } if cc, ok := c.(IClickhouseColumnSpec); ok { + if cc.IsOrderBy() { + orderbys = append(orderbys, fmt.Sprintf("`%s`", c.Name())) + } partition := cc.PartitionBy() if len(partition) > 0 && !utils.IsInStringArray(partition, partitions) { partitions = append(partitions, partition) } - if c.IsPrimary() && len(partition) == 0 { - primaries = append(primaries, fmt.Sprintf("`%s`", c.Name())) - } - if cc.IsOrderBy() && len(partition) == 0 { - orderbys = append(orderbys, fmt.Sprintf("`%s`", c.Name())) - } ttlC, ttlU := cc.GetTTL() if ttlC > 0 && len(ttlU) > 0 { ttlCol = cc