在init_by_file中从mysql数据库中取数的问题

wgm_china

春哥你好！

我想init_by_file中把mysql表的数据取出来存放在openresty　shared_dict中，不过现在在初始化mysql的时候报错，不知有没有办法可以解决？

最小化代码：

----

#!/usr/bin/env lua
local cjson = require "cjson"
local mysql = require "resty.mysql"
local server_ip = "127.0.0.1"
local server_port = "3306"
local server_user = "gcs"
local server_passwd = "123456"
local server_db = "gcs"

function mysql_query(sql)
local db = mysql:new()
db:set_timeout(1000) -- 1 sec
local result
local ok, err, errno, sqlstate = db:connect({
            host = server_ip,
            port = server_port,
            database = server_db,
            user = server_user,
            password = server_passwd,
            max_packet_size=10485760})

    if not ok then
ngx.say("mysql_query connect error:"..err)
        return
    end

    local res, err, errno, sqlstate = db:query(sql)
local ok, err = db:set_keepalive(10, 10)
            if not ok then
                ngx.say("mysql_query close connect error:"..err)
            end
     --close db
     if res then
   return res
     else
   return false
     end
end

local res,err = mysql_query("select * from test")
if res then
ngx.log(ngx.ERR,"select * from test:",cjson.encode(res))
end

-----

报错内容：

------------------------

2013/08/20 20:06:23 [error] 3677#0: failed to run init_by_lua*: /usr/local/gcstorage/lualib/resty/mysql.lua:440: no request found
stack traceback:
        [C]: in function 'tcp'
        /usr/local/gcstorage/lualib/resty/mysql.lua:440: in function 'new'
        ...local/gcstorage/gcsapp/gcsfun/gcs1_3/init_config_new.lua:11: in function 'mysql_query'
        ...local/gcstorage/gcsapp/gcsfun/gcs1_3/init_config_new.lua:40: in main chunk

2013-08-21

wgm_china

agentzh

Hello!

On Tue, Aug 20, 2013 at 8:13 PM, wgm_china wrote:
> 我想init_by_file中把mysql表的数据取出来存放在openresty　shared_dict中，不过现在在初始化mysql的时候报错，不知有没有办法可以解决？

lua-resty-mysql 使用的是 ngx_lua 的 TCP cosocket API，而这个 API 在 init_by_lua 的上下文中是禁用的：

    http://wiki.nginx.org/HttpLuaModule#ngx.socket.tcp

注意 ngx.socket.tcp 这个接口支持的上下文（Context）列表中并没有 init_by_lua.

同时，lua-resty-mysql 库的文档中对此也有提及：

    https://github.com/agentzh/lua-resty-mysql#limitations

引用一下原文，“This library cannot be used in code contexts like set_by_lua*,
log_by_lua*, and header_filter_by_lua* where the ngx_lua cosocket API
is not available.”

另外，建议在邮件列表中发言之前首先加入列表，否则你的邮件总是需要人工审核。加入的方法是：“发送空白邮件到地址
openresty+subscribe@googlegroups.com 即可完成订阅。”

Regards,
-agentzh

wgm.china

谢谢春哥的回复，我再想想其它办法去实现该功能。

2013-08-21

wgm.china

发件人："Yichun Zhang (agentzh)" <age...@gmail.com>

发送时间：2013-08-21 12:57

主题：Re: [openresty] 在init_by_file中从mysql数据库中取数的问题

收件人："openresty"<openresty@googlegroups.com>

抄送：

Hello!

On Tue, Aug 20, 2013 at 8:13 PM, wgm_china wrote:

> 我想init_by_file中把mysql表的数据取出来存放在openresty　shared_dict中，不过现在在初始化mysql的时候报错，不知有没有办法可以解决？

lua-resty-mysql 使用的是 ngx_lua 的 TCP cosocket API，而这个 API 在 init_by_lua 的上下文中是禁用的：

http://wiki.nginx.org/HttpLuaModule#ngx.socket.tcp

注意 ngx.socket.tcp 这个接口支持的上下文（Context）列表中并没有 init_by_lua.

同时，lua-resty-mysql 库的文档中对此也有提及：

https://github.com/agentzh/lua-resty-mysql#limitations

引用一下原文，“This library cannot be used in code contexts like set_by_lua*,

log_by_lua*, and header_filter_by_lua* where the ngx_lua cosocket API

is not available.”

另外，建议在邮件列表中发言之前首先加入列表，否则你的邮件总是需要人工审核。加入的方法是：“发送空白邮件到地址

openresty+subscribe@googlegroups.com 即可完成订阅。”

Regards,

-agentzh

邮件来自列表“openresty”,专用于技术讨论!

订阅: 请发空白邮件到 openresty+subscribe@googlegroups.com

发言: 请发邮件到 openresty@googlegroups.com

退订: 请发邮件至 openresty+unsubscribe@googlegroups.com

归档: http://groups.google.com/group/openresty

官网: http://openresty.org/

仓库: https://github.com/agentzh/ngx_openresty

教程: http://openresty.org/download/agentzh-nginx-tutorials-zhcn.html

johnson.itman

老哥虽然时间有点久远了但还是想问一下你最后是咋实现的？我跟你的需求一样的

在 2013年8月21日星期三 UTC+8上午11:13:58，wgm_china写道：

春哥你好！

我想init_by_file中把mysql表的数据取出来存放在openresty　shared_dict中，不过现在在初始化mysql的时候报错，不知有没有办法可以解决？

最小化代码：

----

#!/usr/bin/env lua
local cjson = require "cjson"
local mysql = require "resty.mysql"
local server_ip = "127.0.0.1"
local server_port = "3306"
local server_user = "gcs"
local server_passwd = "123456"
local server_db = "gcs"

function mysql_query(sql)
local db = mysql:new()
db:set_timeout(1000) -- 1 sec
local result
local ok, err, errno, sqlstate = db:connect({
            host = server_ip,
            port = server_port,
            database = server_db,
            user = server_user,
            password = server_passwd,
            max_packet_size=10485760})

    if not ok then
ngx.say("mysql_query connect error:"..err)
        return
    end

    local res, err, errno, sqlstate = db:query(sql)
local ok, err = db:set_keepalive(10, 10)
            if not ok then
                ngx.say("mysql_query close connect error:"..err)
            end
     --close db
     if res then
   return res
     else
   return false
     end
end

local res,err = mysql_query("select * from test")
if res then
ngx.log(ngx.ERR,"select * from test:",cjson.encode(res))
end

-----

报错内容：

------------------------

2013/08/20 20:06:23 [error] 3677#0: failed to run init_by_lua*: /usr/local/gcstorage/lualib/resty/mysql.lua:440: no request found
stack traceback:
        [C]: in function 'tcp'
        /usr/local/gcstorage/lualib/resty/mysql.lua:440: in function 'new'
        ...local/gcstorage/gcsapp/gcsfun/gcs1_3/init_config_new.lua:11: in function 'mysql_query'
        ...local/gcstorage/gcsapp/gcsfun/gcs1_3/init_config_new.lua:40: in main chunk

2013-08-21

wgm_china

huang_hua2012

hello,

可结合luasql在init_by_lua* phase做db query

https://keplerproject.github.io/luasql/manual.html#mysql_extensions

Kwanhur Huang

TL;DR

在 2018年1月10日，下午6:23，johnso...@gmail.com 写道：

老哥虽然时间有点久远了但还是想问一下你最后是咋实现的？我跟你的需求一样的

在 2013年8月21日星期三 UTC+8上午11:13:58，wgm_china写道：

春哥你好！

我想init_by_file中把mysql表的数据取出来存放在openresty　shared_dict中，不过现在在初始化mysql的时候报错，不知有没有办法可以解决？

最小化代码：

----

#!/usr/bin/env lua
local cjson = require "cjson"
local mysql = require "resty.mysql"
local server_ip = "127.0.0.1"
local server_port = "3306"
local server_user = "gcs"
local server_passwd = "123456"
local server_db = "gcs"

function mysql_query(sql)
local db = mysql:new()
db:set_timeout(1000) -- 1 sec
local result
local ok, err, errno, sqlstate = db:connect({
            host = server_ip,
            port = server_port,
            database = server_db,
            user = server_user,
            password = server_passwd,
            max_packet_size=10485760})

    if not ok then
ngx.say("mysql_query connect error:"..err)
        return
    end

    local res, err, errno, sqlstate = db:query(sql)
local ok, err = db:set_keepalive(10, 10)
            if not ok then
                ngx.say("mysql_query close connect error:"..err)
            end
     --close db
     if res then
   return res
     else
   return false
     end
end

local res,err = mysql_query("select * from test")
if res then
ngx.log(ngx.ERR,"select * from test:",cjson.encode(res))
end

-----

报错内容：

------------------------

2013/08/20 20:06:23 [error] 3677#0: failed to run init_by_lua*: /usr/local/gcstorage/lualib/resty/mysql.lua:440: no request found
stack traceback:
        [C]: in function 'tcp'
        /usr/local/gcstorage/lualib/resty/mysql.lua:440: in function 'new'
        ...local/gcstorage/gcsapp/gcsfun/gcs1_3/init_config_new.lua:11: in function 'mysql_query'
        ...local/gcstorage/gcsapp/gcsfun/gcs1_3/init_config_new.lua:40: in main chunk

2013-08-21

wgm_china

--
--