+-- unfuck the cpath set by mysql-proxy and load sqlite3 driver
+package.cpath=package.cpath .. ";/usr/lib/i386-linux-gnu/lua/5.1/?.so"
+require "luasql.sqlite3"
+
+-- intercept mysql queries
+function read_query( packet )
+ if packet:byte() == proxy.COM_QUERY then
+ print("DEBUG: we got a normal query: " .. packet:sub(2))
+ local query = string.sub(packet, 2)
+
+ if string.match(string.upper(query), '^%s*INSERT') then
+ print("DEBUG: found a query to process")
+ -- create environment object
+ local env = assert (luasql.sqlite3())
+ -- connect to data source
+ local con = assert (env:connect("mydb.sqlite3"))
+
+ -- act on the database
+ -- local cur = assert (con:execute(query))
+ local cur = con:execute(query)
+
+ -- closing time
+ cur:close()
+ con:close()
+ env:close()
+ end
+ end
+end
+