From 6af09a925d8cb390e543053d6527ba8f89594c5e Mon Sep 17 00:00:00 2001
From: liuzujun <307836273@qq.com>
Date: Wed, 10 Mar 2021 13:35:34 +0800
Subject: [PATCH] mysql二进制数据加上quote_sql_str

---
 src/shared/ModelBaseMysql.lua | 10 +++++++---
 src/shared/mysqlproxy.lua     |  2 +-
 2 files changed, 8 insertions(+), 4 deletions(-)

diff --git a/src/shared/ModelBaseMysql.lua b/src/shared/ModelBaseMysql.lua
index c4c9d52..d7cfc7f 100644
--- a/src/shared/ModelBaseMysql.lua
+++ b/src/shared/ModelBaseMysql.lua
@@ -105,10 +105,14 @@ function ModelBaseMysql:save()
             if not next(self[propname]) then 
                 params[fieldName] = "NULL"
             else
-                params[fieldName] = "'" .. MsgPack.pack(self[propname]) .. "'"
+                local result = mysqlproxy:quote_sql_str(MsgPack.pack(self[propname]))
+                --params[fieldName] = "'" .. MsgPack.pack(self[propname]) .. "'"
+                params[fieldName] = result
             end
         elseif self.class.schema[fieldName][1] == "string" then
-            params[fieldName] = "'" .. self[propname] .. "'"
+            local result = mysqlproxy:quote_sql_str(self[propname])
+            --params[fieldName] = "'" .. self[propname] .. "'"
+            params[fieldName] = result
         else
             params[fieldName] = self[propname]
         end
@@ -136,7 +140,7 @@ function ModelBaseMysql:save()
             update_list = update_list .. "`" .. k .. "`=" .. v
         end
         sql = string_format(sql, tbName, key_list, value_list, update_list)
-        mysqlproxy:query(sql)
+        local res = mysqlproxy:query(sql)
     end
 end
 
diff --git a/src/shared/mysqlproxy.lua b/src/shared/mysqlproxy.lua
index 36c3ca2..a264233 100644
--- a/src/shared/mysqlproxy.lua
+++ b/src/shared/mysqlproxy.lua
@@ -18,7 +18,7 @@ setmetatable(mysqlproxy, { __index = function(t, k)
 	local cmd = string.upper(k)
     local f = function (self, ...)
         if k == "query" then
-            --print(...)
+			--print(...)
         end
 		local ok, result = pcall(skynet.call, mysqld, "lua", cmd, ...)
 		if not ok then
--
libgit2 0.21.2