1
local tk = require('proxy.tokenizer')
3
local DEBUG = os.getenv('DEBUG') or 0
6
function print_debug(msg)
12
function read_query( packet )
13
if packet:byte() ~= proxy.COM_QUERY then
14
print_debug('>>>>>> skipping')
17
print_debug('>>>>>> after skipping')
18
local query = packet:sub(2)
19
local tokens = tk.tokenize(query)
20
local stripped_tokens = tk.tokens_without_comments(tokens, true )
21
local simple_tokens = tk.bare_tokens(stripped_tokens, true )
22
proxy.response.type = proxy.MYSQLD_PACKET_OK
23
proxy.response.resultset = {
25
{ type = proxy.MYSQL_TYPE_STRING, name = "item", },
26
{ type = proxy.MYSQL_TYPE_STRING, name = "value", },
29
{ 'original', query },
30
{ 'rebuilt' , tk.tokens_to_query(tokens) }
34
print_debug('>>>>>> returning')
35
return proxy.PROXY_SEND_RESULT
38
function disconnect_client()
39
print_debug('>>>>>> end session')