openresety中使用mysql的事务时，有什么好的设计模式？

jie123108 · 2016-12-18T17:09:11+00:00

Hello0. 没有1. 仔细阅读文档2. 自己动手实践这种问&#x9898...

openresety中使用mysql的事务时，有什么好的设计模式？

jie123108

最近业务中，需要显示使用事务的场景比较多。但是代码写出来，个人觉得比较繁琐，下面是一段伪代码示例：

--获取链接并开启事务
local ok, connection = mysql:open_and_begin()
if not ok then
return json.fail(msg)
end
-- 更新第一张表。
local dao01 = table01:new(connection)
local ok, effects = dao01:update(updates)
if not ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end

-- 更新第二张表。
local dao02 = table02:new(connection)
local del_ok, del_effects = dao02:update(updates)
if not del_ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end
--提交事务,并释放链接
tx_ok, tx_err = mysql:commit_and_close(connection)
if not tx_ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end

可以看到每个出错分支都要主动回滚及释放链接，我想问的是，有没有什么方法或设计模式能避免这种情形，或者有什么自动回滚，提交及自动释放的机制？

有更简洁的模式的同学，请贴示例代码赐教。

huang_hua2012

hello,

若是返回结构均是一样的话，可以考虑先将mysql封装成通用模块，然后将rollback_and_close封装进dao:update commit_and_close底层里

在 2016年12月18日，下午5:09，xiaojie liu <jie1...@gmail.com> 写道：

最近业务中，需要显示使用事务的场景比较多。但是代码写出来，个人觉得比较繁琐，下面是一段伪代码示例：
--获取链接并开启事务
local ok, connection = mysql:open_and_begin()
if not ok then
return json.fail(msg)
end
-- 更新第一张表。
local dao01 = table01:new(connection)
local ok, effects = dao01:update(updates)
if not ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end

-- 更新第二张表。
local dao02 = table02:new(connection)
local del_ok, del_effects = dao02:update(updates)
if not del_ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end
--提交事务,并释放链接
tx_ok, tx_err = mysql:commit_and_close(connection)
if not tx_ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end

可以看到每个出错分支都要主动回滚及释放链接，我想问的是，有没有什么方法或设计模式能避免这种情形，或者有什么自动回滚，提交及自动释放的机制？

有更简洁的模式的同学，请贴示例代码赐教。

--
--

jie123108

封装到dao对象里面，也还是要主动调用的啊。 dao:update并不总是要commit或rollback的。如果是单表写操作，就不需要显示事务。

另外，封装到dao:update里面，逻辑应该是如果 not ok 就自动回滚。但是业务上有时并不是这样。

在 2016年12月18日下午5:30，Kwanhur Huang <huang_...@163.com>写道：

hello,

若是返回结构均是一样的话，可以考虑先将mysql封装成通用模块，然后将rollback_and_close封装进dao:update commit_and_close底层里

--

mike07026a

用异常-捕获的方法，封装 insert, update, select, 传输错误或不达到期望结果（影响行数，或者返回结果集合行数），则直接抛出异常，异常由xpcall捕获，统一处理。

local function test_transaction(db)

transaction_start(db)

local affected_rows = insert_or_update(db, stmt1, expected_affected_rows)

local affected_rows = insert_or_update(db, stmt2, expected_affected_rows)

local res = select(db, stmt3, expected_rows)

if res[1].code == "test" then

local affected_rows = insert_or_update(db, stmt4, expected_affected_rows)

else

local affected_rows = insert_or_update(db, stmt5, expected_affected_rows)

end

transaction_commit(db)

end

local function test_transaction_handler(db, exitcode)

根据exitcode处理（回滚，断开链接或者别的）

end

local ok, err = xpcall(test_transaction, test_transaction_handler, db)

xiaojie liu於 2016年12月18日星期日 UTC+8下午5時09分14秒寫道：

最近业务中，需要显示使用事务的场景比较多。但是代码写出来，个人觉得比较繁琐，下面是一段伪代码示例：
--获取链接并开启事务
local ok, connection = mysql:open_and_begin()
if not ok then
return json.fail(msg)
end
-- 更新第一张表。
local dao01 = table01:new(connection)
local ok, effects = dao01:update(updates)
if not ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end

-- 更新第二张表。
local dao02 = table02:new(connection)
local del_ok, del_effects = dao02:update(updates)
if not del_ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end
--提交事务,并释放链接
tx_ok, tx_err = mysql:commit_and_close(connection)
if not tx_ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end

可以看到每个出错分支都要主动回滚及释放链接，我想问的是，有没有什么方法或设计模式能避免这种情形，或者有什么自动回滚，提交及自动释放的机制？

有更简洁的模式的同学，请贴示例代码赐教。

yuansheng

local function test_transaction(db, fun, ...)

transaction_start(db)

local res, err = fun(...)

transaction_commit(db)

return res, err

end

事务封装部分，可以考虑这种思路，把事务 start、commit 就统一，并且中间部分是任意自定义。

如果担心中间自定义部分异常退出，可以使用 pcall/xpcall 保护一下。

2016-12-20 17:41 GMT+08:00 mike07026 <mike...@gmail.com>:

用异常-捕获的方法，封装 insert, update, select, 传输错误或不达到期望结果（影响行数，或者返回结果集合行数），则直接抛出异常，异常由xpcall捕获，统一处理。

local function test_transaction(db)
transaction_start(db)
local affected_rows = insert_or_update(db, stmt1, expected_affected_rows)
local affected_rows = insert_or_update(db, stmt2, expected_affected_rows)
local res = select(db, stmt3, expected_rows)
if res[1].code == "test" then
local affected_rows = insert_or_update(db, stmt4, expected_affected_rows)
else
local affected_rows = insert_or_update(db, stmt5, expected_affected_rows)
end
transaction_commit(db)
end

local function test_transaction_handler(db, exitcode)
根据exitcode处理（回滚，断开链接或者别的）
end

local ok, err = xpcall(test_transaction, test_transaction_handler, db)

xiaojie liu於 2016年12月18日星期日 UTC+8下午5時09分14秒寫道：
最近业务中，需要显示使用事务的场景比较多。但是代码写出来，个人觉得比较繁琐，下面是一段伪代码示例：
--获取链接并开启事务
local ok, connection = mysql:open_and_begin()
if not ok then
return json.fail(msg)
end
-- 更新第一张表。
local dao01 = table01:new(connection)
local ok, effects = dao01:update(updates)
if not ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end

-- 更新第二张表。
local dao02 = table02:new(connection)
local del_ok, del_effects = dao02:update(updates)
if not del_ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end
--提交事务,并释放链接
tx_ok, tx_err = mysql:commit_and_close(connection)
if not tx_ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end

可以看到每个出错分支都要主动回滚及释放链接，我想问的是，有没有什么方法或设计模式能避免这种情形，或者有什么自动回滚，提交及自动释放的机制？

有更简洁的模式的同学，请贴示例代码赐教。

--

YuanSheng Wang

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

My Github: https://github.com/membphis

OpenResty lover ^_^

jie123108

异常是一种方式，只是在支持多返回值的语言里，使用异常处理逻辑总感觉怪怪的，也不优雅。
另外每个出错的地方抛一个异常与显式回滚似乎并没有更简单。

发自网易邮箱大师

在2016年12月20日 17:41 ，mike07026写道：

用异常-捕获的方法，封装 insert, update, select, 传输错误或不达到期望结果（影响行数，或者返回结果集合行数），则直接抛出异常，异常由xpcall捕获，统一处理。

local function test_transaction(db)
transaction_start(db)
local affected_rows = insert_or_update(db, stmt1, expected_affected_rows)
local affected_rows = insert_or_update(db, stmt2, expected_affected_rows)
local res = select(db, stmt3, expected_rows)
if res[1].code == "test" then
local affected_rows = insert_or_update(db, stmt4, expected_affected_rows)
else
local affected_rows = insert_or_update(db, stmt5, expected_affected_rows)
end
transaction_commit(db)
end

local function test_transaction_handler(db, exitcode)
根据exitcode处理（回滚，断开链接或者别的）
end

local ok, err = xpcall(test_transaction, test_transaction_handler, db)

xiaojie liu於 2016年12月18日星期日 UTC+8下午5時09分14秒寫道：
最近业务中，需要显示使用事务的场景比较多。但是代码写出来，个人觉得比较繁琐，下面是一段伪代码示例：
--获取链接并开启事务
local ok, connection = mysql:open_and_begin()
if not ok then
return json.fail(msg)
end
-- 更新第一张表。
local dao01 = table01:new(connection)
local ok, effects = dao01:update(updates)
if not ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end

-- 更新第二张表。
local dao02 = table02:new(connection)
local del_ok, del_effects = dao02:update(updates)
if not del_ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end
--提交事务,并释放链接
tx_ok, tx_err = mysql:commit_and_close(connection)
if not tx_ok then
mysql:rollback_and_close(connection)
return json.fail(msg)
end

可以看到每个出错分支都要主动回滚及释放链接，我想问的是，有没有什么方法或设计模式能避免这种情形，或者有什么自动回滚，提交及自动释放的机制？

有更简洁的模式的同学，请贴示例代码赐教。

--
--