使用SQLAlchemy与Pandas查询时含单引号值的UndefinedColumn报错求助

问题原因 #

你手动替换单引号后，直接用字符串格式化插入tuple时，Python会自动用双引号包裹包含特殊字符的元素（比如"fish''s"）。而在PostgreSQL中，双引号用于标识列名/表名，而非字符串，这就导致数据库把"fish''''s"当成了列名，而非你要匹配的字符串，从而抛出“列不存在”的错误。另外手动转义单引号不仅容易出错，还存在SQL注入风险。

正确解决方案 #

推荐使用参数化查询，让SQLAlchemy/psycopg2自动处理参数转义，既安全又能避免格式问题。

方法一：使用Pandas read_sql 的 params 参数

from sqlalchemy import create_engine
import pandas as pd

engine = create_engine('postgresql://xxx:5439/data_base')
items = ('fish', 'cow', "fish's")

# 根据元素数量生成对应数量的占位符
placeholders = ', '.join(['%s'] * len(items))
query_string = f"""
  select * from my_table
  where item in ({placeholders})
"""

df = pd.read_sql(query_string, engine, params=items)

方法二：使用SQLAlchemy text 对象绑定参数

from sqlalchemy import create_engine, text
import pandas as pd

engine = create_engine('postgresql://xxx:5439/data_base')
items = ('fish', 'cow', "fish's")

# 用:text_name作为命名参数
query = text("""
  select * from my_table
  where item in :items
""")

df = pd.read_sql(query, engine, params={'items': items})

这两种方法都会自动处理字符串中的单引号转义，同时避免SQL注入问题，也不会出现双引号被误解析为列名的情况。

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