local how_many_queries = 0
function read_query(packet)
how_many_queries=how_many_queries + 1
print (how_many_queries)
end
proxy.globalproxy.global.how_many_queries = proxy.global.how_many_queries or 0
function read_query(packet)
proxy.global.how_many_queries = proxy.global.how_many_queries + 1
print (proxy.global.how_many_queries)
end
nil by checking for a true value, we make sure that we only initialize the variable if it is being accessed for the first time.function affected_rows (rows, id)
proxy.response.type = proxy.MYSQLD_PACKET_OK
proxy.response.affected_rows = rows
proxy.response.insert_id = id
return proxy.PROXY_SEND_RESULT
end
return affected_rows(3000,20)Query OK, 3000 rows affected (0.01 sec)Notice that you can't check the LAST_INSERT_ID with MySQL command line client, but you must use an API call from your favorite language to access that value.
| With the Sun acquisition, MySQL becomes part of a bigger company. Some beneficial effects will be felt at the MySQL Users Conference. There will be a passport giveaway program, which is basically a prize drawing with minimal effort from attendees. |  |
MySQL Conference & Expo attendees will have the opportunity to enter a drawing for cool prizes by having an expo hall passport brochure stamped at each participating sponsor and exhibitor booth.
Once attendees have obtained all "stamps" they will be entered into the drawing and eligible to win one of several prizes.
set_replication.pl command, to create a set of master+slaves. Now the set_many.pl command will create unrelated servers;start_proxy script with replication installations. This script starts MySQL Proxy using as backends all the servers in the group.print(), can be very useful when you develop an application, because can give you information on what is going on. However, when the script is well tuned, all these messages can be distracting and even annoying.local DEBUG = os.getenv('DEBUG') or 0
DEBUG = DEBUG + 0
function read_query (packet )
if packet:byte() ~= proxy.COM_QUERY then return end
print_debug(packet:sub(2),1)
print_debug('inside read_query', 2)
end
function print_debug(msg, level)
level = level or 1
if DEBUG >= level then
print (msg)
end
end
DEBUG=1 /usr/local/sbin/mysql-proxy --proxy-lua-script=simple_messages.lua
read_query_result() from the previous recipe (executing multiple queries) should be modified as follows:function read_query_result (inj )
local res = assert(inj.resultset)
if res.query_status and (res.query_status < 0 ) then
proxy.queries:reset()
return error_result('ERROR IN LOOP ' .. tostring(inj.id),
9999, 'XLOOP')
end
-- do something with the result
if inj.id ~= max_loop then
return proxy.PROXY_IGNORE_RESULT
end
end
SHOW STATUS executed before and after the query to evaluate the efficiency of the query itself.
local max_loop = 0
function read_query (packet )
if packet:byte() ~= proxy.COM_QUERY then return end
local query = packet:sub(2)
local loop_no, repeat_query = query:match('^LOOP%s+(%d+)%s+(.+)')
if loop_no then
loop_no = loop_no + 0
if loop_no < 2 then return end
for x = 1, loop_no do
proxy.queries:append(x, string.char(proxy.COM_QUERY) .. repeat_query )
end
max_loop = loop_no
return proxy.PROXY_SEND_QUERY
end
return
end
function read_query_result (inj )
-- do something with the result
if inj.id ~= max_loop then
return proxy.PROXY_IGNORE_RESULT
end
end
