sqlachemy 獲取新創建對象的id，flush與commit
阿新 • • 發佈：2018-04-27
core base _id mit cep pre obj 但是 uri
for account_info in valid_account_detail:
try:
account = account_info.get(‘account‘)
password = account_info.get(‘password‘)
# date = account_info.get(‘date‘)
q1 = account_info.get(‘q1‘)
a1 = account_info.get(‘a1‘)
q2 = account_info.get(‘q2‘)
a2 = account_info.get(‘a2‘)
q3 = account_info.get(‘q3‘)
a3 = account_info.get(‘a3‘)
security1 = resource_apple_account.get_security_by_question_answer(q1, a1)
security2 = resource_apple_account.get_security_by_question_answer(q2, a2)
security3 = resource_apple_account.get_security_by_question_answer(q3, a3)
if not security1: # 判斷數據庫中是否存在這個數據，沒有則新建
security1 = resource_apple_account.AppleAccountSecurity(question=q1, answer=a1)
db.session.add(security1)
# 如果在這裏寫了commit，後面也可以取到這個新建數據的id，但是後面新建account對象時也要commit，
# 如果出現問題，rollback只會回滾最後一次commit，這裏的就不能一起回滾了
if not security2:
security2 = resource_apple_account.AppleAccountSecurity(question=q2, answer=a2)
db.session.add(security2)
if not security3:
security3 = resource_apple_account.AppleAccountSecurity(question=q3, answer=a3)
db.session.add(security3)
# 新建對象
account_obj = resource_apple_account.AppleAccountCore(account=account, password=password,
creator_id=creator.id)
db.session.add(account_obj)
db.session.flush()
# 將數據刷新到數據庫,這樣才能取到新建對象的id，其實commit()也可以，但是為了保證rollback，
# 將整個事件回滾，所有用的flush，commit默認這次事件完成了，rollback只能回滾此次事件最後一次commit的內容，
# 如果在上面還有其他commit，則上面commit的內容不會被回滾，可以任務flush只是把數據先存入數據庫，
# 但是此次事件還有徹底結束，但是commit就是徹底結束了
map1 = resource_apple_account.AppleAccountSecurityMap(apple_account_core_id=account_obj.id,
apple_account_security_id=security1.id)
map2 = resource_apple_account.AppleAccountSecurityMap(apple_account_core_id=account_obj.id,
apple_account_security_id=security2.id)
map3 = resource_apple_account.AppleAccountSecurityMap(apple_account_core_id=account_obj.id,
apple_account_security_id=security3.id)
db.session.add_all([map1, map2, map3])
db.session.commit()
except Exception as e:
print u‘錯誤信息‘, e
db.session.rollback()
return rest_base.restful_json(data=u‘添加失敗‘, code=406)
return rest_base.restful_json(data=u‘添加成功‘)
sqlachemy 獲取新創建對象的id，flush與commit