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

Clean up mxs314

Browse Source 
Removed excessive output, used stack allocated objects, simplified
assertions.
This commit is contained in:
Markus Mäkelä
2018-06-20 22:29:24 +03:00
parent 3d8f946e19
commit 2c5dacf9ae
1 changed files with 19 additions and 52 deletions
Download Patch File Download Diff File Expand all files Collapse all files

71
maxscale-system-test/mxs314.cpp
View File

@ -1,74 +1,41 @@
/** /**
* @file mx314.cpp regression case for bug MXS-314 ("Read Write Split Error with Galera Nodes") * @file mx314.cpp regression case for bug MXS-314 ("Read Write Split Error with Galera Nodes")
* - try prepared stmt 'SELECT 1,1,1,1...." with different nu,ber of '1' * - try prepared stmt 'SELECT 1,1,1,1...." with different number of '1'
* - check if Maxscale alive * - check if Maxscale alive
*/ */
#include <iostream>
#include <unistd.h>
#include <cstdlib>
#include <string>
#include "testconnections.h" #include "testconnections.h"
using std::string;
using namespace std; using namespace std;
int main(int argc, char *argv[]) int main(int argc, char** argv)
{ {
MYSQL_STMT* stmt; TestConnections test(argc, argv);
int start = 300, p = 0;
int iterations = 2000;
string query = "select 1"; string query = "select 1";
TestConnections * Test = new TestConnections(argc, argv); for (int i = 0; i < 300; i++)
if (Test->smoke)
{
iterations = 500;
}
Test->set_timeout(50);
Test->maxscales->connect_maxscale(0);
stmt = mysql_stmt_init(Test->maxscales->conn_rwsplit[0]);
for (int i = 0; i < start; i++)
{ {
query += ",1"; query += ",1";
} }
Test->tprintf("Query: %s\n", query.c_str()); test.maxscales->connect();
for (int i = start; i < iterations; i++) MYSQL_STMT* stmt = mysql_stmt_init(test.maxscales->conn_rwsplit[0]);
for (int i = 300; i < 500; i++)
{ {
Test->set_timeout(30); test.set_timeout(30);
Test->tprintf("%d\t", i); test.add_result(mysql_stmt_prepare(stmt, query.c_str(), query.length()),
if (mysql_stmt_prepare(stmt, query.c_str(), query.length())) "Failed at %d: %s\n", i, mysql_error(test.maxscales->conn_rwsplit[0]));
{ test.add_result(mysql_stmt_reset(stmt), "Failed at %d: %s\n", i,
Test->add_result(1, "Error: %s\n", mysql_error(Test->maxscales->conn_rwsplit[0])); mysql_error(test.maxscales->conn_rwsplit[0]));
Test->add_result(1, "Failed at %d\n", i);
// delete Test;
// return 1;
}
if (mysql_stmt_reset(stmt))
{
Test->add_result(1, "Error: %s\n", mysql_error(Test->maxscales->conn_rwsplit[0]));
Test->add_result(1, "Failed at %d\n", i);
// delete Test;
// return 1;
}
query += ",1"; query += ",1";
if (i - p > 5)
{
p = i;
cout << endl;
}
} }
cout << endl;
Test->set_timeout(20); test.set_timeout(20);
mysql_stmt_close(stmt); mysql_stmt_close(stmt);
Test->maxscales->close_maxscale_connections(0); test.maxscales->disconnect();
int rval = Test->global_result;
delete Test; return test.global_result;
return rval;
} }