<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')

                    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'添加成功')

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!