lua-resty-mysql是一个用于在OpenResty中与MySQL服务器进行交互的Lua库。它使用了MySQL的客户端/服务器协议，并且提供了完整的MySQL功能支持。
增删改查操作
使用lua-resty-mysql库，可以在OpenResty的Lua脚本中执行MySQL查询、插入、更新和删除等操作。以下是使用lua-resty-mysql库进行MySQL操作的详细步骤：
- 首先，需要在OpenResty的配置文件中指定MySQL服务器的连接信息。可以在lua代码中动态指定，也可以在nginx配置文件中指定。示例代码如下：
local mysql = require "resty.mysql"
local db, err = mysql:new()
if not db then
ngx.say("Failed to instantiate mysql: ", err)
return
end
db:set_timeout(1000) -- 设置连接超时时间，单位为毫秒
-- 连接到MySQL服务器
local ok, err, errno, sqlstate = db:connect{
host = "127.0.0.1",
port = 3306,
database = "test",
user = "dev",
password = "",
}
if not ok then
ngx.say("Failed to connect to mysql: ", err, " (errno ", errno, " sqlstate ", sqlstate, ")")
return
end
- 连接到MySQL服务器后，可以执行各种MySQL操作，例如查询、插入、更新和删除。示例代码如下：
-- 执行SELECT查询
local res, err, errno, sqlstate = db:query("SELECT * FROM users")
if not res then
ngx.say("Failed to execute query: ", err, " (errno ", errno, " sqlstate ", sqlstate, ")")
return
end
-- 处理查询结果
for i, row in ipairs(res) do
ngx.say("User ID: ", row.id)
ngx.say("Username: ", row.username)
end
-- 执行INSERT操作
local res, err, errno, sqlstate = db:execute("INSERT INTO users (username) VALUES ('testuser')")
if not res then
ngx.say("Failed to execute query: ", err, " (errno ", errno, " sqlstate ", sqlstate, ")")
return
end
-- 执行UPDATE操作
local res, err, errno, sqlstate = db:execute("UPDATE users SET username = 'updateduser' WHERE id = 1")
if not res then
ngx.say("Failed to execute query: ", err, " (errno ", errno, " sqlstate ", sqlstate, ")")
return
end
-- 执行DELETE操作
local res, err, errno, sqlstate = db:execute("DELETE FROM users WHERE id = 1")
if not res then
ngx.say("Failed to execute query: ", err, " (errno ", errno, " sqlstate ", sqlstate, ")")
return
end- 完成MySQL操作后，需要关闭与MySQL服务器的连接。示例代码如下：
-- 关闭连接
local ok, err = db:close()
if not ok then
ngx.say("Failed to close mysql connection: ", err)
return
end
事务操作
lua-resty-mysql支持事务操作。在开始事务之前，需要调用begin方法来开始事务。在事务中执行的操作，会自动提交到事务中，直到调用commit方法提交事务或者调用rollback方法回滚事务。
以下是使用lua-resty-mysql进行事务操作的示例代码：
-- 开始事务
local ok, err = db:begin()
if not ok then
ngx.say("Failed to start transaction: ", err)
return
end
-- 在事务中执行操作
local res, err, errno, sqlstate = db:execute("INSERT INTO users (username) VALUES ('testuser')")
if not res then
ngx.say("Failed to execute query: ", err, " (errno ", errno, " sqlstate ", sqlstate, ")")
return
end
res, err, errno, sqlstate = db:execute("UPDATE users SET username = 'updateduser' WHERE id = 1")
if not res then
ngx.say("Failed to execute query: ", err, " (errno ", errno, " sqlstate ", sqlstate, ")")
-- 回滚事务
ok, err = db:rollback()
if not ok then
ngx.say("Failed to rollback transaction: ", err)
return
end
return
end
-- 提交事务
ok, err = db:commit()
if not ok then
ngx.say("Failed to commit transaction: ", err)
return
end
连接池
lua-resty-mysql支持连接池的使用。连接池可以提高数据库连接的复用率，减少建立和销毁连接的开销，提高系统的性能。
-- put it into the connection pool of size 100,
-- with 10 seconds max idle timeout
local ok, err = db:set_keepalive(10000, 100)
if not ok then
ngx.say("failed to set keepalive: ", err)
db:close()
return
end
防SQL注入
在使用 lua-resty-mysql 模块进行数据库操作时，防止 SQL 注入是非常重要的。为了确保安全性，可以将参数进行转义，从而避免了 SQL 注入的风险。
示例代码
下面是一个使用 lua-resty-mysql 防SQL注入查询的例子：
local quoted_name = ngx.quote_sql_str(name)
local sql = "select * from users where name = " .. quoted_name通过上述方法，你可以有效地防止 SQL 注入攻击，保护你的应用程序免受恶意攻击。
