sql-server – SQLAlchemy：单个会话中的多个数据库(在同一台服

发布时间：2020-12-12 06:37:05 所属栏目：MsSql教程来源：网络整理

导读：我正在运行MS SQL Server,并且我正在尝试在位于不同数据库(在同一服务器上)的两个表之间执行JOIN.如果我使用pyodbc连接到服务器(没有指定数据库),那么以下原始SQL工作正常. SELECT * FROM DatabaseA.dbo.tableA tblA INNER JOIN DatabaseB.dbo.tableB tblB ON

我正在运行MS SQL Server,并且我正在尝试在位于不同数据库(在同一服务器上)的两个表之间执行JOIN.如果我使用pyodbc连接到服务器(没有指定数据库),那么以下原始SQL工作正常.

SELECT * FROM DatabaseA.dbo.tableA tblA 
         INNER JOIN DatabaseB.dbo.tableB tblB 
         ON tblA.id = tblB.id

不幸的是,我似乎无法使用SQLAlchemy使模拟工作.我在几个地方看过这个话题：

> Is there a way to perform a join across multiple sessions in sqlalchemy?
> Cross database join in sqlalchemy
> How do I connect to multiple databases on the same SQL Server with sqlalchemy?
> How can I use multiple databases in the same request in Cherrypy and SQLAlchemy?

大多数人建议使用不同的引擎/会话,但我至关重要的是需要在数据库之间执行连接,所以我不认为这种方法会有所帮助.另一个典型的建议是使用schema参数,但这似乎对我不起作用.例如,以下不起作用.

engine = create_engine('mssql+pyodbc://...')  #Does not specify database

metadataA = MetaData(bind=engine,schema='DatabaseA.dbo',reflect=True)
tableA = Table('tableA',metadataA,autoload=True)

metadataB = MetaData(bind=engine,schema='DatabaseB.dbo',reflect=True)
tableB = Table('tableB',metadataB,autoload=True)

我也尝试过schema =’DatabaseA’和schema =’dbo’的varients.在所有情况下,SQLAlchemy都会为表A和B抛出NoSuchTableError.任何想法？

解决方法

如果您可以在其中一个数据库中创建同义词,则可以将查询保持为该单个数据库的本地查询.

USE DatabaseB;
GO
CREATE SYNONYM dbo.DbA_TblA FOR DatabaseA.dbo.tableA;
GO

您的查询将变为：

SELECT * FROM dbo.DbA_TblA tblA 
     INNER JOIN dbo.tableB tblB 
     ON tblA.id = tblB.id

（编辑：李大同）

【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容!