97 lines
2.7 KiB
C++
97 lines
2.7 KiB
C++
/**
|
|
* MXS-1507: Test inconsistent result detection
|
|
*
|
|
* https://jira.mariadb.org/browse/MXS-1507
|
|
*/
|
|
#include <maxtest/testconnections.hh>
|
|
#include <functional>
|
|
#include <iostream>
|
|
#include <vector>
|
|
|
|
using namespace std;
|
|
|
|
int main(int argc, char** argv)
|
|
{
|
|
Mariadb_nodes::require_gtid(true);
|
|
TestConnections test(argc, argv);
|
|
|
|
auto query = [&](string q) {
|
|
return execute_query_silent(test.maxscales->conn_rwsplit[0], q.c_str()) == 0;
|
|
};
|
|
|
|
auto ok = [&](string q) {
|
|
test.expect(query(q),
|
|
"Query '%s' should work: %s",
|
|
q.c_str(),
|
|
mysql_error(test.maxscales->conn_rwsplit[0]));
|
|
};
|
|
|
|
auto kill_master = [&]() {
|
|
test.repl->connect();
|
|
int master = test.repl->find_master();
|
|
test.repl->disconnect();
|
|
test.repl->block_node(master);
|
|
test.maxscales->wait_for_monitor(3);
|
|
test.repl->unblock_node(master);
|
|
test.maxscales->wait_for_monitor(3);
|
|
};
|
|
|
|
// Create a table
|
|
test.maxscales->connect();
|
|
ok("CREATE OR REPLACE TABLE test.t1 (id INT)");
|
|
test.maxscales->disconnect();
|
|
|
|
// Make sure it's replicated to all slaves before starting the transaction
|
|
test.repl->connect();
|
|
test.repl->sync_slaves();
|
|
test.repl->disconnect();
|
|
|
|
// Try to do a transaction across multiple master failures
|
|
test.maxscales->connect();
|
|
|
|
cout << "Start transaction, insert a value and read it" << endl;
|
|
ok("START TRANSACTION");
|
|
ok("INSERT INTO test.t1 VALUES (1)");
|
|
ok("SELECT * FROM test.t1 WHERE id = 1");
|
|
|
|
cout << "Killing master" << endl;
|
|
kill_master();
|
|
|
|
cout << "Insert value and read it" << endl;
|
|
ok("INSERT INTO test.t1 VALUES (2)");
|
|
ok("SELECT * FROM test.t1 WHERE id = 2");
|
|
|
|
cout << "Killing second master" << endl;
|
|
kill_master();
|
|
|
|
cout << "Inserting value 3" << endl;
|
|
ok("INSERT INTO test.t1 VALUES (3)");
|
|
ok("SELECT * FROM test.t1 WHERE id = 3");
|
|
|
|
cout << "Killing third master" << endl;
|
|
kill_master();
|
|
|
|
cout << "Selecting final result" << endl;
|
|
ok("SELECT SUM(id) FROM test.t1");
|
|
|
|
cout << "Killing fourth master" << endl;
|
|
kill_master();
|
|
|
|
cout << "Committing transaction" << endl;
|
|
ok("COMMIT");
|
|
test.maxscales->disconnect();
|
|
|
|
test.maxscales->connect();
|
|
cout << "Checking results" << endl;
|
|
Row r = get_row(test.maxscales->conn_rwsplit[0], "SELECT SUM(id), @@last_insert_id FROM t1");
|
|
test.expect(!r.empty() && r[0] == "6", "All rows were not inserted: %s",
|
|
r.empty() ? "No rows" : r[0].c_str());
|
|
test.maxscales->disconnect();
|
|
|
|
test.maxscales->connect();
|
|
ok("DROP TABLE test.t1");
|
|
test.maxscales->disconnect();
|
|
|
|
return test.global_result;
|
|
}
|