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

function getFriendCount(roleId)
    local res = mysqlproxy:query(string.format("SELECT `id` FROM `Friend` WHERE `roleid` = %s", roleId))
    if res["errno"] then
        return globalCsv.friendListLimit
    end

    return #res
end

function addFriend(roleId, friendId)
	local stmt_csp = mysqlproxy:prepare("call add_friends(?, ?, ?)")
    local r = mysqlproxy:execute(stmt_csp, roleId, friendId, skynet.timex())
    if r[1][1]["t_error"] == 0 then
		rpcRole(roleId, "addFriend", friendId)
		rpcRole(friendId, "addFriend", roleId)
    end
end

function delFriend(roleId, friendId)
	local stmt_csp = mysqlproxy:prepare("call del_friends(?, ?)")
    local r = mysqlproxy:execute(stmt_csp, roleId, friendId)
    if r[1][1]["t_error"] == 0 then
		rpcRole(roleId, "delFriend", friendId)
		rpcRole(friendId, "delFriend", roleId)
    end
end

function roleExists(roleId)
    local res = mysqlproxy:query(string.format("SELECT `id` FROM `Role` WHERE `id` = %s", roleId))
    if res["errno"] or not next(res) then
        return false
    end

    return true
end

function roleUidExists(uid)
    local res = mysqlproxy:query(string.format("SELECT `name` FROM `Role` WHERE `uid` = '%s'", uid))
    if res["errno"] or not next(res) then
        return false
    end

    return true, res[1]["name"]
end