如何在Django中执行含多数据库链接的Oracle SQL查询？

1. 执行含数据库链接的SQL查询 #

在Django中，直接使用原生SQL+指定数据库连接是处理这类场景的直接方式，步骤如下：

• 从django.db导入connections，指定你在settings.py中配置好的Oracle数据库别名
• 获取游标执行查询，再将结果转换为易处理的格式

示例代码：

from django.db import connections

def run_cross_db_query():
    # 替换为你配置的Oracle数据库别名
    db_alias = 'oracle_db'
    query = """
    SELECT 
        CASE 
            WHEN ACDMH_LOC_CODE LIKE '02%' THEN 'KHOBAR'
            WHEN ACDMH_LOC_CODE LIKE '03%' THEN 'RIYADH'
            ELSE 'JEDDAH'
        END AS Region,
        ACDMH_INTF_YN,
        ACDMH_TRANSACTION_TYPE AS TRANSACTION_TYPE,
        ACDMH_SOURCE_DOC_NO AS SOURCE_DOC_NO,
        TO_CHAR(ACDMH_TRANSACTION_DATE, 'dd-MM-yyyy') AS TRANSACTION_DATE,
        ACDMH_CUSTOMER_ID AS CUSTOMER_No,
        CUSTOMER_NAME,
        TO_CHAR(ACDMH_CRE_DATE, 'dd-mm-yyyy') AS Pushed_date_WinIT,
        TO_CHAR(ACDMH_CRE_DATE, 'hh:mi:ss AM') AS Pushed_time_WinIT,
        ACDMH_INTF_ORA_REF AS ERP_REF,
        ACDMH_LOC_CODE AS LOC_CODE,
        ACDMD_ORIGINAL_INVOICE_NO AS ORIGINAL_INVOICE_NO,
        ACDMD_OLD_VALUE AS fake_PRICE,
        ACDMD_NEW_VALUE AS selling_price,
        ACDMD_TOTAL AS tran_value,
        ACDMD_TAX_AMOUNT AS TAX_AMOUNT
    FROM 
        AX_CREDIT_DEBIT_MEMO_HEADERS@erpbridge
        INNER JOIN AX_CREDIT_DEBIT_MEMO_LINES@erpbridge ON ACDMH_HEADER_ID = ACDMD_HEADER_ID
        LEFT JOIN AXKSA_ORACLE_CUSTOMER ON CUSTOMER_NUMBER = ACDMH_CUSTOMER_ID
    WHERE 
        -- 替换为你的实际查询条件
        ACDMH_TRANSACTION_DATE >= TO_DATE('01-01-2024', 'dd-mm-yyyy')
    """
    
    with connections[db_alias].cursor() as cursor:
        cursor.execute(query)
        # 获取查询结果的字段名
        columns = [col[0] for col in cursor.description]
        # 转换为字典列表，方便后续业务处理
        results = [dict(zip(columns, row)) for row in cursor.fetchall()]
    
    return results

2. Django处理Oracle数据库链接的配置与注意事项 #

• 数据库链接由Oracle端管理：@erpbridge这类数据库链接是在Oracle服务器上通过CREATE DATABASE LINK语句创建的，Django无需在settings.py中额外配置该链接，只需确保你配置的Oracle数据库用户拥有访问该链接的权限（比如通过GRANT语句授权）。
• 确保Oracle数据库配置正确：使用Django官方支持的Oracle驱动（如oracledb），示例配置：

  DATABASES = {
      'default': {
          # 你的默认数据库配置
      },
      'oracle_db': {
          'ENGINE': 'django.db.backends.oracle',
          'NAME': 'ORCL',  # Oracle服务名/SID
          'USER': 'your_username',
          'PASSWORD': 'your_password',
          'HOST': 'oracle_host',
          'PORT': '1521',
      }
  }
  

• 提前验证权限与连通性：直接登录到Oracle数据库，手动执行你的查询，确认该用户能正常通过@erpbridge访问远程数据，避免Django执行时出现权限不足或链接失败的错误。
• 匹配字符集与时区：确保Oracle数据库的字符集与Django的USE_TZ、TIME_ZONE配置一致，避免日期、字符串显示异常。

3. 原生SQL是否为正确方式？有没有更高效的方案？ #

• 原生SQL是当前场景的最优解：你的查询用到了Oracle特有的数据库链接语法，Django ORM无法识别@erpbridge这类写法，也无法直接构建跨数据库链接的关联查询，因此原生SQL是必须的选择。
• 更高效的优化方案：
  • 将复杂查询封装为Oracle视图：在Oracle中创建包含该查询逻辑的视图（如CREATE VIEW CREDIT_DEBIT_REPORT AS [你的查询]），然后在Django中为这个视图创建模型（标记为非托管），即可用ORM操作：

    from django.db import models
    
    class CreditDebitReport(models.Model):
        region = models.CharField(max_length=20, db_column='Region')
        transaction_type = models.CharField(max_length=50, db_column='TRANSACTION_TYPE')
        customer_no = models.CharField(max_length=30, db_column='CUSTOMER_No')
        # 其他字段对应视图中的列，注意db_column要匹配视图别名
        
        class Meta:
            managed = False  # 告诉Django不要修改这个视图
            db_table = 'CREDIT_DEBIT_REPORT'
    

    之后可通过ORM查询：CreditDebitReport.objects.using('oracle_db').filter(...)
  • 优化查询性能：在Oracle端为涉及的表（包括远程链接的表）添加合适的索引，避免全表扫描；若结果集较大，使用cursor.fetchmany(size=1000)分批获取数据，减少内存占用。

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