如何在Python中将CSV列作为变量传入Oracle SQL查询？

直接上可运行的代码和关键注意点，帮你避开踩过的坑：

完整实现代码 #

import pandas as pd
import oracledb  # 官方新版驱动，替代旧的cx_Oracle，兼容性更好

# 1. 读取CSV，提取目标列
csv_df = pd.read_csv("your_data.csv")
# 按需转换数据类型，比如数据库列是INT就转int，DATE就转datetime
col1_list = csv_df["csv_col1"].astype(str).tolist()  # 示例转字符串，根据实际调整
col2_list = csv_df["csv_col2"].astype(int).tolist()

# 2. 建立Oracle连接
conn = oracledb.connect(
    user="your_username",
    password="your_password",
    dsn="your_host:your_port/your_service_name"
)

# 3. 构造正确的参数化SQL
# 重点：匹配CSV每行的(col1, col2)组合，避免笛卡尔积
sql = """
SELECT t.*
FROM your_oracle_table t
WHERE (t.db_col1, t.db_col2) IN (
    SELECT 
        A.column_value AS csv_col1,
        B.column_value AS csv_col2
    FROM 
        TABLE(SYS.ODCIVARCHAR2LIST(:col1_params)) A,
        TABLE(SYS.ODCIVARCHAR2LIST(:col2_params)) B
    WHERE 
        A.ROWNUM = B.ROWNUM
)
"""

# 4. 绑定参数并查询，转DataFrame
result_df = pd.read_sql(
    sql,
    conn,
    params={"col1_params": col1_list, "col2_params": col2_list}
)

# 收尾
conn.close()
print(result_df.head())

关键踩坑提示 #

• 占位符格式：Oracle用:变量名，别用MySQL的%s，手动写SQL必须严格遵循这个格式，pd.read_sql会自动适配驱动的参数绑定规则。
• 组合条件匹配：如果要匹配CSV里的每行成对值，绝对不能写db_col1 IN (...) AND db_col2 IN (...)——这会让两个列的所有值产生笛卡尔积，结果完全不符合预期，必须用上面的ROWNUM关联集合，或者用UNION ALL拼接多行条件（集合方式更简洁）。
• 数据类型对齐：CSV读出来的默认是字符串，数据库列如果是数字、日期，必须先转换类型，比如用astype(int)或者pd.to_datetime()，不然绑定参数时会报类型不兼容错误。
• 驱动选择：放弃旧的cx_Oracle，oracledb是Oracle官方维护的新版驱动，支持最新Python版本，安装直接执行pip install oracledb。

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