66 lines
		
	
	
		
			2.3 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
			
		
		
	
	
			66 lines
		
	
	
		
			2.3 KiB
		
	
	
	
		
			C++
		
	
	
	
	
	
/**
 | 
						|
 * Firewall filter multiple matching users
 | 
						|
 *
 | 
						|
 * Test it multiple matching user rows are handled in OR fashion.
 | 
						|
 */
 | 
						|
 | 
						|
 | 
						|
#include <iostream>
 | 
						|
#include <unistd.h>
 | 
						|
#include "testconnections.h"
 | 
						|
#include "fw_copy_rules.h"
 | 
						|
 | 
						|
int main(int argc, char** argv)
 | 
						|
{
 | 
						|
    TestConnections::skip_maxscale_start(true);
 | 
						|
    char rules_dir[4096];
 | 
						|
 | 
						|
    TestConnections test(argc, argv);
 | 
						|
    test.stop_timeout();
 | 
						|
 | 
						|
    test.tprintf("Creating rules\n");
 | 
						|
    test.maxscales->stop_maxscale(0);
 | 
						|
 | 
						|
    sprintf(rules_dir, "%s/fw/", test_dir);
 | 
						|
    copy_rules(&test, (char*) "rules_mxs1583", rules_dir);
 | 
						|
 | 
						|
    test.set_timeout(60);
 | 
						|
    test.maxscales->start_maxscale(0);
 | 
						|
 | 
						|
    test.set_timeout(30);
 | 
						|
    test.maxscales->connect_maxscale(0);
 | 
						|
 | 
						|
    test.try_query(test.maxscales->conn_rwsplit[0], "drop table if exists t");
 | 
						|
    test.try_query(test.maxscales->conn_rwsplit[0], "create table t (a text, b text)");
 | 
						|
 | 
						|
    test.tprintf("Trying query that matches one 'user' row, expecting failure\n");
 | 
						|
    test.set_timeout(30);
 | 
						|
    test.add_result(!execute_query(test.maxscales->conn_rwsplit[0], "select concat(a) from t"),
 | 
						|
                    "Query that matches one 'user' row should fail.\n");
 | 
						|
 | 
						|
    test.tprintf("Trying query that matches other 'user' row, expecting failure\n");
 | 
						|
    test.set_timeout(30);
 | 
						|
    test.add_result(!execute_query(test.maxscales->conn_rwsplit[0], "select concat(b) from t"),
 | 
						|
                    "Query that matches other 'user' row should fail.\n");
 | 
						|
 | 
						|
    test.tprintf("Trying query that matches both 'user' rows, expecting failure\n");
 | 
						|
    test.set_timeout(30);
 | 
						|
    test.add_result(!execute_query_silent(test.maxscales->conn_rwsplit[0], "select concat(a), concat(b) from t"),
 | 
						|
                    "Query that matches both 'user' rows should fail.\n");
 | 
						|
 | 
						|
    test.tprintf("Trying non-matching query to blacklisted RWSplit, expecting success\n");
 | 
						|
    test.set_timeout(30);
 | 
						|
    test.add_result(execute_query_silent(test.maxscales->conn_rwsplit[0], "show status"),
 | 
						|
                    "Non-matching query to blacklist service should succeed.\n");
 | 
						|
 | 
						|
    test.stop_timeout();
 | 
						|
    test.tprintf("Checking if MaxScale is alive\n");
 | 
						|
    test.check_maxscale_processes(0, 1);
 | 
						|
    test.maxscales->stop_maxscale(0);
 | 
						|
    sleep(10);
 | 
						|
    test.tprintf("Checking if MaxScale was succesfully terminated\n");
 | 
						|
    test.check_maxscale_processes(0, 0);
 | 
						|
 | 
						|
    return test.global_result;
 | 
						|
}
 |