From ed6dd3967015f143ae3d40b1619f543a37b7edee 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:31:12 +0800
Subject: [PATCH] =?UTF-8?q?=E6=94=AF=E6=8C=81=E9=A2=84=E5=A4=84=E7=90=86?=
 =?UTF-8?q?=E5=8F=A5=E6=9F=84=E9=87=8D=E7=BD=AE=E5=92=8C=E9=87=8A=E6=94=BE?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 lualib/skynet/db/mysql.lua | 34 ++++++++++++++++++++++++++++++++++
 1 file changed, 34 insertions(+)

diff --git a/lualib/skynet/db/mysql.lua b/lualib/skynet/db/mysql.lua
index f63963ea..fa73ab86 100644
--- a/lualib/skynet/db/mysql.lua
+++ b/lualib/skynet/db/mysql.lua
@@ -28,6 +28,8 @@ local COM_QUERY = "\x03"
 local COM_PING = "\x0e"
 local COM_STMT_PREPARE = "\x16"
 local COM_STMT_EXECUTE = "\x17"
+local COM_STMT_CLOSE = "\x19"
+local COM_STMT_RESET = "\x1a"
 local CURSOR_TYPE_NO_CURSOR = 0x00
 local SERVER_MORE_RESULTS_EXISTS = 8
 
@@ -942,6 +944,38 @@ function _M.execute(self, stmt, ...)
     return sockchannel:request(querypacket, self.execute_resp)
 end
 
+local function _compose_stmt_reset(self, stmt)
+    self.packet_no = -1
+
+    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
+    return sockchannel:request(querypacket, self.query_resp)
+end
+
+local function _compose_stmt_close(self, stmt)
+    self.packet_no = -1
+
+    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)
+end
+
+
 function _M.ping(self)
     local querypacket, er = _compose_ping(self)
     if not querypacket then