前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >sqlachemy 获取新创建对象的id,flush与commit

sqlachemy 获取新创建对象的id,flush与commit

作者头像
用户1214487
发布2018-05-28 17:50:20
1.1K0
发布2018-05-28 17:50:20
举报
文章被收录于专栏:PythonPythonPython
                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'添加成功')
本文参与 腾讯云自媒体分享计划,分享自作者个人站点/博客。
原始发表:2018-04-27 ,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体分享计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档