Firefly_DB模块 - daaoling/daaoling.github.io GitHub Wiki

#coding:utf8
'''
__author__ = 'Administrator'
'''

from gfirefly.dbentrust.dbpool import dbpool
from gfirefly.dbentrust.madminanager import MAdminManager
from gfirefly.dbentrust.memclient import mclient
from gfirefly.dbentrust.mmode import MAdmin

import json

config = json.load(open("config.json","r"))

dbconfig = config.get("db")
dbpool.initPool(**dbconfig)

memconfig = config.get('memcached')
urls = memconfig.get("urls")
hostname = str(memconfig.get('hostname'))
mclient.connect(urls, hostname)

mAdmin = MAdmin("cfg_errcode","id")
mAdmin.insert()
# insert
#  'cfg_errcode:_name' (71989768) = {str} 'cfg_errcode'
#  'cfg_errcode:_pk' (72003872) = {str} 'id'
#  'cfg_errcode:_timeout' (71989712) = {int} 1800
mAdmin.load()

MAdminManager().registe(mAdmin)

# 从数据库加载到mAdmin
# 其中一行的记录
#  'cfg_errcode:0:_name' (71601376) = {str} 'cfg_errcode:0'
#  'cfg_errcode:0:_pk' (71601544) = {str} 'id'
#  'cfg_errcode:0:data' (71601320) = {dict} {'msg': u'\u6210\u529f', 'id': 0L}

mMode = mAdmin.getObj(0)
# 根据 cfg_errcode:0:data 找到内存中对应的那一条memcache记录

mMode.update("msg","测试")
# 更新

MAdminManager().checkAdmins()
#保存到数据库