|
|
|
|
@ -5070,7 +5070,6 @@ bool MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
|
|
|
|
|
}
|
|
|
|
|
proxy_debug(PROXY_DEBUG_MYSQL_COM, 8, "Changing connection SQL Mode to %s\n", value1.c_str());
|
|
|
|
|
}
|
|
|
|
|
//exit_after_SetParse = true;
|
|
|
|
|
// the following two blocks of code will be simplified later
|
|
|
|
|
} else if ((var == "sql_auto_is_null") || (var == "sql_safe_updates")) {
|
|
|
|
|
int idx = SQL_NAME_LAST;
|
|
|
|
|
@ -5174,7 +5173,6 @@ bool MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
|
|
|
|
|
return false;
|
|
|
|
|
proxy_debug(PROXY_DEBUG_MYSQL_COM, 8, "Changing connection Time zone to %s\n", value1.c_str());
|
|
|
|
|
}
|
|
|
|
|
//exit_after_SetParse = true;
|
|
|
|
|
} else if (var == "session_track_gtids") {
|
|
|
|
|
std::string value1 = *values;
|
|
|
|
|
if ((strcasecmp(value1.c_str(),"OWN_GTID")==0) || (strcasecmp(value1.c_str(),"OFF")==0) || (strcasecmp(value1.c_str(),"ALL_GTIDS")==0)) {
|
|
|
|
|
@ -5199,7 +5197,6 @@ bool MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
|
|
|
|
|
proxy_debug(PROXY_DEBUG_MYSQL_COM, 5, "Changing connection session_track_gtids to %s\n", value1.c_str());
|
|
|
|
|
client_myds->myconn->options.session_track_gtids=strdup(value1.c_str());
|
|
|
|
|
}
|
|
|
|
|
//exit_after_SetParse = true;
|
|
|
|
|
} else {
|
|
|
|
|
unable_to_parse_set_statement(lock_hostgroup);
|
|
|
|
|
return false;
|
|
|
|
|
@ -5278,7 +5275,6 @@ bool MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
|
|
|
|
|
proxy_debug(PROXY_DEBUG_MYSQL_COM, 5, "Changing connection %s to %s\n", var.c_str(), value1.c_str());
|
|
|
|
|
}
|
|
|
|
|
}
|
|
|
|
|
//exit_after_SetParse = true;
|
|
|
|
|
} else {
|
|
|
|
|
unable_to_parse_set_statement(lock_hostgroup);
|
|
|
|
|
return false;
|
|
|
|
|
@ -5321,7 +5317,6 @@ bool MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
|
|
|
|
|
} else {
|
|
|
|
|
proxy_debug(PROXY_DEBUG_MYSQL_COM, 8, "Changing connection charset to %d\n", c->nr);
|
|
|
|
|
client_myds->myconn->set_charset(c->nr, NAMES);
|
|
|
|
|
//exit_after_SetParse = true;
|
|
|
|
|
}
|
|
|
|
|
} else if (var == "tx_isolation") {
|
|
|
|
|
std::string value1 = *values;
|
|
|
|
|
@ -5335,7 +5330,6 @@ bool MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
|
|
|
|
|
return false;
|
|
|
|
|
proxy_debug(PROXY_DEBUG_MYSQL_COM, 8, "Changing connection TX ISOLATION to %s\n", value1.c_str());
|
|
|
|
|
}
|
|
|
|
|
//exit_after_SetParse = true;
|
|
|
|
|
} else {
|
|
|
|
|
std::string value1 = *values;
|
|
|
|
|
std::size_t found_at = value1.find("@");
|
|
|
|
|
@ -5452,7 +5446,6 @@ bool MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
|
|
|
|
|
return false;
|
|
|
|
|
proxy_debug(PROXY_DEBUG_MYSQL_COM, 8, "Changing connection TRANSACTION ISOLATION LEVEL to %s\n", value1.c_str());
|
|
|
|
|
}
|
|
|
|
|
//exit_after_SetParse = true;
|
|
|
|
|
} else if (var == "read") {
|
|
|
|
|
std::string value1 = *values;
|
|
|
|
|
proxy_debug(PROXY_DEBUG_MYSQL_COM, 5, "Processing SET SESSION TRANSACTION READ value %s\n", value1.c_str());
|
|
|
|
|
@ -5462,7 +5455,6 @@ bool MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
|
|
|
|
|
return false;
|
|
|
|
|
proxy_debug(PROXY_DEBUG_MYSQL_COM, 8, "Changing connection TRANSACTION READ to %s\n", value1.c_str());
|
|
|
|
|
}
|
|
|
|
|
//exit_after_SetParse = true;
|
|
|
|
|
} else {
|
|
|
|
|
unable_to_parse_set_statement(lock_hostgroup);
|
|
|
|
|
return false;
|
|
|
|
|
@ -5507,7 +5499,6 @@ bool MySQL_Session::handler___status_WAITING_CLIENT_DATA___STATE_SLEEP___MYSQL_C
|
|
|
|
|
} else {
|
|
|
|
|
proxy_debug(PROXY_DEBUG_MYSQL_COM, 8, "Changing connection charset to %d\n", c->nr);
|
|
|
|
|
client_myds->myconn->set_charset(c->nr, CHARSET);
|
|
|
|
|
//exit_after_SetParse = true;
|
|
|
|
|
}
|
|
|
|
|
if (exit_after_SetParse) {
|
|
|
|
|
if (command_type == _MYSQL_COM_QUERY) {
|
|
|
|
|
|