python - 使用 sqlalchemy 加入两个不同的数据库

问题描述

我试图在 MSSQL 中加入 2 个数据库。

这是 SQL 查询：

SELECT od.Indice, cs.Argued
FROM HN_Ondata.dbo.ODCalls as od
JOIN HN_ADMIN.dbo.CallStatus as cs ON od.CallStatusGroup = cs.StatusGroup

我试过了：

创建两个引擎，使表具有自动加载并查询它。
创建两个引擎，打开两个会话并进行子查询。
创建两个引擎创建 table2 的 CTE。
创建一个元数据绑定到 database1 reflect table1 然后为 table2 调用 reflect(bind=database2)

总是以这个错误结束：

pymssql.ProgrammingError: (208, b"Invalid object name 'CallStatus'.DB-Lib error message 20018, severity 16:\nGeneral SQL Server error: Check messages from the SQL Server\n")

我得到的当前解决方案是使用 session.execute 并写下原始 sql，我可以坚持使用它，但我很奇怪有没有办法用 sqlalchemy ORM 做到这一点？

编辑1：

这是我的代码：

 db1 = DatabaseManager(settings.DATABASE['hrm'], database='HN_Ondata')
 db2 = DatabaseManager(settings.DATABASE['hrm'], database='HN_ADMIN')

 metadata1 = MetaData(bind=db1.database)
 metadata2 = MetaData(bind=db2.database)

 table1 = Table('ODCalls', metadata1, autoload=True)
 table2 = Table('CallStatus', metadata2, autoload=True)


 with db1.session(raise_err=True) as session:
     result = (
         session
         .query(table1.c.Indice, table2.c.Argued)
         .join(table2, table1.c.CallStatusGroup == table2.c.StatusGroup)
         .all()
     )

谁产生以下查询：

SELECT [ODCalls].[Indice] AS [ODCalls_Indice], [CallStatus].[Argued] AS [CallStatus_Argued] 
FROM [ODCalls]
JOIN [CallStatus] ON [ODCalls].[CallStatusGroup] = [CallStatus].[StatusGroup]

标签： pythonsql-serversqlalchemy

找到解决方案感谢 Ryan Gadsdon 和 Ilja Everilä 为我指路。

您需要在表架构参数中精确 database.schema，如下所示：

table1 = Table('ODCalls', metadata1, autoload=True, schema='HN_Odcalls.dbo')

仅当表引用您的引擎未连接的数据库时，才需要在模式中指定数据库，如果您在模式参数中精确 database.schema，则可以将该表与连接到同一服务器上任何数据库的任何引擎一起使用。

http://docs.sqlalchemy.org/en/latest/dialects/mssql.html#multipart-schema-names

python - 使用 sqlalchemy 加入两个不同的数据库

问题描述

解决方案

推荐阅读