hcq/MaxScale
hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

MXS-701: Extend binlogfilter test

Browse Source 
The test now checks that default database usage works as expected. This
currently only works with RBR and with SBR it fails due to inadequate
processing of the SQL statements (default database is not concatenated
into the table).
This commit is contained in:
Markus Mäkelä 2018-09-23 09:03:42 +03:00
parent d7fab9e43a
commit 5869f5369c
No known key found for this signature in database
GPG Key ID: 72D48FCE664F7B19
1 changed files with 35 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

39
maxscale-system-test/mxs701_binlog_filter.cpp
View File

@ -7,6 +7,9 @@
int main(int argc, char** argv)
{
TestConnections test(argc, argv);
// Configures nodes[1] to replicate from nodes[0] and nodes[2] and nodes[3]
// to replicate from the binlogrouter
test.start_binlog();
test.repl->connect();
@ -17,34 +20,62 @@ int main(int argc, char** argv)
execute_query(test.repl->nodes[0], "CREATE TABLE a.t1(id INT)");
execute_query(test.repl->nodes[0], "CREATE TABLE a.t2(id INT)");
execute_query(test.repl->nodes[0], "CREATE TABLE b.t2(id INT)");
execute_query(test.repl->nodes[0], "CREATE TABLE a.t3(id INT)");
execute_query(test.repl->nodes[0], "CREATE TABLE b.t3(id INT)");
execute_query(test.repl->nodes[0], "INSERT INTO a.t1 VALUES (1)");
execute_query(test.repl->nodes[0], "INSERT INTO a.t2 VALUES (2)");
execute_query(test.repl->nodes[0], "INSERT INTO b.t2 VALUES (3)");
Row gtid = get_row(test.repl->nodes[0], "SELECT @@gtid_current_pos");
test.tprintf("Synchronizing slaves on GTID %s", gtid[0].c_str());
execute_query(test.repl->nodes[1], "SELECT MASTER_GTID_WAIT('%s')", gtid[0].c_str());
execute_query(test.repl->nodes[2], "SELECT MASTER_GTID_WAIT('%s')", gtid[0].c_str());
// Queries with default databases
execute_query(test.repl->nodes[0], "USE a");
execute_query(test.repl->nodes[0], "INSERT INTO t3 VALUES (1)");
execute_query(test.repl->nodes[0], "USE b");
execute_query(test.repl->nodes[0], "INSERT INTO t3 VALUES (2)");
// Test parsing of query events (DDLs are always query events, never row events)
execute_query(test.repl->nodes[0], "USE a");
execute_query(test.repl->nodes[0], "CREATE TABLE t4 AS SELECT 1 AS `id`");
execute_query(test.repl->nodes[0], "USE b");
execute_query(test.repl->nodes[0], "CREATE TABLE t4 AS SELECT 2 AS `id`");
// Let the events replicate to the slaves
sleep(10);
test.tprintf("Checking normal slave");
// The first slave has no filtering
Row a = get_row(test.repl->nodes[1], "SELECT * FROM a.t1");
Row b = get_row(test.repl->nodes[1], "SELECT * FROM a.t2");
Row c = get_row(test.repl->nodes[1], "SELECT * FROM b.t2");
Row d = get_row(test.repl->nodes[1], "SELECT * FROM a.t3");
Row e = get_row(test.repl->nodes[1], "SELECT * FROM b.t3");
Row f = get_row(test.repl->nodes[1], "SELECT * FROM a.t4");
Row g = get_row(test.repl->nodes[1], "SELECT * FROM b.t4");
test.expect(!a.empty() && a[0] == "1", "a.t1 should return 1");
test.expect(!b.empty() && b[0] == "2", "a.t2 should return 2");
test.expect(!c.empty() && c[0] == "3", "b.t2 should return 3");
test.expect(!d.empty() && d[0] == "1", "a.t3 should return 1");
test.expect(!e.empty() && e[0] == "2", "b.t3 should return 2");
test.expect(!f.empty() && f[0] == "1", "a.t4 should return 1");
test.expect(!g.empty() && g[0] == "2", "b.t4 should return 2");
test.tprintf("Checking filtered slave");
// The second slave has match=/a[.]/ and exclude=/[.]t1/
a = get_row(test.repl->nodes[2], "SELECT * FROM a.t1");
b = get_row(test.repl->nodes[2], "SELECT * FROM a.t2");
c = get_row(test.repl->nodes[2], "SELECT * FROM b.t2");
d = get_row(test.repl->nodes[2], "SELECT * FROM a.t3");
e = get_row(test.repl->nodes[2], "SELECT * FROM b.t3");
f = get_row(test.repl->nodes[2], "SELECT * FROM a.t4");
g = get_row(test.repl->nodes[2], "SELECT * FROM b.t4");
test.expect(a.empty(), "a.t1 should be empty");
test.expect(!b.empty() && b[0] == "2", "a.t2 should return 2");
test.expect(c.empty(), "b.t2 should be empty");
test.expect(!d.empty() && d[0] == "1", "a.t3 should return 1");
test.expect(e.empty(), "b.t3 should be empty");
test.expect(!f.empty() && f[0] == "1", "a.t4 should return 1");
test.expect(g.empty(), "b.t4 should be empty");
execute_query(test.repl->nodes[0], "DROP DATABASE a");
execute_query(test.repl->nodes[0], "DROP DATABASE b");