MXS-1849 Add basic test case
This commit is contained in:
42
maxscale-system-test/mxs1849_table_sharding.cpp
Normal file
42
maxscale-system-test/mxs1849_table_sharding.cpp
Normal file
@ -0,0 +1,42 @@
|
||||
/**
|
||||
* MXS-1849: Table family sharding router test
|
||||
*
|
||||
* https://jira.mariadb.org/browse/MXS-1849
|
||||
*/
|
||||
|
||||
|
||||
#include <iostream>
|
||||
#include "testconnections.h"
|
||||
|
||||
int main(int argc, char *argv[])
|
||||
{
|
||||
TestConnections test(argc, argv);
|
||||
test.set_timeout(30);
|
||||
test.repl->execute_query_all_nodes("STOP SLAVE");
|
||||
test.repl->execute_query_all_nodes("DROP DATABASE IF EXISTS shard_db");
|
||||
test.repl->execute_query_all_nodes("CREATE DATABASE shard_db");
|
||||
MYSQL* conn;
|
||||
for (int i = 0; i < test.repl->N; i++)
|
||||
{
|
||||
conn = open_conn_db(test.repl->port[i], test.repl->IP[i], "shard_db",
|
||||
test.repl->user_name, test.repl->password, test.ssl);
|
||||
execute_query(conn, "CREATE TABLE table%d (x1 int, fl int)", i);
|
||||
mysql_close(conn);
|
||||
}
|
||||
|
||||
conn = test.maxscales->open_rwsplit_connection(0);
|
||||
// Check that queries are routed to the right shards
|
||||
for (int i = 0; i < test.repl->N; i++)
|
||||
{
|
||||
test.add_result(execute_query(conn, "SELECT * FROM shard_db.table%d", i), "Query should succeed.");
|
||||
}
|
||||
|
||||
mysql_close(conn);
|
||||
test.stop_timeout();
|
||||
// Cleanup
|
||||
test.repl->execute_query_all_nodes("DROP DATABASE IF EXISTS shard_db");
|
||||
test.repl->execute_query_all_nodes("START SLAVE");
|
||||
sleep(1);
|
||||
test.repl->fix_replication();
|
||||
return test.global_result;
|
||||
}
|
Reference in New Issue
Block a user