49 lines
1.2 KiB
Python
49 lines
1.2 KiB
Python
from http.client import HTTPException
|
|
|
|
from day24.model.order_model import Order
|
|
|
|
|
|
def add_student_dao(o,db):
|
|
try:
|
|
o1 = Order( **o) # 将字典解析成键值对关键字参数输入 title = xxx, userid = XXX
|
|
db.add(o1)
|
|
except:
|
|
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:
|
|
db.rollback()
|
|
return False
|
|
else:
|
|
db.commit()
|
|
return rows
|
|
|
|
|
|
def get_orders_dao(order_title,db):
|
|
try:
|
|
r = db.query(Order).filter( Order.title == order_title ).all()
|
|
except:
|
|
db.rollback()
|
|
return False
|
|
else:
|
|
return [{"order_id": i.id, 'order_title': i.title, "user_id": i.userid, "create_date": i.create_date,
|
|
"update_date": i.update_date} for i in r]
|
|
|
|
|
|
def delete_orders_dao(id,db):
|
|
try:
|
|
r = db.query( Order ).filter( Order.id == id ).delete()
|
|
except:
|
|
db.rollback()
|
|
return False
|
|
else:
|
|
db.commit()
|
|
return True |