<div class="cnblogs_Highlighter">
<pre class="brush:python;gutter:true;"> 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')
s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>1 = resource_apple_account.get_s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>_by_question_answer(q1,a1)
s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>2 = resource_apple_account.get_s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>_by_question_answer(q2,a2)
s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>3 = resource_apple_account.get_s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>_by_question_answer(q3,a3)
if not s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>1: # 判断<a href="https://www.jb51.cc/tag/shujuku/" target="_blank" class="keywords">数据库</a>中是否存<a href="https://www.jb51.cc/tag/zaizhe/" target="_blank" class="keywords">在这</a>个数据，没有则新建
s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>1 = resource_apple_account.AppleAccountS<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>(question=q1,answer=a1)
db.session.add(s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>1)
# 如果<a href="https://www.jb51.cc/tag/zaizheli/" target="_blank" class="keywords">在这里</a>写了commit，后面也可以取到这个新建数据的id，但是后面新建account对象时也要commit，
# 如果出现问题，rollback只会回滚最后一次commit，这里的就不能一起回滚了
if not s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>2:
s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>2 = resource_apple_account.AppleAccountS<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>(question=q2,answer=a2)
db.session.add(s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>2)
if not s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>3:
s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>3 = resource_apple_account.AppleAccountS<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>(question=q3,answer=a3)
db.session.add(s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>3)
# 新建对象
account_obj = resource_apple_account.AppleAccountCore(account=account,password=password,creator_id=creator.id)
db.session.add(account_obj)
db.session.flush()
# 将数据刷新到<a href="https://www.jb51.cc/tag/shujuku/" target="_blank" class="keywords">数据库</a>,这样才能取到新建对象的id，其实commit()也可以，但是为了保证rollback，
# 将整个事件回滚，所有用的flush，commit<a href="https://www.jb51.cc/tag/mo/" target="_blank" class="keywords">默</a>认这次事件完成了，rollback只能回滚此次事件最后一次commit的<a href="https://www.jb51.cc/tag/neirong/" target="_blank" class="keywords">内容</a>，
# 如果在上面还有其他commit，则上面commit的<a href="https://www.jb51.cc/tag/neirong/" target="_blank" class="keywords">内容</a>不会被回滚，可以任务flush只是把数据先存入<a href="https://www.jb51.cc/tag/shujuku/" target="_blank" class="keywords">数据库</a>，
# 但是此次事件还有彻底结束，但是commit就是彻底结束了
map1 = resource_apple_account.AppleAccountS<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>Map(apple_account_core_id=account_obj.id,apple_account_s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>_id=s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>1.id)
map2 = resource_apple_account.AppleAccountS<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>Map(apple_account_core_id=account_obj.id,apple_account_s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>_id=s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>2.id)
map3 = resource_apple_account.AppleAccountS<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>Map(apple_account_core_id=account_obj.id,apple_account_s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>_id=s<a href="https://www.jb51.cc/tag/ecurity/" target="_blank" class="keywords">ecurity</a>3.id)
db.session.add_all([map1,map2,map3])
db.session.commit()
except Exception as e:
print u'<a href="https://www.jb51.cc/tag/cuowu/" target="_blank" class="keywords">错误</a>信息',e
db.session.rollback()
return rest_base.restful_json(data=u'<a href="https://www.jb51.cc/tag/tianjia/" target="_blank" class="keywords">添加</a>失败',code=406)
return rest_base.restful_json(data=u'<a href="https://www.jb51.cc/tag/tianjia/" target="_blank" class="keywords">添加</a>成功')
