Oracle多SELECT查询合并为单CSV字符串 无需多CURSOR实现咨询

核心结论 #

完全可以实现，不需要为每个SELECT单独定义游标。核心思路是一次性执行所有SQL查询，遍历返回的多个结果集，逐个处理后合并成单一CSV。

具体实现步骤 #

1. 读取并执行所有SQL查询 #

将SQL文件中的所有语句一次性传入数据库连接执行（大多数数据库驱动支持执行包含多个SELECT的脚本，会自动返回多个结果集）。以Python的psycopg2（PostgreSQL）为例：

import psycopg2
import csv
from io import StringIO

# 读取SQL文件内容
with open('queries.sql', 'r') as f:
    sql_script = f.read()

# 连接数据库
conn = psycopg2.connect("dbname=your_db user=your_user")
cur = conn.cursor()

# 执行整个SQL脚本，自动返回多个结果集
cur.execute(sql_script)

2. 遍历结果集并合并成CSV #

执行多查询后，通过cur.nextset()切换结果集，逐个读取数据并写入CSV流：

output = StringIO()
writer = csv.writer(output)
first_set = True

while True:
    # 获取当前结果集的列名
    columns = [desc[0] for desc in cur.description]
    # 写入表头：若需保留每个查询的表头则去掉判断，仅保留第一个表头则保留判断
    if first_set:
        writer.writerow(columns)
        first_set = False
    else:
        writer.writerow(['--- 下一个查询结果分割线 ---'])
        writer.writerow(columns)
    
    # 写入当前结果集的所有数据行
    writer.writerows(cur.fetchall())
    
    # 切换到下一个结果集，无结果则退出循环
    if not cur.nextset():
        break

# 获取最终CSV字符串
csv_str = output.getvalue()

# 关闭资源
cur.close()
conn.close()

3. 关键注意事项 #

• 驱动兼容性：确保使用的数据库驱动支持多结果集处理（如psycopg2、pyodbc、mysql-connector-python均支持）。
• SQL脚本规范：SQL文件中的多个SELECT语句用分号分隔，保证语法正确。
• 合并逻辑自定义：若所有查询列结构一致，可只保留一次表头；若结构不同，保留每个查询的表头更清晰。
• 大结果集优化：如果数据量极大，改用cur.fetchmany(1000)分批读取，避免内存溢出。

命令行替代方案 #

如果是命令行场景，可直接用数据库自带工具执行多查询并导出CSV，比如PostgreSQL的psql：

psql -d your_db -U your_user -f queries.sql --csv > combined_result.csv

无需写代码，直接生成合并后的CSV文件，适合简单场景。

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