mysql二进制数据加上quote_sql_str

测试
1 parent 2ca93972
Showing 2 changed files with 8 additions and 4 deletions Show diff stats
src/shared/ModelBaseMysql.lua
src/shared/mysqlproxy.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
  
@@ -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