===========数据库访问--第三方
http {
upstream backend {
drizzle_server 192.168.4.119:3306 protocol=mysql
dbname=igirl user=root password=123456;
drizzle_keepalive max=10 overflow=ignore mode=single;
}
server {
listen 8080;
location /lua_content {
# MIME type determined by default_type:
default_type 'text/plain';
content_by_lua_block {
ngx.say('Hello,world!')
}
}
location /mysql {
drizzle_query $echo_request_body;
drizzle_pass backend;
}
location /api {
content_by_lua '
local sql = "select * from p_user"
local resp = ngx.location.capture("/mysql", {
method = ngx.HTTP_POST, body = sql
})
if resp.status ~= ngx.HTTP_OK or not resp.body then
error("failed to query mysql")
end
local parser = require "rds.parser"
local res, err = parser.parse(resp.body)
if res == nil then
error("failed to parse RDS: " .. err)
end
local rows = res.resultset
if not rows or #rows == 0 then
ngx.say("empty resultset")
ngx.exit(0)
end
for i, row in ipairs(rows) do
ngx.print("row ", i, ": ")
for col, val in pairs(row) do
if val ~= parser.null then
ngx.print(col, "=", val, " ")
else
ngx.print(col, "=null ")
end
end
ngx.say()
end
';
}
}
}