Merge branch 'master' into unsigned-order-by-part-table

DEPS.bzl

@@ -3527,16 +3527,16 @@ def go_deps():
         name = "com_github_tiancaiamao_gp",
         build_file_proto_mode = "disable",
         importpath = "github.com/tiancaiamao/gp",
-        sum = "h1:4RNtqw1/tW67qP9fFgfQpTVd7DrfkaAWu4vsC18QmBo=",
-        version = "v0.0.0-20221221095600-1a473d1f9b4b",
+        sum = "h1:J/YdBZ46WKpXsxsW93SG+q0F8KI+yFrcIDT4c/RNoc4=",
+        version = "v0.0.0-20221230034425-4025bc8a4d4a",
     )
 
     go_repository(
         name = "com_github_tikv_client_go_v2",
         build_file_proto_mode = "disable_global",
         importpath = "github.com/tikv/client-go/v2",
-        sum = "h1:m6glgBGCIds9QURbk8Mn+8mjLKDcv6nWrNwYh92fydQ=",
-        version = "v2.0.4-0.20221226080148-018c59dbd837",
+        sum = "h1:cPtMXTExqjzk8L40qhrgB/mXiBXKP5LRU0vwjtI2Xxo=",
+        version = "v2.0.4",
     )
     go_repository(
         name = "com_github_tikv_pd_client",
@@ -4383,8 +4383,8 @@ def go_deps():
         name = "org_golang_x_crypto",
         build_file_proto_mode = "disable_global",
         importpath = "golang.org/x/crypto",
-        sum = "h1:MDRAIl0xIo9Io2xV565hzXHw3zVseKrJKodhohM5CjU=",
-        version = "v0.1.0",
+        sum = "h1:U/0M97KRkSFvyD/3FSmdP5W5swImpNgle/EHFhOsQPE=",
+        version = "v0.5.0",
     )
     go_repository(
         name = "org_golang_x_exp",
@@ -4433,8 +4433,8 @@ def go_deps():
         name = "org_golang_x_net",
         build_file_proto_mode = "disable_global",
         importpath = "golang.org/x/net",
-        sum = "h1:Q5QPcMlvfxFTAPV0+07Xz/MpK9NTXu2VDUuy0FeMfaU=",
-        version = "v0.4.0",
+        sum = "h1:GyT4nK/YDHSqa1c4753ouYCDajOYKTja9Xb/OHtgvSw=",
+        version = "v0.5.0",
     )
     go_repository(
         name = "org_golang_x_oauth2",
@@ -4454,22 +4454,22 @@ def go_deps():
         name = "org_golang_x_sys",
         build_file_proto_mode = "disable_global",
         importpath = "golang.org/x/sys",
-        sum = "h1:w8ZOecv6NaNa/zC8944JTU3vz4u6Lagfk4RPQxv92NQ=",
-        version = "v0.3.0",
+        sum = "h1:Zr2JFtRQNX3BCZ8YtxRE9hNJYC8J6I1MVbMg6owUp18=",
+        version = "v0.4.0",
     )
     go_repository(
         name = "org_golang_x_term",
         build_file_proto_mode = "disable_global",
         importpath = "golang.org/x/term",
-        sum = "h1:qoo4akIqOcDME5bhc/NgxUdovd6BSS2uMsVjB56q1xI=",
-        version = "v0.3.0",
+        sum = "h1:O7UWfv5+A2qiuulQk30kVinPoMtoIPeVaKLEgLpVkvg=",
+        version = "v0.4.0",
     )
     go_repository(
         name = "org_golang_x_text",
         build_file_proto_mode = "disable_global",
         importpath = "golang.org/x/text",
-        sum = "h1:OLmvp0KP+FVG99Ct/qFiL/Fhk4zp4QQnZ7b2U+5piUM=",
-        version = "v0.5.0",
+        sum = "h1:3XmdazWV+ubf7QgHSTWeykHOci5oeekaGJBLkrkaw4k=",
+        version = "v0.6.0",
     )
     go_repository(
         name = "org_golang_x_time",

README.md

@@ -44,12 +44,13 @@ See the [Get Started](https://pingcap.github.io/tidb-dev-guide/get-started/intro
 
 You can join the following groups or channels to discuss or ask questions about TiDB, and to keep yourself informed of the latest TiDB updates:
 
-- Discuss TiDB's implementation and design
-  - [TiDB Internals forum](https://internals.tidb.io/)
 - Seek help when you use TiDB
+  - [TiDB Forum](https://ask.pingcap.com/)
+  - [Chinese TiDB Forum](https://asktug.com)
   - Slack channels: [#everyone](https://slack.tidb.io/invite?team=tidb-community&channel=everyone&ref=pingcap-tidb) (English), [#tidb-japan](https://slack.tidb.io/invite?team=tidb-community&channel=tidb-japan&ref=github-tidb) (Japanese)
-  - [TiDB User Group forum](https://asktug.com) (Chinese)
   - [Stack Overflow](https://stackoverflow.com/questions/tagged/tidb) (questions tagged with #tidb)
+- Discuss TiDB's implementation and design
+  - [TiDB Internals forum](https://internals.tidb.io/)
 - Get the latest TiDB news or updates
     - Follow [@PingCAP](https://twitter.com/PingCAP) on Twitter
     - Read the PingCAP [English Blog](https://www.pingcap.com/blog/?from=en) or [Chinese Blog](https://cn.pingcap.com/blog/)

ddl/BUILD.bazel

@@ -71,6 +71,7 @@ go_library(
         "//parser",
         "//parser/ast",
         "//parser/charset",
+        "//parser/duration",
         "//parser/format",
         "//parser/model",
         "//parser/mysql",
@@ -179,6 +180,7 @@ go_test(
         "main_test.go",
         "modify_column_test.go",
         "multi_schema_change_test.go",
+        "mv_index_test.go",
         "options_test.go",
         "partition_test.go",
         "placement_policy_ddl_test.go",
@@ -221,6 +223,7 @@ go_test(
         "//parser/ast",
         "//parser/auth",
         "//parser/charset",
+        "//parser/duration",
         "//parser/model",
         "//parser/mysql",
         "//parser/terror",

ddl/column_modify_test.go

@@ -1029,78 +1029,3 @@ func TestColumnTypeChangeGenUniqueChangingName(t *testing.T) {
 
 	tk.MustExec("drop table if exists t")
 }
-
-func TestWriteReorgForColumnTypeChangeOnAmendTxn(t *testing.T) {
-	store, dom := testkit.CreateMockStoreAndDomainWithSchemaLease(t, columnModifyLease)
-
-	tk := testkit.NewTestKit(t, store)
-	tk.MustExec("set global tidb_enable_metadata_lock=0")
-	tk.MustExec("set global tidb_ddl_enable_fast_reorg = 0")
-	tk.MustExec("set global tidb_enable_amend_pessimistic_txn = ON")
-	defer tk.MustExec("set global tidb_enable_amend_pessimistic_txn = OFF")
-
-	d := dom.DDL()
-	testInsertOnModifyColumn := func(sql string, startColState, commitColState model.SchemaState, retStrs []string, retErr error) {
-		tk := testkit.NewTestKit(t, store)
-		tk.MustExec("use test")
-		tk.MustExec("drop table if exists t1")
-		tk.MustExec("create table t1 (c1 int, c2 int, c3 int, unique key(c1))")
-		tk.MustExec("insert into t1 values (20, 20, 20);")
-
-		var checkErr error
-		tk1 := testkit.NewTestKit(t, store)
-		defer func() {
-			if tk1.Session() != nil {
-				tk1.Session().Close()
-			}
-		}()
-		hook := &ddl.TestDDLCallback{Do: dom}
-		times := 0
-		hook.OnJobRunBeforeExported = func(job *model.Job) {
-			if job.Type != model.ActionModifyColumn || checkErr != nil || job.SchemaState != startColState {
-				return
-			}
-
-			tk1.MustExec("use test")
-			tk1.MustExec("begin pessimistic;")
-			tk1.MustExec("insert into t1 values(101, 102, 103)")
-		}
-		onJobUpdatedExportedFunc := func(job *model.Job) {
-			if job.Type != model.ActionModifyColumn || checkErr != nil || job.SchemaState != commitColState {
-				return
-			}
-			if times == 0 {
-				_, checkErr = tk1.Exec("commit;")
-			}
-			times++
-		}
-		hook.OnJobUpdatedExported.Store(&onJobUpdatedExportedFunc)
-		d.SetHook(hook)
-
-		tk.MustExec(sql)
-		if retErr == nil {
-			require.NoError(t, checkErr)
-		} else {
-			require.Error(t, checkErr)
-			require.Contains(t, checkErr.Error(), retErr.Error())
-		}
-		tk.MustQuery("select * from t1").Check(testkit.Rows(retStrs...))
-		tk.MustExec("admin check table t1")
-	}
-
-	// Testing it needs reorg data.
-	ddlStatement := "alter table t1 change column c2 cc smallint;"
-	testInsertOnModifyColumn(ddlStatement, model.StateNone, model.StateWriteReorganization, []string{"20 20 20"}, domain.ErrInfoSchemaChanged)
-	testInsertOnModifyColumn(ddlStatement, model.StateDeleteOnly, model.StateWriteReorganization, []string{"20 20 20"}, domain.ErrInfoSchemaChanged)
-	testInsertOnModifyColumn(ddlStatement, model.StateWriteOnly, model.StateWriteReorganization, []string{"20 20 20"}, domain.ErrInfoSchemaChanged)
-	testInsertOnModifyColumn(ddlStatement, model.StateNone, model.StatePublic, []string{"20 20 20"}, domain.ErrInfoSchemaChanged)
-	testInsertOnModifyColumn(ddlStatement, model.StateDeleteOnly, model.StatePublic, []string{"20 20 20"}, domain.ErrInfoSchemaChanged)
-	testInsertOnModifyColumn(ddlStatement, model.StateWriteOnly, model.StatePublic, []string{"20 20 20"}, domain.ErrInfoSchemaChanged)
-
-	// Testing it needs not reorg data. This case only have two states: none, public.
-	ddlStatement = "alter table t1 change column c2 cc bigint;"
-	testInsertOnModifyColumn(ddlStatement, model.StateNone, model.StateWriteReorganization, []string{"20 20 20"}, nil)
-	testInsertOnModifyColumn(ddlStatement, model.StateWriteOnly, model.StateWriteReorganization, []string{"20 20 20"}, nil)
-	testInsertOnModifyColumn(ddlStatement, model.StateNone, model.StatePublic, []string{"20 20 20", "101 102 103"}, nil)
-	testInsertOnModifyColumn(ddlStatement, model.StateWriteOnly, model.StatePublic, []string{"20 20 20"}, nil)
-}