您好, 欢迎来到 !    登录 | 注册 | | 设为首页 | 收藏本站

Flask-SQLAlchemy-会话如何与多个数据库一起使用?

Flask-SQLAlchemy-会话如何与多个数据库一起使用?

Flask-sqlAlchemy使用定制的会话,该会话根据__bind_key__映射类中的给定属性处理绑定路由。实际上,它实际上将该键作为信息添加到创建的表中。换句话说,Flask不会创建多个会话,每个绑定一个会话,而是一个单个会话,该会话根据绑定键路由到正确的可连接对象(引擎/连接)。请注意,香草sqlAlchemy具有开箱即用的类似功能

在这两种情况下,如何引用特定数据库的会话/事务?如果我使用db.session.commit()系统,那么是否对所有涉及的数据库都进行提交,但是如果我只想对单个数据库进行提交,该怎么办?

在会话中使用会话拥有的连接来颠覆并向特定数据库提交提交不是一个好主意。会话是一个整体,并跟踪对象实例的状态,在需要时刷新对数据库的更改等。这意味着会话所处理的事务不仅是数据库事务,而且是会话本身的事务。所有这些都应该提交和回滚。

另一方面,您可以创建新的sqlAlchemy(或Flask- sqlAlchemy)会话,这些会话可能通过绑定之一加入正在进行的事务

session = db.create_scoped_session(
    options=dict(bind=db.get_engine(app, 'oracle_bind'),
                 binds={}))

这就是请求请求的内容。它允许使用现有的事务连接作为新Flask-sqlAlchemy会话 绑定。例如,在测试中这是非常有用的,从该请求请求的原理中可以看出。这样,您可以拥有一个“主”事务,例如可以回滚测试中完成的所有操作。

请注意,如果存在 bind_key ,则SignallingSession始终会查询db.get_engine()方法。这意味着示例会话无法在没有绑定键的情况下查询表,并且该表在您的oracle DB上不存在,但仍适用于具有 mssql_bind 键的表。

另一方面,您链接到的问题确实列出了将sql发出到特定绑定的方法

rows = db.session.execute(query, params,
                          bind=db.get_engine(app, 'oracle_bind'))

还列出了其他不太显式的方法,但是显式比隐式更好。

Python 2022/1/1 18:35:45 有340人围观

撰写回答


你尚未登录,登录后可以

和开发者交流问题的细节

关注并接收问题和回答的更新提醒

参与内容的编辑和改进,让解决方法与时俱进

请先登录

推荐问题


联系我
置顶