Skip to content

Commit 6ad91f6

Browse files
authored
fix(mc2mc): use lowercase timestamp (#81)
fix: use lowercase timstamp
1 parent 91e6069 commit 6ad91f6

File tree

1 file changed

+6
-6
lines changed

1 file changed

+6
-6
lines changed

mc2mc/mc2mc.go

Lines changed: 6 additions & 6 deletions
Original file line numberDiff line numberDiff line change
@@ -76,8 +76,8 @@ func mc2mc(envs []string) error {
7676
query.WithQuery(string(raw)),
7777
query.WithMethod(query.APPEND),
7878
query.WithDestination(cfg.DestinationTableID),
79-
query.WithOverridedValue("_partitiontime", fmt.Sprintf("TIMESTAMP('%s')", dstart)),
80-
query.WithOverridedValue("_partitiondate", fmt.Sprintf("DATE(TIMESTAMP('%s'))", dstart)),
79+
query.WithOverridedValue("_partitiontime", fmt.Sprintf("timestamp('%s')", dstart)),
80+
query.WithOverridedValue("_partitiondate", fmt.Sprintf("DATE(timestamp('%s'))", dstart)),
8181
query.WithAutoPartition(cfg.DevEnableAutoPartition == "true"),
8282
query.WithPartitionValue(cfg.DevEnablePartitionValue == "true"),
8383
query.WithColumnOrder(),
@@ -103,8 +103,8 @@ func mc2mc(envs []string) error {
103103
if cfg.DisableMultiQueryGeneration {
104104
queryToExecute, err := queryBuilder.SetOptions(
105105
query.WithQuery(string(raw)),
106-
query.WithOverridedValue("_partitiontime", fmt.Sprintf("TIMESTAMP('%s')", dstart)),
107-
query.WithOverridedValue("_partitiondate", fmt.Sprintf("DATE(TIMESTAMP('%s'))", dstart)),
106+
query.WithOverridedValue("_partitiontime", fmt.Sprintf("timestamp('%s')", dstart)),
107+
query.WithOverridedValue("_partitiondate", fmt.Sprintf("DATE(timestamp('%s'))", dstart)),
108108
).Build()
109109
if err != nil {
110110
return errors.WithStack(err)
@@ -135,8 +135,8 @@ func mc2mc(envs []string) error {
135135
currentQueryBuilder := queryBuilder
136136
queryToExecute, err := currentQueryBuilder.SetOptions(
137137
query.WithQuery(currentQueryToExecute),
138-
query.WithOverridedValue("_partitiontime", fmt.Sprintf("TIMESTAMP('%s')", dates[i])),
139-
query.WithOverridedValue("_partitiondate", fmt.Sprintf("DATE(TIMESTAMP('%s'))", dates[i])),
138+
query.WithOverridedValue("_partitiontime", fmt.Sprintf("timestamp('%s')", dates[i])),
139+
query.WithOverridedValue("_partitiondate", fmt.Sprintf("DATE(timestamp('%s'))", dates[i])),
140140
).Build()
141141
if err != nil {
142142
return errors.WithStack(err)

0 commit comments

Comments
 (0)