From 386c709f425d090f5443b1cf2d0c875c93d35c13 Mon Sep 17 00:00:00 2001
From: =?UTF-8?q?=E5=86=89=E6=9C=8B?= <zero@kkv.me>
Date: Tue, 17 Dec 2019 18:58:04 +0800
Subject: [PATCH] =?UTF-8?q?=E4=BF=AE=E6=94=B9=E5=88=B6=E8=A1=A8=E7=AC=A6?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lualib/skynet/db/mysql.lua | 29 +++++++++++++++--------------
 1 file changed, 15 insertions(+), 14 deletions(-)

diff --git a/lualib/skynet/db/mysql.lua b/lualib/skynet/db/mysql.lua
index 6d92712f..e701a0aa 100644
--- a/lualib/skynet/db/mysql.lua
+++ b/lualib/skynet/db/mysql.lua
@@ -945,33 +945,34 @@ function _M.execute(self, stmt, ...)
 end
 
 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)
-    return _compose_packet(self, cmd_packet)
+	local cmd_packet = strpack("c1<I4", COM_STMT_RESET, stmt.prepare_id)
+	return _compose_packet(self, cmd_packet)
 end
 
 --重置预处理句柄
 function _M.stmt_reset(self, stmt)
-    local querypacket = _compose_stmt_reset(self, stmt)
-    local sockchannel = self.sockchannel
-        if not self.query_resp then
-        self.query_resp = _query_resp(self)
-    end
+	local querypacket = _compose_stmt_reset(self, stmt)
+	local sockchannel = self.sockchannel
+		if not self.query_resp then
+		self.query_resp = _query_resp(self)
+	end
+	return sockchannel:request(querypacket, self.query_resp)
 end
 
 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)
-    return _compose_packet(self, cmd_packet)
+	local cmd_packet = strpack("c1<I4", COM_STMT_CLOSE, stmt.prepare_id)
+	return _compose_packet(self, cmd_packet)
 end
 
 --关闭预处理句柄
 function _M.stmt_close(self, stmt)
-    local querypacket = _compose_stmt_close(self, stmt)
-    local sockchannel = self.sockchannel
-    return sockchannel:request(querypacket)
+	local querypacket = _compose_stmt_close(self, stmt)
+	local sockchannel = self.sockchannel
+	return sockchannel:request(querypacket)
 end