Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

session: add physical table placement_policy in mysql schema #27054

Merged
merged 8 commits into from
Aug 13, 2021
Merged

session: add physical table placement_policy in mysql schema #27054

Changes from 1 commit
Commits
Show all changes
8 commits
Select commit Hold shift + click to select a range
830bc09
add physical table placement_policy in mysql schema
AilinKid Aug 10, 2021
db4e7e1
Update session/bootstrap.go
AilinKid Aug 10, 2021
11befc7
pass test
AilinKid Aug 10, 2021
f2b9b22
Merge branch 'master' into add-placement-policy
AilinKid Aug 10, 2021
ee806a0
Merge branch 'master' into add-placement-policy
AilinKid Aug 11, 2021
160bbb6
Merge branch 'master' into add-placement-policy
AilinKid Aug 12, 2021
79a4ded
Merge branch 'master' into add-placement-policy
AilinKid Aug 13, 2021
c6e4498
Merge branch 'master' into add-placement-policy
ti-chi-bot Aug 13, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Loading
Jump to
Jump to file
Failed to load files.
Loading
Diff view
Diff view
30 changes: 29 additions & 1 deletion session/bootstrap.go
View file
Open in desktop
Original file line number Diff line number Diff line change
Expand Up @@ -339,6 +339,22 @@ const (
WITH_GRANT_OPTION enum('N','Y') NOT NULL DEFAULT 'N',
PRIMARY KEY (USER,HOST,PRIV)
);`

// CreatePlacementPolicyTable store the placement policys.
CreatePlacementPolicyTable = `CREATE TABLE IF NOT EXISTS mysql.placement_policy (
AilinKid marked this conversation as resolved.
Show resolved Hide resolved
NAME varchar(255) NOT NULL,
AilinKid marked this conversation as resolved.
Show resolved Hide resolved
PRIMARY_REGION varchar(255) DEFAULT NULL,
REGIONS varchar(255) DEFAULT NULL,
LEADERS BIGINT UNSIGNED DEFAULT NULL,
FOLLOWERS BIGINT UNSIGNED DEFAULT NULL,
VOTERS BIGINT UNSIGNED DEFAULT NULL,
SCHEDULE varchar(255) DEFAULT NULL,
CONSTRAINTS varchar(255) DEFAULT NULL,
LEADER_CONSTRAINTS varchar(255) DEFAULT NULL,
FOLLOWER_CONSTRAINTS varchar(255) DEFAULT NULL,
VOTER_CONSTRAINTS varchar(255) DEFAULT NULL,
PRIMARY KEY (NAME)
);`
)

// bootstrap initiates system DB for a store.
Expand Down Expand Up @@ -498,11 +514,13 @@ const (
version71 = 71
// version72 adds snapshot column for mysql.stats_meta
version72 = 72
// version73 adds the placement policy for mysql.placement_meta
version73 = 73
)

// currentBootstrapVersion is defined as a variable, so we can modify its value for testing.
// please make sure this is the largest version
var currentBootstrapVersion int64 = version72
var currentBootstrapVersion int64 = version73

var (
bootstrapVersion = []func(Session, int64){
Expand Down Expand Up @@ -578,6 +596,7 @@ var (
upgradeToVer70,
upgradeToVer71,
upgradeToVer72,
upgradeToVer73,
}
)

Expand Down Expand Up @@ -1527,6 +1546,13 @@ func upgradeToVer72(s Session, ver int64) {
doReentrantDDL(s, "ALTER TABLE mysql.stats_meta ADD COLUMN snapshot BIGINT(64) UNSIGNED NOT NULL DEFAULT 0", infoschema.ErrColumnExists)
}

func upgradeToVer73(s Session, ver int64) {
if ver >= version73 {
return
}
doReentrantDDL(s, CreatePlacementPolicyTable)
}

func writeOOMAction(s Session) {
comment := "oom-action is `log` by default in v3.0.x, `cancel` by default in v4.0.11+"
mustExecute(s, `INSERT HIGH_PRIORITY INTO %n.%n VALUES (%?, %?, %?) ON DUPLICATE KEY UPDATE VARIABLE_VALUE= %?`,
Expand Down Expand Up @@ -1605,6 +1631,8 @@ func doDDLWorks(s Session) {
mustExecute(s, CreateStatsFMSketchTable)
// Create global_grants
mustExecute(s, CreateGlobalGrantsTable)
// Create placement_policy
mustExecute(s, CreatePlacementPolicyTable)
}

// doDMLWorks executes DML statements in bootstrap stage.
Expand Down