table partition: enhance auto id for exchange partition with table #36663
Conversation
|
[REVIEW NOTIFICATION] This pull request has not been approved. To complete the pull request process, please ask the reviewers in the list to review by filling The full list of commands accepted by this bot can be found here. Reviewer can indicate their review by submitting an approval review. |
ti-chi-bot
added
release-note-none
size/M
Signed-off-by: Weizhen Wang <wangweizhen@pingcap.com>
|
Code Coverage Details: https://codecov.io/github/pingcap/tidb/commit/77938832b25f6fda9ce7e5385e88f40808509bb7 |
…lehorse/tidb into AutoID-For-Exchange-Partition
infoschema/builder.go
Outdated
| @@ -74,7 +75,7 @@ func (b *bundleInfoBuilder) SetDeltaUpdateBundles() { | |||
| b.deltaUpdate = true | |||
| } | |||
|
|
|||
| func (b *bundleInfoBuilder) deleteBundle(is *infoSchema, tblID int64) { | |||
| func (_ *bundleInfoBuilder) deleteBundle(is *infoSchema, tblID int64) { | |||
infoschema/builder.go
Outdated
| return err | ||
| } | ||
| // non-partition table auto IDs. | ||
| ntAutoIDs, err := m.GetAutoIDAccessors(ntSchemaID, ntID).Get() |
There was a problem hiding this comment.
What would happen in this case?
CREATE TABLE pt (a int unsigned auto_increment, b varchar(255)) PARTITION BY RANGE (a) (PARTITION p0 VALUES LESS THAN (1000000), partition p1M values less than (2000000));
create table t (a int unsigned auto_increment, b varchar(255));
insert into pt values (1, "1");
insert into t values (2, "2");
insert into t values (4000000, "4M");
delete from t where a = 4000000;
alter table pt exchange partition p0 with table t;
There was a problem hiding this comment.
I put it to the test，RowID is equal to 4005000.
ti-chi-bot
added
size/XL
| @@ -5,6 +5,7 @@ package restore_test | |||
| import ( | |||
| "context" | |||
| "encoding/json" | |||
| "github.com/pingcap/tidb/infoschema" | |||
There was a problem hiding this comment.
I think you can revert this file change?
| //tkCancel := testkit.NewTestKit(t, store) | ||
|
|
||
| tk.MustExec("set @@tidb_enable_exchange_partition=1") | ||
| defer tk.MustExec("set @@tidb_enable_exchange_partition=0") |
There was a problem hiding this comment.
I don't think this is necessary. I think this is a session scoped variable and the session will end after the test anyway?
| // why use tkCancel, not tk. | ||
| //tkCancel := testkit.NewTestKit(t, store) |
There was a problem hiding this comment.
| // why use tkCancel, not tk. | |
| //tkCancel := testkit.NewTestKit(t, store) |
| } | ||
| hook.OnJobUpdatedExported = hookFunc | ||
|
|
||
| //tk.MustExec(`create table nt1(a int);`) |
There was a problem hiding this comment.
| //tk.MustExec(`create table nt1(a int);`) |
|
|
||
| //tk.MustQuery("select * from pt partition(p0)").Check(testkit.Rows("1")) | ||
| //tk.MustExec("alter table pt exchange partition p0 with table nt") | ||
| //tkCancel.MustExec("insert into nt values (1)") | ||
| //tkCancel.MustExec("use test") | ||
| // tkCancel.MustExec("insert into pt values (2)") | ||
| // tkCancel.MustQuery("select * from pt partition(p0)").Check(testkit.Rows()) |
There was a problem hiding this comment.
| //tk.MustQuery("select * from pt partition(p0)").Check(testkit.Rows("1")) | |
| //tk.MustExec("alter table pt exchange partition p0 with table nt") | |
| //tkCancel.MustExec("insert into nt values (1)") | |
| //tkCancel.MustExec("use test") | |
| // tkCancel.MustExec("insert into pt values (2)") | |
| // tkCancel.MustQuery("select * from pt partition(p0)").Check(testkit.Rows()) |
What problem does this PR solve?
Issue Number: close #36661
Problem Summary:
What is changed and how it works?
Check List
Tests
Side effects
Documentation
Release note
Please refer to Release Notes Language Style Guide to write a quality release note.