Skip to content

Commit

Permalink
checker(dm): support concurrent check (pingcap#3975)
Browse files Browse the repository at this point in the history 
close pingcap#3974
  • Loading branch information
@okJiang @zhaoxinyu
okJiang authored and zhaoxinyu committed Feb 16, 2022
1 parent 15cd2aa commit ca0b2a1
Show file tree
Hide file tree
Showing 10 changed files with 527 additions and 400 deletions.
87 changes: 51 additions & 36 deletions dm/checker/check_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -255,32 +255,33 @@ func (s *testCheckerSuite) TestTableSchemaChecking(c *tc.C) {
}

createTable1 := `CREATE TABLE %s (
id int(11) DEFAULT NULL,
b int(11) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1`
id int(11) DEFAULT NULL,
b int(11) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1`
createTable2 := `CREATE TABLE %s (
id int(11) DEFAULT NULL,
b int(11) DEFAULT NULL,
UNIQUE KEY id (id)
) ENGINE=InnoDB DEFAULT CHARSET=latin1`
id int(11) DEFAULT NULL,
b int(11) DEFAULT NULL,
UNIQUE KEY id (id)
) ENGINE=InnoDB DEFAULT CHARSET=latin1`

mock := initMockDB(c)
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable1, tb1)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'max_connections'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("max_connections", "2"))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable1, tb1)))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable1, tb2)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
msg, err := CheckSyncConfig(context.Background(), cfgs, common.DefaultErrorCnt, common.DefaultWarnCnt)
c.Assert(len(msg), tc.Equals, 0)
c.Assert(err, tc.ErrorMatches, "(.|\n)*primary/unique key does not exist(.|\n)*")
c.Assert(len(msg), tc.Equals, 0)

mock = initMockDB(c)
mock.ExpectQuery("SHOW VARIABLES LIKE 'max_connections'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("max_connections", "2"))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable2, tb1)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable2, tb2)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
msg, err = CheckSyncConfig(context.Background(), cfgs, common.DefaultErrorCnt, common.DefaultWarnCnt)
c.Assert(msg, tc.Equals, CheckTaskSuccess)
c.Assert(err, tc.IsNil)
c.Assert(msg, tc.Equals, CheckTaskSuccess)
}

func (s *testCheckerSuite) TestShardTableSchemaChecking(c *tc.C) {
Expand All @@ -299,29 +300,37 @@ func (s *testCheckerSuite) TestShardTableSchemaChecking(c *tc.C) {
}

createTable1 := `CREATE TABLE %s (
id int(11) DEFAULT NULL,
b int(11) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1`
id int(11) DEFAULT NULL,
b int(11) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1`
createTable2 := `CREATE TABLE %s (
id int(11) DEFAULT NULL,
c int(11) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1`
id int(11) DEFAULT NULL,
c int(11) DEFAULT NULL
) ENGINE=InnoDB DEFAULT CHARSET=latin1`

mock := initMockDB(c)
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable1, tb1)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'max_connections'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("max_connections", "2"))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable1, tb1)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable2, tb2)))
msg, err := CheckSyncConfig(context.Background(), cfgs, common.DefaultErrorCnt, common.DefaultWarnCnt)
c.Assert(len(msg), tc.Equals, 0)
c.Assert(err, tc.ErrorMatches, "(.|\n)*different column definition(.|\n)*")
c.Assert(len(msg), tc.Equals, 0)

mock = initMockDB(c)
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable1, tb1)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'max_connections'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("max_connections", "2"))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable1, tb1)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable1, tb2)))
msg, err = CheckSyncConfig(context.Background(), cfgs, common.DefaultErrorCnt, common.DefaultWarnCnt)
c.Assert(msg, tc.Equals, CheckTaskSuccess)
c.Assert(err, tc.IsNil)
c.Assert(msg, tc.Equals, CheckTaskSuccess)
}

func (s *testCheckerSuite) TestShardAutoIncrementIDChecking(c *tc.C) {
Expand All @@ -340,36 +349,42 @@ func (s *testCheckerSuite) TestShardAutoIncrementIDChecking(c *tc.C) {
}

createTable1 := `CREATE TABLE %s (
id int(11) NOT NULL AUTO_INCREMENT,
b int(11) DEFAULT NULL,
PRIMARY KEY (id),
UNIQUE KEY u_b(b)
) ENGINE=InnoDB DEFAULT CHARSET=latin1`
id int(11) NOT NULL AUTO_INCREMENT,
b int(11) DEFAULT NULL,
PRIMARY KEY (id),
UNIQUE KEY u_b(b)
) ENGINE=InnoDB DEFAULT CHARSET=latin1`

createTable2 := `CREATE TABLE %s (
id int(11) NOT NULL,
b int(11) DEFAULT NULL,
INDEX (id),
UNIQUE KEY u_b(b)
) ENGINE=InnoDB DEFAULT CHARSET=latin1`
id int(11) NOT NULL,
b int(11) DEFAULT NULL,
INDEX (id),
UNIQUE KEY u_b(b)
) ENGINE=InnoDB DEFAULT CHARSET=latin1`

mock := initMockDB(c)
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable1, tb1)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'max_connections'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("max_connections", "2"))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable1, tb1)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable1, tb2)))
msg, err := CheckSyncConfig(context.Background(), cfgs, common.DefaultErrorCnt, common.DefaultWarnCnt)
c.Assert(len(msg), tc.Equals, 0)
c.Assert(err, tc.ErrorMatches, "(.|\n)*instance table .* of sharding .* have auto-increment key(.|\n)*")
c.Assert(msg, tc.Matches, "(.|\n)*sourceID table .* of sharding .* have auto-increment key(.|\n)*")
c.Assert(err, tc.IsNil)

mock = conn.InitMockDB(c)
mock.ExpectQuery("SHOW DATABASES").WillReturnRows(sqlmock.NewRows([]string{"DATABASE"}).AddRow(schema))
mock.ExpectQuery("SHOW FULL TABLES").WillReturnRows(sqlmock.NewRows([]string{"Tables_in_" + schema, "Table_type"}).AddRow(tb1, "BASE TABLE").AddRow(tb2, "BASE TABLE"))
mock = initMockDB(c)
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable2, tb1)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'max_connections'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("max_connections", "2"))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable2, tb1)))
mock.ExpectQuery("SHOW VARIABLES LIKE 'sql_mode'").WillReturnRows(sqlmock.NewRows([]string{"Variable_name", "Value"}).AddRow("sql_mode", ""))
mock.ExpectQuery("SHOW CREATE TABLE .*").WillReturnRows(sqlmock.NewRows([]string{"Table", "Create Table"}).AddRow(tb1, fmt.Sprintf(createTable2, tb2)))
msg, err = CheckSyncConfig(context.Background(), cfgs, common.DefaultErrorCnt, common.DefaultWarnCnt)
c.Assert(msg, tc.Equals, CheckTaskSuccess)
c.Assert(err, tc.IsNil)
c.Assert(msg, tc.Equals, CheckTaskSuccess)
}

func (s *testCheckerSuite) TestSameTargetTableDetection(c *tc.C) {
Expand Down
41 changes: 19 additions & 22 deletions dm/checker/checker.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -119,9 +119,11 @@ func (c *Checker) Init(ctx context.Context) (err error) {
rollbackHolder.Add(fr.FuncRollback{Name: "close-DBs", Fn: c.closeDBs})

c.tctx = tcontext.NewContext(ctx, log.With(zap.String("unit", "task check")))
// target name => source => schema => [tables]
sharding := make(map[string]map[string]map[string][]string)
// targetTableID => source => [tables]
sharding := make(map[string]map[string][]*filter.Table)
shardingCounter := make(map[string]int)
// sourceID => []table
checkTablesMap := make(map[string][]*filter.Table)
dbs := make(map[string]*sql.DB)
columnMapping := make(map[string]*column.Mapping)
_, checkingShardID := c.checkingItems[config.ShardAutoIncrementIDChecking]
Expand Down Expand Up @@ -206,29 +208,22 @@ func (c *Checker) Init(ctx context.Context) (err error) {
return err
}

// checkTables map schema => {table1, table2, ...}
checkTables := make(map[string][]string)
var checkTables []*filter.Table
checkSchemas := make(map[string]struct{}, len(mapping))
for name, tables := range mapping {
for targetTableID, tables := range mapping {
checkTables = append(checkTables, tables...)
if _, ok := sharding[targetTableID]; !ok {
sharding[targetTableID] = make(map[string][]*filter.Table)
}
sharding[targetTableID][instance.cfg.SourceID] = append(sharding[targetTableID][instance.cfg.SourceID], tables...)
shardingCounter[targetTableID] += len(tables)
for _, table := range tables {
checkTables[table.Schema] = append(checkTables[table.Schema], table.Name)
if _, ok := checkSchemas[table.Schema]; !ok {
checkSchemas[table.Schema] = struct{}{}
}
if _, ok := sharding[name]; !ok {
sharding[name] = make(map[string]map[string][]string)
}
if _, ok := sharding[name][instance.cfg.SourceID]; !ok {
sharding[name][instance.cfg.SourceID] = make(map[string][]string)
}
if _, ok := sharding[name][instance.cfg.SourceID][table.Schema]; !ok {
sharding[name][instance.cfg.SourceID][table.Schema] = make([]string, 0, 1)
}

sharding[name][instance.cfg.SourceID][table.Schema] = append(sharding[name][instance.cfg.SourceID][table.Schema], table.Name)
shardingCounter[name]++
}
}
checkTablesMap[instance.cfg.SourceID] = checkTables
dbs[instance.cfg.SourceID] = instance.sourceDB.DB
if _, ok := c.checkingItems[config.DumpPrivilegeChecking]; ok {
exportCfg := export.DefaultConfig()
Expand All @@ -241,9 +236,11 @@ func (c *Checker) Init(ctx context.Context) (err error) {
if c.onlineDDL != nil {
c.checkList = append(c.checkList, checker.NewOnlineDDLChecker(instance.sourceDB.DB, checkSchemas, c.onlineDDL, bw))
}
if checkSchema {
c.checkList = append(c.checkList, checker.NewTablesChecker(instance.sourceDB.DB, instance.sourceDBinfo, checkTables))
}
}

dumpThreads := c.instances[0].cfg.MydumperConfig.Threads
if checkSchema {
c.checkList = append(c.checkList, checker.NewTablesChecker(dbs, checkTablesMap, dumpThreads))
}

if checkingShard {
Expand All @@ -252,7 +249,7 @@ func (c *Checker) Init(ctx context.Context) (err error) {
continue
}

c.checkList = append(c.checkList, checker.NewShardingTablesChecker(name, dbs, shardingSet, columnMapping, checkingShardID))
c.checkList = append(c.checkList, checker.NewShardingTablesChecker(name, dbs, shardingSet, columnMapping, checkingShardID, dumpThreads))
}
}

Expand Down
9 changes: 4 additions & 5 deletions dm/pkg/checker/mysql_server.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -124,13 +124,12 @@ func (pc *MySQLServerIDChecker) Check(ctx context.Context) *Result {

serverID, err := dbutil.ShowServerID(ctx, pc.db)
if err != nil {
if utils.OriginError(err) == sql.ErrNoRows {
result.Errors = append(result.Errors, NewError("server_id not set"))
result.Instruction = "please set server_id in your database"
} else {
if utils.OriginError(err) != sql.ErrNoRows {
markCheckError(result, err)
return result
}

result.Errors = append(result.Errors, NewError("server_id not set"))
result.Instruction = "please set server_id in your database"
return result
}

Expand Down
20 changes: 9 additions & 11 deletions dm/pkg/checker/privilege.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -20,6 +20,7 @@ import (
"strings"

"github.com/pingcap/tidb-tools/pkg/dbutil"
"github.com/pingcap/tidb-tools/pkg/filter"
"github.com/pingcap/tidb/parser"
"github.com/pingcap/tidb/parser/ast"
"github.com/pingcap/tidb/parser/mysql"
Expand All @@ -41,12 +42,12 @@ var privNeedGlobal = map[mysql.PrivilegeType]struct{}{
type SourceDumpPrivilegeChecker struct {
db *sql.DB
dbinfo *dbutil.DBConfig
checkTables map[string][]string // map schema => {table1, table2, ...}
checkTables []*filter.Table
consistency string
}

// NewSourceDumpPrivilegeChecker returns a RealChecker.
func NewSourceDumpPrivilegeChecker(db *sql.DB, dbinfo *dbutil.DBConfig, checkTables map[string][]string, consistency string) RealChecker {
func NewSourceDumpPrivilegeChecker(db *sql.DB, dbinfo *dbutil.DBConfig, checkTables []*filter.Table, consistency string) RealChecker {
return &SourceDumpPrivilegeChecker{
db: db,
dbinfo: dbinfo,
Expand Down Expand Up @@ -320,23 +321,20 @@ func verifyPrivileges(result *Result, grants []string, lackPriv map[mysql.Privil
return NewError(privileges)
}

// checkTables map schema => {table1, table2, ...}.
// lackPriv map privilege => schema => table.
func genExpectPriv(privileges map[mysql.PrivilegeType]struct{}, checkTables map[string][]string) map[mysql.PrivilegeType]map[string]map[string]struct{} {
func genExpectPriv(privileges map[mysql.PrivilegeType]struct{}, checkTables []*filter.Table) map[mysql.PrivilegeType]map[string]map[string]struct{} {
lackPriv := make(map[mysql.PrivilegeType]map[string]map[string]struct{}, len(privileges))
for p := range privileges {
if _, ok := privNeedGlobal[p]; ok {
lackPriv[p] = make(map[string]map[string]struct{})
continue
}
lackPriv[p] = make(map[string]map[string]struct{}, len(checkTables))
for schema, tables := range checkTables {
if _, ok := lackPriv[p][schema]; !ok {
lackPriv[p][schema] = make(map[string]struct{}, len(tables))
}
for _, table := range tables {
lackPriv[p][schema][table] = struct{}{}
for _, table := range checkTables {
if _, ok := lackPriv[p][table.Schema]; !ok {
lackPriv[p][table.Schema] = make(map[string]struct{})
}
lackPriv[p][table.Schema][table.Name] = struct{}{}
}
if p == mysql.SelectPriv {
if _, ok := lackPriv[p]["INFORMATION_SCHEMA"]; !ok {
Expand All @@ -353,7 +351,7 @@ func genReplicPriv(replicationPrivileges map[mysql.PrivilegeType]struct{}) map[m
return genExpectPriv(replicationPrivileges, nil)
}

func genDumpPriv(dumpPrivileges map[mysql.PrivilegeType]struct{}, checkTables map[string][]string) map[mysql.PrivilegeType]map[string]map[string]struct{} {
func genDumpPriv(dumpPrivileges map[mysql.PrivilegeType]struct{}, checkTables []*filter.Table) map[mysql.PrivilegeType]map[string]map[string]struct{} {
// due to dump privilege checker need check db/table level privilege
// so we need know the check tables
return genExpectPriv(dumpPrivileges, checkTables)
Expand Down
25 changes: 13 additions & 12 deletions dm/pkg/checker/privilege_test.go
View file
Original file line number Diff line number Diff line change
Expand Up @@ -17,6 +17,7 @@ import (
"testing"

tc "github.com/pingcap/check"
"github.com/pingcap/tidb-tools/pkg/filter"
"github.com/pingcap/tidb/parser/mysql"
)

Expand All @@ -31,7 +32,7 @@ type testCheckSuite struct{}
func (t *testCheckSuite) TestVerifyDumpPrivileges(c *tc.C) {
cases := []struct {
grants []string
checkTables map[string][]string
checkTables []*filter.Table
dumpState State
errMatch string
}{
Expand All @@ -58,8 +59,8 @@ func (t *testCheckSuite) TestVerifyDumpPrivileges(c *tc.C) {
"GRANT EXECUTE ON FUNCTION db1.anomaly_score TO 'user1'@'domain-or-ip-address1'",
},
dumpState: StateFailure,
checkTables: map[string][]string{
"db1": {"anomaly_score"},
checkTables: []*filter.Table{
{Schema: "db1", Name: "anomaly_score"},
},
// `db1`.`anomaly_score`; `INFORMATION_SCHEMA`
// can't guarantee the order
Expand Down Expand Up @@ -126,8 +127,8 @@ func (t *testCheckSuite) TestVerifyDumpPrivileges(c *tc.C) {
"GRANT ALL PRIVILEGES ON `medz`.* TO `zhangsan`@`10.8.1.9` WITH GRANT OPTION",
},
dumpState: StateFailure,
checkTables: map[string][]string{
"medz": {"medz"},
checkTables: []*filter.Table{
{Schema: "medz", Name: "medz"},
},
errMatch: "lack of RELOAD privilege; ",
},
Expand All @@ -137,8 +138,8 @@ func (t *testCheckSuite) TestVerifyDumpPrivileges(c *tc.C) {
"GRANT ALL PRIVILEGES ON `INFORMATION_SCHEMA`.* TO `zhangsan`@`10.8.1.9` WITH GRANT OPTION",
},
dumpState: StateFailure,
checkTables: map[string][]string{
"medz": {"medz"},
checkTables: []*filter.Table{
{Schema: "medz", Name: "medz"},
},
errMatch: "lack of RELOAD privilege; ",
},
Expand All @@ -149,8 +150,8 @@ func (t *testCheckSuite) TestVerifyDumpPrivileges(c *tc.C) {
"GRANT SELECT ON `INFORMATION_SCHEMA`.* TO 'user'@'%'",
},
dumpState: StateFailure,
checkTables: map[string][]string{
"lance": {"t"},
checkTables: []*filter.Table{
{Schema: "lance", Name: "t"},
},
errMatch: "lack of Select privilege: {`lance`.`t`}; ",
},
Expand All @@ -162,8 +163,8 @@ func (t *testCheckSuite) TestVerifyDumpPrivileges(c *tc.C) {
"GRANT `r1`@`%`,`r2`@`%` TO `u1`@`localhost`",
},
dumpState: StateSuccess,
checkTables: map[string][]string{
"db1": {"t"},
checkTables: []*filter.Table{
{Schema: "db1", Name: "t"},
},
},
{
Expand Down Expand Up @@ -195,7 +196,7 @@ func (t *testCheckSuite) TestVerifyDumpPrivileges(c *tc.C) {
func (t *testCheckSuite) TestVerifyReplicationPrivileges(c *tc.C) {
cases := []struct {
grants []string
checkTables map[string][]string
checkTables []*filter.Table
replicationState State
errMatch string
}{
Expand Down
Loading

0 comments on commit ca0b2a1

Please sign in to comment.