|
@@ -1,9 +1,7 @@
|
|
|
-local mysql = require "resty.mysql"
|
|
|
+local mysql = mysql
|
|
|
|
|
|
-local encode = require("cjson").encode
|
|
|
+local encode = encode
|
|
|
local random = math.random
|
|
|
-local insert = table.insert
|
|
|
-
|
|
|
|
|
|
local mysqlconn = {
|
|
|
host = "DBHOSTNAME",
|
|
@@ -12,14 +10,14 @@ local mysqlconn = {
|
|
|
user = "benchmarkdbuser",
|
|
|
password = "benchmarkdbpass"
|
|
|
}
|
|
|
-local db = mysql:new()
|
|
|
return function(ngx)
|
|
|
- db:connect(mysqlconn)
|
|
|
+ local db = mysql:new()
|
|
|
+ assert(db:connect(mysqlconn))
|
|
|
local num_queries = tonumber(ngx.var.arg_queries) or 1
|
|
|
local worlds = {}
|
|
|
for i=1, num_queries do
|
|
|
local wid = random(1, 10000)
|
|
|
- insert(worlds, db:query('SELECT * FROM World WHERE id = '..wid)[1])
|
|
|
+ worlds[#worlds+1] = db:query('SELECT * FROM World WHERE id = '..wid)[1]
|
|
|
end
|
|
|
ngx.print( encode(worlds) )
|
|
|
db:set_keepalive(0, 256)
|