如何使用luasql向变量添加函数输出

1. 在函数体中需要使用 return 语句来返回一个值。

2. 你示例中的空行是 printvalues 函数中的 print() 语句。

我看到你正在使用 limit 1 进行查询，由于你只会得到一个值，while 循环语句是无用的。

希望这对你有用

local luasql = require "luasql.postgres"
local env = luasql.postgres()
local con = assert(env:connect(
    'postgres', 'postgres', 'postgres', '192.168.241.93', '5432'
))
local res = assert(con:execute(
    'select client_addr from pg_stat_replication order by replay_lag asc limit 1'
))
local row = res:fetch({}, 'a')
local a = string.format('%-12s', row.client_addr)

res:close()

if a == '192.168.242.41' then
    print('backend1')
elseif a == '192.168.241.76' then
    print('backend2')
end

print(a)

但如果你想要一个带有函数的示例：

local luasql = require "luasql.postgres"
local env = luasql.postgres()
local con = assert(env:connect(
    'postgres', 'postgres', 'postgres', '192.168.241.93', '5432'
))
local res = assert(con:execute(
    'select client_addr from pg_stat_replication order by replay_lag asc limit 1'
))

local function printvalues(res)
    local row = res:fetch({}, 'a')
    res:close()
    return string.format('%-12s', row.client_addr)
end

local a = printvalues(res)

if a == '192.168.242.41' then
    print('backend1')
elseif a == '192.168.241.76' then
    print('backend2')
end

print(a)

尝试在变量前使用 local 关键字，这将使它们成为作用域变量。

感谢。我最终使用了这个脚本：

luasql = require "luasql.postgres"
env = luasql.postgres()
con = assert (env:connect('postgres', 'postgres', 'postgres','333.333.333.333','5432')) --master

backend = function(txn)
res = assert (con:execute('select client_addr from pg_stat_replication order by replay_lag asc limit 1'))
row = res:fetch ({}, "a")
while row do
    ip = string.format("%-12s", row.client_addr)
    row = res:fetch (row, "a")
end
result = "backend1"
if ip == '111.111.111.111' then
result = "backend1"
elseif ip == '222.222.222.222' then
result = "backend2"
end
return result
end

core.register_fetches("choose_backend", backend)