66 lines
2.6 KiB
C++
66 lines
2.6 KiB
C++
/**
|
|
* @file mxs1110_16mb.cpp - trying to use LONGBLOB with > 16 mb data blocks
|
|
* - try to insert large LONGBLOB via RWSplit in blocks > 16mb
|
|
* - read data via RWsplit, ReadConn master, ReadConn slave, compare with inserted data
|
|
*/
|
|
|
|
#include <maxtest/blob_test.hh>
|
|
#include <maxtest/fw_copy_rules.hh>
|
|
#include <maxtest/testconnections.hh>
|
|
|
|
int main(int argc, char* argv[])
|
|
{
|
|
TestConnections::skip_maxscale_start(true);
|
|
TestConnections::require_galera(true);
|
|
TestConnections* Test = new TestConnections(argc, argv);
|
|
Test->maxscales->stop_maxscale(0);
|
|
Test->set_timeout(60);
|
|
int chunk_size = 2500000;
|
|
int chunk_num = 5;
|
|
std::string src_dir = test_dir;
|
|
std::string masking_rules = src_dir + "/masking/masking_user/masking_rules.json";
|
|
std::string cache_rules = src_dir + "/cache/cache_basic/cache_rules.json";
|
|
std::string fw_rules = src_dir + "/fw";
|
|
|
|
Test->maxscales->copy_to_node_legacy(masking_rules.c_str(), "~/", 0);
|
|
|
|
Test->maxscales->copy_to_node_legacy(cache_rules.c_str(), "~/", 0);
|
|
|
|
Test->maxscales->ssh_node(0, "chmod a+rw *.json", true);
|
|
|
|
copy_rules(Test, "rules2", fw_rules.c_str());
|
|
|
|
Test->maxscales->start_maxscale(0);
|
|
|
|
Test->repl->execute_query_all_nodes((char*) "set global max_allowed_packet=100000000");
|
|
Test->galera->execute_query_all_nodes((char*) "set global max_allowed_packet=100000000");
|
|
|
|
Test->maxscales->connect_maxscale(0);
|
|
Test->repl->connect();
|
|
Test->tprintf("LONGBLOB: Trying send data via RWSplit\n");
|
|
test_longblob(Test, Test->maxscales->conn_rwsplit[0], (char*) "LONGBLOB", chunk_size, chunk_num, 2);
|
|
Test->repl->close_connections();
|
|
Test->maxscales->close_maxscale_connections(0);
|
|
|
|
Test->repl->sync_slaves();
|
|
Test->maxscales->connect_maxscale(0);
|
|
Test->tprintf("Checking data via RWSplit\n");
|
|
check_longblob_data(Test, Test->maxscales->conn_rwsplit[0], chunk_size, chunk_num, 2);
|
|
Test->tprintf("Checking data via ReadConn master\n");
|
|
check_longblob_data(Test, Test->maxscales->conn_master[0], chunk_size, chunk_num, 2);
|
|
Test->tprintf("Checking data via ReadConn slave\n");
|
|
check_longblob_data(Test, Test->maxscales->conn_slave[0], chunk_size, chunk_num, 2);
|
|
Test->maxscales->close_maxscale_connections(0);
|
|
|
|
MYSQL* conn_galera = open_conn(4016,
|
|
Test->maxscales->IP[0],
|
|
Test->maxscales->user_name,
|
|
Test->maxscales->password,
|
|
Test->ssl);
|
|
mysql_close(conn_galera);
|
|
|
|
int rval = Test->global_result;
|
|
delete Test;
|
|
return rval;
|
|
}
|