adodbapi ormオブジェクトクエリー(3)


転載して出典を明記する http://blog.csdn.net/xugangjava/article/details/7565420
前編に続き、2つのアダプタを書きます.1つはQueryをクエリーするために、もう1つはExecuteに使用します.
########################################################################
#decorators
def Query(fn):
	'''decorator of connection 
	use this funciton can use conn to operator db
	using conn=None param to user conn'''
	def wrapper(*args, **kv):
		conn=connect()
		kv['conn']=conn
		try:
			return fn(*args, **kv)
		except:
			LogErr()
			raise
		finally:
			conn.close()
	return wrapper
def Execute(fn):
	'''decorator of connection 
	use this funciton can use conn to operator db
	using conn=None param to user conn'''
	def wrapper(*args, **kv):
		conn=connect()
		kv['conn']=conn
		try:
			result= fn(*args, **kv)
			conn.commit()
			return result
		except:
			conn.rollback()
			LogErr()
			raise
		finally:
			conn.close()
	return wrapper

最後に我々の論理コード
########################################################################
#proc and function
@Execute
def  procLogin(name,pwd,ip,mac,conn=None):
	cur=conn.cursor()
	uid,val,remark,opResult=0,0,'',''
	param=(name,pwd, AvailablePeopleNum,mac, Ip2Int(ip), ip,False,uid,val,remark,opResult)
	param=cur.callproc('Proc_login',param)
	uid,val,remark,opResult=param[-4],param[-3],param[-2],param[-1]
	user=None
	if val==2:user=findUserByID(conn,uid)
	return user,remark

パラメータconn=NoneはExecuteにconnが注入され、私たちの論理関数はconnectionの管理を全く気にしなくなりました.
吐きそうにない繰り返しのtry catch finallyでconnectionを管理しました大笑
Executeを実行すると自動的に提出され、Executeを間違えたらロールバックされます.Queryも同じです.
bug where関数を変更するにはsql><=lineの接合に問題があります.
#where
def where(**kv):
	keys=''
	params=[]
	for key in kv.keys():
		if keys:keys+=' and '
		else: keys=' where '
		if key.endswith('_gt'):
			exp=key.replace('_gt',' > ')
		elif key.endswith('_lt'):
			exp=key.replace('_lt',' < ')
		elif key.endswith('_ge'):
			exp=key.replace('_ge',' >= ')
		elif key.endswith('_le'):
			exp=key.replace('_le',' <= ')
		elif key.endswith('_like'):
			exp=key.replace('_like',' like ')
		else:
			exp=key+'='
		keys+=exp+'?'
		param=kv[key]
		if isinstance(param,unicode):param=param.encode('gbk')
		params.append(param)
	return keys,tuple(params)

関数where(id=0、row_gt=0)は、(where id=?and row>?、(0,0))を返します.