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

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

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏不想当开发的产品不是好测试

pip is configured with locations that require TLS/SSL, however the ssl module in Python is not avail

# 背景 安装pip后发现执行pip install pytest,提示下面错误 pip is configured with locations that r...

1.1K11
来自专栏Aloys的开发之路

Unix/Linux操作系统中如何在sqlplus/rman中使用方向键

默认情况下在Unix/Linux中使用Oracle的sqlplus/rman是无法使用↑↓←→几个方向键进行操作的,要想达到Windows下使用sqlplus/...

2116
来自专栏xingoo, 一个梦想做发明家的程序员

公司内网,无法使用yum在线下载,肿么办?

1 配置上网代理   编辑/etc/yum.conf,增加如下属性: proxy=你的代理地址 proxy_user=你的用户名 proxy_passwor...

32710
来自专栏深度学习之tensorflow实战篇

windows下mysql忘记root密码,如何重设密码

添加windows下mysql服务 以管理员身份打开cmd,执行 mysqld --install net stop mysql # 忘记密码找回 找到mysq...

3295
来自专栏积累沉淀

hbase集群安装(1)-ssh安装及配置

安装ssh服务器端 赋予tg用户权限 sudo chown -R tg:tg /software/ ? 查看用户被赋予的权限 ? 1.检查ssh客户端是否安装:...

2115
来自专栏运维小白

增加网卡注意点

在虚拟机增加一个新的网卡之后,并设置为仅主机模式 开启虚拟机,用ifconfig命令,查看是否已经加载了网卡——>安装ifconfig包:yum install...

2338
来自专栏编程思想之路

Android6.0之修改或者查看系统属性值

系统属性值存在于system.prop文件中,也有一些存在于settings中 1,查看settingsprovider中的值的方法 命令为adb shell ...

4265
来自专栏测试文章

当影响范围内Nginx默认配置文件中开启缓存

当影响范围内Nginx默认配置文件中开启缓存功能时,攻击者可以通过发送包含恶意构造 range 域的 header 请求,来获取响应中的缓存文件头部信息。在某些...

20311
来自专栏运维技术迷

HTTP响应可视化测试工具-httpstat

httpstat是一款可以测试http状态的可视化工具,通过这个工具可以看出来http响应信息。包括dns解析、tcp连接等信息,httpstat一共有gola...

3968
来自专栏FreeBuf

Python编写的开源Struts2全版本漏洞检测工具

0x01 说明: 由于struts2框架频繁爆出漏洞,为方便安全从业人员检测并及时修复,遂将struts历史版本payload整合在一起(ST2-005至ST2...

6926

扫码关注云+社区

领取腾讯云代金券