我正在做一个 Flask 项目，我正在使用 Flask-SQLAlchemy。
我需要使用多个现有的数据库。
我创建了“app”对象和 SQLAlchemy 对象:
from flask import Flask
from flask_sqlalchemy import SQLAlchemy
app = Flask(__name__)
db = SQLAlchemy(app)
在配置中，我设置了默认连接和附加绑定(bind):
SQLALCHEMY_DATABASE_URI = 'postgresql://pg_user:pg_pwd@pg_server/pg_db'
SQLALCHEMY_BINDS = {
'oracle_bind': 'oracle://oracle_user:oracle_pwd@oracle_server/oracle_schema',
'mssql_bind': 'mssql+pyodbc://msssql_user:mssql_pwd@mssql_server/mssql_schema?driver=FreeTDS'
}
然后我使用声明式系统创建了表模型，并在需要时设置
__bind_key__ 参数来指示表所在的数据库。
例如:
class MyTable(db.Model):
__bind_key__ = 'mssql_bind'
__tablename__ = 'my_table'
id = db.Column(db.Integer, nullable=False, primary_key=True)
val = db.Column(db.String(50), nullable=False)
以这种方式，一切正常，当我进行查询时，它是在正确的数据库上进行的。
阅读 SQLAlchemy 文档和 Flask-SQLALchemy 文档我明白了这些事情
(我把它们写下来以检查我是否理解正确):
所以我可以这样做:
record = MyTable(1, 'some text')
db.session.add(record)
db.session.commit()
我不明白当我们在 Flask-SqlAlchemy 中使用多个数据库时，关于 session 会发生什么。
我验证了系统能够通过 __bind_key__ 参数在正确的数据库中正确绑定(bind)表，
因此，我可以通过 db.session 在不同的数据库中插入数据，并在提交时保存所有内容。
但是，我无法理解 Flask-SQLAlchemy 是否创建了多个 session (每个引擎一个)或者是否以不同的方式管理事物。
在这两种情况下，如何引用特定数据库的 session /事务？
如果我使用 db.session.commit()，系统会在所有涉及的数据库上提交，但如果我只想提交一个数据库，我该怎么办？
我会做类似的事情:
db.session('mssql_bind').commit()
但我不知道该怎么做。
我还看到了一个 Flask-SQLAlchemy 实现，它应该可以简化这些情况的管理:
问题:https://github.com/mitsuhiko/flask-sqlalchemy/issues/107
实现:https://github.com/mitsuhiko/flask-sqlalchemy/pull/249
但我不知道如何使用它。
在 Flask-SQLAlchemy 中，我如何专门为每个引擎管理 session ？
最佳答案
Flask-SQLAlchemy 使用 customized session根据给定的 __bind_key__ attribute in mapped class 处理绑定(bind)路由.在幕后，它实际上将该键作为信息添加到创建的表中。换句话说，Flask 不会创建多个 session ，一个用于每个绑定(bind)，而是根据绑定(bind) key 路由到正确的可连接(引擎/连接)的单个 session 。请注意， Vanilla SQLAlchemy 有 similar functionality开箱即用。
In both cases, how is it possible refer to the session/transaction of a specific database? If I use
db.session.commit()the system does the commit on all involved databases, but how can I do if I want to commit only for a single database?
在 session 中使用 session 拥有的连接来颠覆和提交对特定数据库的提交可能不是一个好主意。 session 是一个整体和keeps track of state对于对象实例，在需要时刷新对数据库的更改等。这意味着 session 处理的事务不仅是数据库事务，而且还是 session 自己的事务。所有这些都应该作为一个整体提交和回滚。
另一方面，您可以创建新的 SQLAlchemy(或 Flask-SQLAlchemy) session ，这可能是 join the ongoing transaction in one of the binds :
session = db.create_scoped_session(
options=dict(bind=db.get_engine(app, 'oracle_bind'),
binds={}))
这就是拉取请求的内容。它允许使用现有的事务连接作为新 Flask-SQLAlchemy session 的 绑定(bind)。这在测试中非常有用，正如该拉取请求的基本原理所示。这样你就可以拥有一个“主”事务，例如可以回滚在测试中完成的所有事情。
请注意，如果存在 bind_key，SignallingSession 始终会查询 db.get_engine() 方法。这意味着示例 session 无法查询没有绑定(bind)键且不存在于您的 Oracle 数据库中的表，但仍可用于具有您的 mssql_bind 键的表。
另一方面，您链接到的问题确实列出了向特定绑定(bind)发出 SQL 的方法:
rows = db.session.execute(query, params,
bind=db.get_engine(app, 'oracle_bind'))
还列出了其他不太显式的方法，但显式优于隐式。
关于python - Flask-SQLAlchemy - session 如何与多个数据库一起工作？，我们在Stack Overflow上找到一个类似的问题： https://stackoverflow.com/questions/38374005/
我正在学习如何使用Nokogiri，根据这段代码我遇到了一些问题:require'rubygems'require'mechanize'post_agent=WWW::Mechanize.newpost_page=post_agent.get('http://www.vbulletin.org/forum/showthread.php?t=230708')puts"\nabsolutepathwithtbodygivesnil"putspost_page.parser.xpath('/html/body/div/div/div/div/div/table/tbody/tr/td/div
总的来说，我对ruby还比较陌生，我正在为我正在创建的对象编写一些rspec测试用例。许多测试用例都非常基础，我只是想确保正确填充和返回值。我想知道是否有办法使用循环结构来执行此操作。不必为我要测试的每个方法都设置一个assertEquals。例如:describeitem,"TestingtheItem"doit"willhaveanullvaluetostart"doitem=Item.new#HereIcoulddotheitem.name.shouldbe_nil#thenIcoulddoitem.category.shouldbe_nilendend但我想要一些方法来使用
关闭。这个问题是opinion-based.它目前不接受答案。想要改进这个问题？更新问题，以便editingthispost可以用事实和引用来回答它.关闭4年前。Improvethisquestion我想在固定时间创建一系列低音和高音调的哔哔声。例如:在150毫秒时发出高音调的蜂鸣声在151毫秒时发出低音调的蜂鸣声200毫秒时发出低音调的蜂鸣声250毫秒的高音调蜂鸣声有没有办法在Ruby或Python中做到这一点？我真的不在乎输出编码是什么(.wav、.mp3、.ogg等等)，但我确实想创建一个输出文件。
Rails2.3可以选择随时使用RouteSet#add_configuration_file添加更多路由。是否可以在Rails3项目中做同样的事情？ 最佳答案 在config/application.rb中:config.paths.config.routes在Rails3.2(也可能是Rails3.1)中，使用:config.paths["config/routes"] 关于ruby-on-rails-Rails3中的多个路由文件，我们在StackOverflow上找到一个类似的问题
给定这段代码defcreate@upgrades=User.update_all(["role=?","upgraded"],:id=>params[:upgrade])redirect_toadmin_upgrades_path,:notice=>"Successfullyupgradeduser."end我如何在该操作中实际验证它们是否已保存或未重定向到适当的页面和消息？ 最佳答案 在Rails3中，update_all不返回任何有意义的信息，除了已更新的记录数(这可能取决于您的DBMS是否返回该信息)。http://ar.ru
我在我的项目目录中完成了compasscreate.和compassinitrails。几个问题:我已将我的.sass文件放在public/stylesheets中。这是放置它们的正确位置吗？当我运行compasswatch时，它不会自动编译这些.sass文件。我必须手动指定文件:compasswatchpublic/stylesheets/myfile.sass等。如何让它自动运行？文件ie.css、print.css和screen.css已放在stylesheets/compiled。如何在编译后不让它们重新出现的情况下删除它们？我自己编译的.sass文件编译成compiled/t
我有多个ActiveRecord子类Item的实例数组，我需要根据最早的事件循环打印。在这种情况下，我需要打印付款和维护日期，如下所示:ItemAmaintenancerequiredin5daysItemBpaymentrequiredin6daysItemApaymentrequiredin7daysItemBmaintenancerequiredin8days我目前有两个查询，用于查找maintenance和payment项目(非排他性查询)，并输出如下内容:paymentrequiredin...maintenancerequiredin...有什么方法可以改善上述(丑陋的)代
我正在寻找执行以下操作的正确语法(在Perl、Shell或Ruby中):#variabletoaccessthedatalinesappendedasafileEND_OF_SCRIPT_MARKERrawdatastartshereanditcontinues. 最佳答案 Perl用__DATA__做这个:#!/usr/bin/perlusestrict;usewarnings;while(){print;}__DATA__Texttoprintgoeshere 关于ruby-如何将脚
我主要使用Ruby来执行此操作，但到目前为止我的攻击计划如下:使用gemsrdf、rdf-rdfa和rdf-microdata或mida来解析给定任何URI的数据。我认为最好映射到像schema.org这样的统一模式，例如使用这个yaml文件，它试图描述数据词汇表和opengraph到schema.org之间的转换:#SchemaXtoschema.orgconversion#data-vocabularyDV:name:namestreet-address:streetAddressregion:addressRegionlocality:addressLocalityphoto:i
Rackup通过Rack的默认处理程序成功运行任何Rack应用程序。例如:classRackAppdefcall(environment)['200',{'Content-Type'=>'text/html'},["Helloworld"]]endendrunRackApp.new但是当最后一行更改为使用Rack的内置CGI处理程序时，rackup给出“NoMethodErrorat/undefinedmethod`call'fornil:NilClass”:Rack::Handler::CGI.runRackApp.newRack的其他内置处理程序也提出了同样的反对意见。例如Rack