Skip to content

Commit 42f5e38

Browse files
authored
ddl: fix DST times for adding index (#47425) (#47448)
ref #46033, close #47426
1 parent c82570c commit 42f5e38

File tree

4 files changed

+10
-7
lines changed

4 files changed

+10
-7
lines changed

ddl/db_test.go

Lines changed: 5 additions & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -139,12 +139,12 @@ func TestGetTimeZone(t *testing.T) {
139139
offset int
140140
err string
141141
}{
142-
{"set time_zone = '+00:00'", "", "UTC", 0, ""},
143-
{"set time_zone = '-00:00'", "", "UTC", 0, ""},
142+
{"set time_zone = '+00:00'", "", "", 0, ""},
143+
{"set time_zone = '-00:00'", "", "", 0, ""},
144144
{"set time_zone = 'UTC'", "UTC", "UTC", 0, ""},
145-
{"set time_zone = '+05:00'", "", "UTC", 18000, ""},
146-
{"set time_zone = '-08:00'", "", "UTC", -28800, ""},
147-
{"set time_zone = '+08:00'", "", "UTC", 28800, ""},
145+
{"set time_zone = '+05:00'", "", "", 18000, ""},
146+
{"set time_zone = '-08:00'", "", "", -28800, ""},
147+
{"set time_zone = '+08:00'", "", "", 28800, ""},
148148
{"set time_zone = 'Asia/Shanghai'", "Asia/Shanghai", "Asia/Shanghai", 0, ""},
149149
{"set time_zone = 'SYSTEM'", "Asia/Shanghai", "Asia/Shanghai", 0, ""},
150150
{"set time_zone = DEFAULT", "Asia/Shanghai", "Asia/Shanghai", 0, ""},

ddl/index_cop.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -482,7 +482,7 @@ func getRestoreData(tblInfo *model.TableInfo, targetIdx, pkIdx *model.IndexInfo,
482482

483483
func buildDAGPB(sCtx sessionctx.Context, tblInfo *model.TableInfo, colInfos []*model.ColumnInfo) (*tipb.DAGRequest, error) {
484484
dagReq := &tipb.DAGRequest{}
485-
_, dagReq.TimeZoneOffset = timeutil.Zone(sCtx.GetSessionVars().Location())
485+
dagReq.TimeZoneName, dagReq.TimeZoneOffset = timeutil.Zone(sCtx.GetSessionVars().Location())
486486
sc := sCtx.GetSessionVars().StmtCtx
487487
dagReq.Flags = sc.PushDownFlags()
488488
for i := range colInfos {

ddl/ingest/integration_test.go

Lines changed: 3 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -199,12 +199,15 @@ func TestAddIndexIngestTimezone(t *testing.T) {
199199
tk.MustExec("SET time_zone = '-06:00';")
200200
tk.MustExec("create table t (`src` varchar(48),`t` timestamp,`timezone` varchar(100));")
201201
tk.MustExec("insert into t values('2000-07-29 23:15:30','2000-07-29 23:15:30','-6:00');")
202+
// Test Daylight time.
203+
tk.MustExec("insert into t values('1991-07-21 00:00:00','1991-07-21 00:00:00','-6:00');")
202204
tk.MustExec("alter table t add index idx(t);")
203205
tk.MustExec("admin check table t;")
204206

205207
tk.MustExec("alter table t drop index idx;")
206208
tk.MustExec("SET time_zone = 'Asia/Shanghai';")
207209
tk.MustExec("insert into t values('2000-07-29 23:15:30','2000-07-29 23:15:30', '+8:00');")
210+
tk.MustExec("insert into t values('1991-07-21 00:00:00','1991-07-21 00:00:00','+8:00');")
208211
tk.MustExec("alter table t add index idx(t);")
209212
tk.MustExec("admin check table t;")
210213
}

ddl/util/util.go

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -230,7 +230,7 @@ func GetTimeZone(sctx sessionctx.Context) (string, int) {
230230
}
231231
}
232232
_, offset := time.Now().In(loc).Zone()
233-
return "UTC", offset
233+
return "", offset
234234
}
235235

236236
// enableEmulatorGC means whether to enable emulator GC. The default is enable.

0 commit comments

Comments
 (0)