45 lines
1.1 KiB
Python
45 lines
1.1 KiB
Python
|
from day23sk.model.order_model import Order
|
||
|
|
|
||
|
|
|
||
|
|
def add_student_dao(o,db):
|
||
|
|
try:
|
||
|
|
o1 = Order( **o) # 将字典解析成键值对关键字参数输入 title = xxx, userid = XXX
|
||
|
|
db.add(o1)
|
||
|
|
except Exception:
|
||
|
|
db.rollback()
|
||
|
|
return False
|
||
|
|
else:
|
||
|
|
db.commit()
|
||
|
|
return True
|
||
|
|
|
||
|
|
|
||
|
|
|
||
|
|
def update_orders_dao(id,update_data,db):
|
||
|
|
try: # 数据更新是有返回值的，返回的是影响的行数
|
||
|
|
rows = db.query( Order ).filter( Order.id == id ).update( update_data )
|
||
|
|
except Exception:
|
||
|
|
db.rollback()
|
||
|
|
return False
|
||
|
|
else:
|
||
|
|
db.commit()
|
||
|
|
return rows
|
||
|
|
|
||
|
|
def delete_orders_dao(id,db):
|
||
|
|
try:
|
||
|
|
rows = db.query( Order ).filter( Order.id == id ).delete()
|
||
|
|
except Exception:
|
||
|
|
db.rollback()
|
||
|
|
return None
|
||
|
|
else:
|
||
|
|
db.commit()
|
||
|
|
return rows
|
||
|
|
|
||
|
|
def get_orders_dao(order_title,db):
|
||
|
|
try:
|
||
|
|
rows = db.query( Order ).filter( Order.title == order_title ).all()
|
||
|
|
except Exception:
|
||
|
|
db.rollback()
|
||
|
|
return False
|
||
|
|
else:
|
||
|
|
db.commit()
|
||
|
|
return rows
|