MXS-701: Add binlogfilter test case

Added a simple test case that checks that the match and exclude parameters
work.

maxscale-system-test/CMakeLists.txt

@@ -1072,4 +1072,8 @@ add_test_executable(mxs2037_namedserver_wildcards.cpp mxs2037_namedserver_wildca
 # https://jira.mariadb.org/browse/MXS-2047
 add_test_executable(mxs2047_blr_gtid_path.cpp mxs2047_blr_gtid_path mxs2047_blr_gtid_path LABELS binlogrouter GALERA_BACKEND)
 
+# MXS-701: Binlog filtering
+# https://jira.mariadb.org/browse/MXS-701
+add_test_executable(mxs701_binlog_filter.cpp mxs701_binlog_filter mxs701_binlog_filter LABELS bilogrouter REPL_BACKEND)
+
 configure_file(templates.h.in ${CMAKE_CURRENT_BINARY_DIR}/templates.h @ONLY)

maxscale-system-test/cnf/maxscale.cnf.template.mxs701_binlog_filter

@@ -0,0 +1,33 @@
+[maxscale]
+threads=###threads###
+log_info=1
+
+[Binlog-Filter]
+type=filter
+module=binlogfilter
+match=/a[.]/
+exclude=/[.]t1/
+
+[Binlog-Service]
+type=service
+router=binlogrouter
+user=skysql
+password=skysql
+server_id=9993
+filters=Binlog-Filter
+
+[Binlog-Listener]
+type=listener
+service=Binlog-Service
+protocol=MySQLClient
+port=5306
+
+[CLI]
+type=service
+router=cli
+
+[CLI-Listener]
+type=listener
+service=CLI
+protocol=maxscaled
+socket=default

maxscale-system-test/mxs701_binlog_filter.cpp

@@ -0,0 +1,56 @@
+/**
+ * MXS-701: Binlog filtering
+ */
+
+#include "testconnections.h"
+
+int main(int argc, char** argv)
+{
+    TestConnections test(argc, argv);
+    test.start_binlog();
+
+    test.repl->connect();
+    execute_query_silent(test.repl->nodes[0], "DROP DATABASE a");
+    execute_query_silent(test.repl->nodes[0], "DROP DATABASE b");
+    execute_query(test.repl->nodes[0], "CREATE DATABASE a");
+    execute_query(test.repl->nodes[0], "CREATE DATABASE b");
+    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], "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());
+
+    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");
+
+    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.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");
+
+    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");
+
+    execute_query(test.repl->nodes[0], "DROP DATABASE a");
+    execute_query(test.repl->nodes[0], "DROP DATABASE b");
+
+    test.repl->disconnect();
+    test.repl->fix_replication();
+
+    return test.global_result;
+}