Blame view

src/utils/MysqlUtil.lua 645 Bytes
913e070e   liuzujun   添加订单表,全局id定时回写数据库
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
  local skynet = require "skynet"
  local mysqlproxy = require "shared.mysqlproxy"
  
  
  function getDbCfgVal(tbName, keyName, fieldName)
      local sql = string.format("SELECT * FROM `%s` WHERE `key` = '%s';", tbName, keyName)
      local res = mysqlproxy:query(sql)
      if not next(res) or res.errno then
          return
      end
  
      return res[1][fieldName]
  end
  
  function setDbCfgVal(tbName, keyName, fieldName, fieldVal)
      if type(fieldVal) == "string" then fieldVal = string.format("'%s'", fieldVal) end
      local sql = string.format("UPDATE `%s` SET `%s` = %s WHERE `key` = '%s';", tbName, fieldName, fieldVal, keyName)
      mysqlproxy:query(sql)
  end