5c50045227
The avrorouter failed to detect ALTER TABLE statements which caused a regression. Extended the alter table tests to parse the JSON for more strict validation of test results.
92 lines
2.1 KiB
C++
92 lines
2.1 KiB
C++
/**
|
|
* @file avro.cpp test of avro
|
|
* - setup binlog and avro
|
|
* - put some data to t1
|
|
* - check avro file with "maxavrocheck -vv /var/lib/maxscale/avro/test.t1.000001.avro"
|
|
* - check that data in avro file is correct
|
|
*/
|
|
|
|
|
|
#include "testconnections.h"
|
|
#include "maxadmin_operations.h"
|
|
#include "sql_t1.h"
|
|
|
|
#include "test_binlog_fnc.h"
|
|
#include <jansson.h>
|
|
#include "maxinfo_func.h"
|
|
|
|
#include <sstream>
|
|
#include <iostream>
|
|
|
|
using std::cout;
|
|
using std::endl;
|
|
|
|
int main(int argc, char *argv[])
|
|
{
|
|
|
|
TestConnections test(argc, argv);
|
|
test.set_timeout(600);
|
|
test.ssh_maxscale(true, (char *) "rm -rf /var/lib/maxscale/avro");
|
|
|
|
/** Start master to binlogrouter replication */
|
|
if (!test.replicate_from_master())
|
|
{
|
|
return 1;
|
|
}
|
|
|
|
test.set_timeout(120);
|
|
test.repl->connect();
|
|
|
|
create_t1(test.repl->nodes[0]);
|
|
insert_into_t1(test.repl->nodes[0], 3);
|
|
execute_query(test.repl->nodes[0], "FLUSH LOGS");
|
|
|
|
test.repl->close_connections();
|
|
|
|
/** Give avrorouter some time to process the events */
|
|
test.stop_timeout();
|
|
sleep(10);
|
|
test.set_timeout(120);
|
|
|
|
char * output = test.ssh_maxscale_output(true, "maxavrocheck -d /var/lib/maxscale/avro/test.t1.000001.avro");
|
|
|
|
std::istringstream iss;
|
|
iss.str(output);
|
|
int x1_exp = 0;
|
|
int fl_exp = 0;
|
|
int x = 16;
|
|
|
|
for (std::string line; std::getline(iss, line);)
|
|
{
|
|
long long int x1, fl;
|
|
test.set_timeout(20);
|
|
get_x_fl_from_json((char*)line.c_str(), &x1, &fl);
|
|
|
|
if (x1 != x1_exp || fl != fl_exp)
|
|
{
|
|
test.add_result(1, "Output:x1 %lld, fl %lld, Expected: x1 %d, fl %d",
|
|
x1, fl, x1_exp, fl_exp);
|
|
break;
|
|
}
|
|
|
|
if ((++x1_exp) >= x)
|
|
{
|
|
x1_exp = 0;
|
|
x = x * 16;
|
|
fl_exp++;
|
|
test.tprintf("fl = %d", fl_exp);
|
|
}
|
|
}
|
|
|
|
if (fl_exp != 3)
|
|
{
|
|
test.add_result(1, "not enough lines in avrocheck output");
|
|
}
|
|
|
|
execute_query(test.repl->nodes[0], "DROP TABLE test.t1;RESET MASTER");
|
|
test.stop_timeout();
|
|
test.repl->fix_replication();
|
|
|
|
return test.global_result;
|
|
}
|