每个视图更改数据库并访问每个视图的多个数据库

Question

我在Pyramid中使用SQLAlchemy时遇到了一些问题.虽然我可以找到我需要的例子,但它们通常很短而且缺乏.所以我最终得到的补丁代码几乎没有任何意义.所以我希望有人可以更充分地说明我需要做些什么.

我有4个数据库都具有相同的架构.我希望能够从一个金字塔应用程序处理它们,有时列出来自所有4个数据库的所有"订单",有时只列出"site1"中的所有"订单".由于模式相同,我还为数据库使用相同的模型类.

我已经尝试了sqlahelper和普通的SQLAlchemy而没有运气.下面的代码使用sqlahelper,但我很乐意使用任何有效的方法:

__init__.py

site1_eng = engine_from_config(settings, prefix='site1.')
site2_eng = engine_from_config(settings, prefix='site2.')
site3_eng = engine_from_config(settings, prefix='site3.')

sqlahelper.add_engine(site1_eng, 'site1_eng')
sqlahelper.add_engine(site2_eng, 'site2_eng')

views.py

def site_orders(request):
    site = request.matchdict['site']
    db_eng = sqlahelper.get_engine(("%s_eng" % (site)))
    conn = db_eng.connect()
    dbsession = sqlahelper.get_session()
    dbsession.configure(bind=conn)

    orders = dbsession.query(Order).order_by(Order.cdate.desc())[:100]

    return dict(orders=orders, pagetitle=(site+" Orders"))

怎么了？

好吧,我希望它会根据URL切换数据库,它确实!但是,选择哪个似乎是完全随机的.所以/ orders/site1 /有时会转到site2数据库,有时会转到site3.刷新通常会每次都切换它选择的数据库.其他网址也是如此.

它几乎就好像会话没有绑定到数据库并且它的选择当时在会话中发生了什么？这可能没有意义 - 我对SQLAlchemy的理解并不是很好.

真的希望有人可以提供帮助,因为这一切都取决于能否在视图中快速轻松地切换数据库,而且目前似乎完全无法控制它.

注意:我最初尝试关注和更改Pyramid SQLA + URL Dispatcher教程,该教程使用:

DBSession = scoped_session(sessionmaker(extension=ZopeTransactionExtension()))

但是在找到sqlahelper时我删除了它.如果我应该使用它让我知道.

Answer 1

为每个请求配置和连接对我来说似乎很多工作.我将在我的模型模块中创建四个会话处理程序,并从中进行选择.

例:

models/__init__.py

DBSession1 = scoped_session(sessionmaker(extension=ZopeTransactionExtension()))  
DBSession2 = scoped_session(sessionmaker(extension=ZopeTransactionExtension()))  
DBSession3 = scoped_session(sessionmaker(extension=ZopeTransactionExtension()))  
DBSession4 = scoped_session(sessionmaker(extension=ZopeTransactionExtension()))  
metadata1 = MetaData()                                                           
metadata2 = MetaData()                                                           
metadata3 = MetaData()                                                           
metadata4 = MetaData()                                                           

def initialize_sql(engines, drop_db=False):                                      
    DBSession1.configure(bind=engine[0])
    DBSession2.configure(bind=engine[1])                                            
    DBSession3.configure(bind=engine[2])                                            
    DBSession4.configure(bind=engine[3])                                            
    metadata1.bind = engine[0]                                            
    metadata2.bind = engine[1]                                            
    metadata3.bind = engine[2]                                            
    metadata4.bind = engine[3]  

然后在你看来:

from mypackage.models import DBSession1, DBSession2, DBSession3, DBSession4

def site_orders(request)                                                      
    site = request.matchdict['site']                                                      
    dbsession = globals().get("DBSession%d" % site)                                                      
    orders = dbsession.query(Order).order_by(Order.cdate.desc())[:100]                                                      
    return dict(orders=orders, pagetitle=(site+" Orders"))