FastAPI调用Snowflake存储过程时无法传入NULL值的问题求助

核心问题根源 #

你的代码通过手动拼接SQL字符串处理NULL值的方式非常脆弱，容易出现遗漏；而且当前的字符串格式化逻辑存在错误（误用字典而非元组传递参数），导致未填写字段被转为空字符串而非NULL。另外Snowflake自动生成ilike = ''的条件，本质是因为存储过程接收到了空字符串参数，内部逻辑据此生成了对应过滤规则。

分步解决方案 #

1. 确保FastAPI正确接收None值 #

先检查你的Pydantic请求模型，将可选字段定义为Optional[str] = None，比如：

from pydantic import BaseModel, Optional

class RequestData(BaseModel):
    data1: str
    data2: Optional[str] = None
    data3: Optional[str] = None
    # 其他字段同理

同时确认Express转发时保留前端的null值，不要将空字段转为空字符串。

2. 用参数化查询替代手动字符串拼接 #

放弃手动拼接CALL语句的方式，使用SQLAlchemy的参数化执行，Python的None会被自动映射为SQL的NULL，彻底避免字符串处理错误：

from sqlalchemy import text

# 整理所有参数，未填写的字段保持为None
params = [
    data1, data2, data3, data4, None,
    data5, data6, data7, data8, None,
    None, None, None, None  # 补全到存储过程要求的14个参数
]

# 构造参数化的存储过程调用语句
call_sql = text(f"CALL {environment}_DB.SCHEMA.PROCNAME(%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)")
results = db.execute(call_sql, params)

如果需要更清晰的参数管理，可以用命名参数：

call_sql = text("""
    CALL :db_schema.PROCNAME(
        :data1, :data2, :data3, :data4, :param5,
        :data5, :data6, :data7, :data8, :param9,
        :param10, :param11, :param12, :param13
    )
""")
results = db.execute(call_sql, {
    "db_schema": f"{environment}_DB.SCHEMA",
    "data1": data1,
    "data2": data2,
    "data3": data3,
    "data4": data4,
    "param5": None,
    "data5": data5,
    "data6": data6,
    "data7": data7,
    "data8": data8,
    "param9": None,
    "param10": None,
    "param11": None,
    "param12": None,
    "param13": None
})

3. 修复存储过程内部逻辑 #

当参数正确传递为NULL后，检查存储过程代码，确保在参数为NULL时，生成的是IS NULL而非ilike = ''的条件。比如将存储过程中类似WHERE col ilike :param的逻辑，调整为：

WHERE (:param IS NULL OR col ilike :param)

这样当参数为NULL时，该条件会自动忽略，不会生成空字符串过滤。

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