lihao/skynet
1
0
Fork 0
mirror of https://github.com/cloudwu/skynet.git synced 2026-07-25 12:43:09 +00:00
Code Issues Packages Projects Releases Wiki Activity

修改制表符

Browse Source
This commit is contained in:
冉朋
2019-12-17 18:58:04 +08:00
committed by 云风
parent 64d6baa176
commit 386c709f42
1 changed files with 15 additions and 14 deletions
Download Patch File Download Diff File Expand all files Collapse all files

29
lualib/skynet/db/mysql.lua
View File

@@ -945,33 +945,34 @@ function _M.execute(self, stmt, ...)
end end
local function _compose_stmt_reset(self, stmt) local function _compose_stmt_reset(self, stmt)
self.packet_no = -1 self.packet_no = -1
local cmd_packet = strpack("c1<I4", COM_STMT_RESET, stmt.prepare_id) local cmd_packet = strpack("c1<I4", COM_STMT_RESET, stmt.prepare_id)
return _compose_packet(self, cmd_packet) return _compose_packet(self, cmd_packet)
end end
--重置预处理句柄 --重置预处理句柄
function _M.stmt_reset(self, stmt) function _M.stmt_reset(self, stmt)
local querypacket = _compose_stmt_reset(self, stmt) local querypacket = _compose_stmt_reset(self, stmt)
local sockchannel = self.sockchannel local sockchannel = self.sockchannel
if not self.query_resp then if not self.query_resp then
self.query_resp = _query_resp(self) self.query_resp = _query_resp(self)
end end
return sockchannel:request(querypacket, self.query_resp)
end end
local function _compose_stmt_close(self, stmt) local function _compose_stmt_close(self, stmt)
self.packet_no = -1 self.packet_no = -1
local cmd_packet = strpack("c1<I4", COM_STMT_CLOSE, stmt.prepare_id) local cmd_packet = strpack("c1<I4", COM_STMT_CLOSE, stmt.prepare_id)
return _compose_packet(self, cmd_packet) return _compose_packet(self, cmd_packet)
end end
--关闭预处理句柄 --关闭预处理句柄
function _M.stmt_close(self, stmt) function _M.stmt_close(self, stmt)
local querypacket = _compose_stmt_close(self, stmt) local querypacket = _compose_stmt_close(self, stmt)
local sockchannel = self.sockchannel local sockchannel = self.sockchannel
return sockchannel:request(querypacket) return sockchannel:request(querypacket)
end end