Django中使用Raw SQL跨多数据库查询的问题求助

1. 先在Oracle端创建数据库链接（DB Link） #

跨库查询的核心是让其中一个Oracle实例能直接访问另一个，所以得先建DB Link。假设你要从primary库访问secondary库的数据，在primary的Oracle实例上执行这条SQL：

CREATE DATABASE LINK secondary_link
CONNECT TO secondary_db_user IDENTIFIED BY secondary_db_password
USING 'secondary_db_tns_name';

• 把secondary_link换成你自己想取的链接名
• secondary_db_user和secondary_db_password填secondary库的账号密码
• secondary_db_tns_name是primary服务器上配置的secondary库的TNS名称（要确保primary服务器能通过这个TNS连上secondary）

如果需要从secondary访问primary，就在secondary库上创建指向primary的DB Link就行。

2. 在Django里用单个连接执行带DB Link的Raw SQL #

Django的connections只能单个单个地取连接，你之前用connections['primary', 'secondary']是错误用法，这也是报错的核心原因。现在用任意一个已配置的连接（比如primary），执行包含DB Link的SQL就行：

from django.db import connections

def cross_db_query():
    # 获取primary库的游标
    with connections['primary'].cursor() as cursor:
        # 用@secondary_link指定secondary库的表
        cursor.execute("""
            SELECT t1.id, t2.name
            FROM table1 t1
            INNER JOIN table2@secondary_link t2 ON t1.foreign_id = t2.id
        """)
        results = cursor.fetchall()
    return results

Oracle会自动通过DB Link去secondary库拉数据，相当于在单条SQL里完成跨库关联。

3. 无权限建DB Link？试试分别查询后合并 #

如果因为权限问题没法建DB Link，那就分开从两个库查数据，再在Python代码里合并：

from django.db import connections

def cross_db_merge():
    # 查primary库的数据
    with connections['primary'].cursor() as cursor1:
        cursor1.execute("SELECT id, foreign_id FROM table1")
        primary_rows = cursor1.fetchall()
    
    # 查secondary库的数据，转成字典方便匹配
    with connections['secondary'].cursor() as cursor2:
        cursor2.execute("SELECT id, name FROM table2")
        secondary_map = {row[0]: row[1] for row in cursor2.fetchall()}
    
    # 合并两个数据集
    merged_results = [(t1_id, secondary_map.get(t1_fid)) for t1_id, t1_fid in primary_rows]
    return merged_results

这种方法适合数据量不大的场景，不用依赖Oracle的DB Link，但性能肯定不如直接用DB Link在数据库层面关联。

常见坑点 #

• 权限问题：建DB Link的账号需要有CREATE DATABASE LINK权限，访问远程表的账号要有对应表的SELECT权限
• TNS配置错误：如果连不上远程库，先检查primary服务器上的tsnames.ora配置是否正确
• 不要尝试用Django同时绑定两个连接执行单条SQL：每个游标只能属于一个数据库连接，这是你之前报错的核心原因

内容的提问来源于stack exchange，提问作者Logan