hcq/MaxScale
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

Only parse COM_QUERY packets

Browse Source
This commit is contained in:
Johan Wikman
2016-10-25 20:28:50 +03:00
parent 8391579206
commit 46c2b6e76a
1 changed files with 30 additions and 25 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
server/modules/protocol/MySQL/MySQLClient/mysql_client.c
View File

@ -1435,41 +1435,46 @@ static int route_by_statement(SESSION* session, uint64_t capabilities, GWBUF** p
if (rcap_type_required(capabilities, RCAP_TYPE_TRANSACTION_TRACKING)) if (rcap_type_required(capabilities, RCAP_TYPE_TRANSACTION_TRACKING))
{ {
uint32_t type = qc_get_type(packetbuf); uint32_t *data = GWBUF_DATA(packetbuf);
if (type & QUERY_TYPE_BEGIN_TRX) if (MYSQL_GET_COMMAND(data) == MYSQL_COM_QUERY)
{ {
if (type & QUERY_TYPE_DISABLE_AUTOCOMMIT) uint32_t type = qc_get_type(packetbuf);
if (type & QUERY_TYPE_BEGIN_TRX)
{ {
session_set_autocommit(session, false); if (type & QUERY_TYPE_DISABLE_AUTOCOMMIT)
session_set_trx_state(session, SESSION_TRX_INACTIVE);
}
else
{
session_trx_state_t trx_state;
if (type & QUERY_TYPE_WRITE)
{ {
trx_state = SESSION_TRX_READ_WRITE; session_set_autocommit(session, false);
} session_set_trx_state(session, SESSION_TRX_INACTIVE);
else if (type & QUERY_TYPE_READ)
{
trx_state = SESSION_TRX_READ_ONLY;
} }
else else
{ {
trx_state = SESSION_TRX_ACTIVE; session_trx_state_t trx_state;
if (type & QUERY_TYPE_WRITE)
{
trx_state = SESSION_TRX_READ_WRITE;
}
else if (type & QUERY_TYPE_READ)
{
trx_state = SESSION_TRX_READ_ONLY;
}
else
{
trx_state = SESSION_TRX_ACTIVE;
}
session_set_trx_state(session, trx_state);
} }
session_set_trx_state(session, trx_state);
} }
} else if ((type & QUERY_TYPE_COMMIT) || (type & QUERY_TYPE_ROLLBACK))
else if ((type & QUERY_TYPE_COMMIT) || (type & QUERY_TYPE_ROLLBACK))
{
session_set_trx_state(session, SESSION_TRX_INACTIVE);
if (type & QUERY_TYPE_ENABLE_AUTOCOMMIT)
{ {
session_set_autocommit(session, true); session_set_trx_state(session, SESSION_TRX_INACTIVE);
if (type & QUERY_TYPE_ENABLE_AUTOCOMMIT)
{
session_set_autocommit(session, true);
}
} }
} }
} }