60 lines
1.4 KiB
C++
60 lines
1.4 KiB
C++
/**
|
|
* @file avro_long.cpp test of avro
|
|
* - setup binlog and avro
|
|
* - put some data to t1 in the loop
|
|
*/
|
|
|
|
#include <iostream>
|
|
#include <maxtest/maxadmin_operations.h>
|
|
#include <maxtest/sql_t1.h>
|
|
#include <maxtest/test_binlog_fnc.h>
|
|
#include <maxtest/testconnections.h>
|
|
|
|
int main(int argc, char* argv[])
|
|
{
|
|
|
|
TestConnections* Test = new TestConnections(argc, argv);
|
|
Test->set_timeout(600);
|
|
Test->maxscales->stop_maxscale(0);
|
|
Test->maxscales->ssh_node(0, (char*) "rm -rf /var/lib/maxscale/avro", true);
|
|
|
|
// Test->maxscales->ssh_node(0, (char *) "mkdir /var/lib/maxscale/avro; chown -R maxscale:maxscale
|
|
// /var/lib/maxscale/avro", true);
|
|
|
|
Test->repl->connect();
|
|
execute_query(Test->repl->nodes[0], (char*) "DROP TABLE IF EXISTS t1;");
|
|
Test->repl->close_connections();
|
|
sleep(5);
|
|
|
|
|
|
Test->start_binlog(0);
|
|
|
|
Test->set_timeout(120);
|
|
|
|
Test->maxscales->stop_maxscale(0);
|
|
|
|
Test->maxscales->ssh_node(0, (char*) "rm -rf /var/lib/maxscale/avro", true);
|
|
|
|
Test->set_timeout(120);
|
|
|
|
Test->maxscales->start_maxscale(0);
|
|
|
|
Test->set_timeout(60);
|
|
|
|
Test->repl->connect();
|
|
create_t1(Test->repl->nodes[0]);
|
|
|
|
for (int i = 0; i < 1000000; i++)
|
|
{
|
|
Test->set_timeout(60);
|
|
insert_into_t1(Test->repl->nodes[0], 3);
|
|
Test->tprintf("i=%d\n", i);
|
|
}
|
|
|
|
Test->repl->close_connections();
|
|
|
|
int rval = Test->global_result;
|
|
delete Test;
|
|
return rval;
|
|
}
|