adodbapi ormオブジェクトクエリー(3)
転載して出典を明記する http://blog.csdn.net/xugangjava/article/details/7565420
前編に続き、2つのアダプタを書きます.1つはQueryをクエリーするために、もう1つはExecuteに使用します.
最後に我々の論理コード
パラメータconn=NoneはExecuteにconnが注入され、私たちの論理関数はconnectionの管理を全く気にしなくなりました.
吐きそうにない繰り返しのtry catch finallyでconnectionを管理しました
Executeを実行すると自動的に提出され、Executeを間違えたらロールバックされます.Queryも同じです.
bug where関数を変更するにはsql><=lineの接合に問題があります.
関数where(id=0、row_gt=0)は、(where id=?and row>?、(0,0))を返します.
前編に続き、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))を返します.