使用Psycopg2 execute_values向Postgres插入数据时子查询报错求助

你遇到的核心问题是：把SQL子查询当成字符串字面量传递给了execute_values，而不是让PostgreSQL去执行这个子查询。execute_values默认会把你传入的每个值都作为参数绑定，所以当你传'(SELECT id FROM city WHERE name =''Boston'')'时，它会把这个整个字符串当作id字段的取值——但id是整数类型，字符串和整数类型不匹配，自然就报错了。

下面给你几种可行的解决方案，按推荐程度排序：

方案1：先查询获取子查询结果，再作为参数插入 #

这是最简单也最安全的方式，先单独查询出Boston对应的id，再把这个整数作为普通参数传入valuesList：

import psycopg2
from psycopg2.extras import execute_values

try:
    conn = psycopg2.connect("dbname='test' user='postgres' host='localhost' password='serengeti'")
    conn.autocommit = True
except:
    print("I am unable to connect to the database")
cur = conn.cursor()

# 先查询得到Boston的id
cur.execute("SELECT id FROM city WHERE name = %s", ('Boston',))
boston_id = cur.fetchone()[0]  # 需确保city表中存在name='Boston'的行，否则fetchone会返回None

SQL = "INSERT INTO sample (id,name) VALUES %s"
valuesList = []
valuesList.append((5,'wolf'))
valuesList.append((boston_id,'tiger'))  # 直接用查询到的整数id

execute_values(cur, SQL, valuesList, page_size=1000000)

方案2：自定义execute_values的模板，直接嵌入子查询 #

如果你确实需要在批量插入语句中直接使用子查询（比如批量数据里有多个需要从其他表取值的项），可以通过自定义template参数，让子查询被直接解析为SQL而不是字符串参数：

SQL = "INSERT INTO sample (id,name) VALUES %s"
valuesList = []
valuesList.append((5,'wolf'))
# 注意这里不要给子查询加引号，它会被直接拼入SQL
valuesList.append(("(SELECT id FROM city WHERE name = 'Boston')", 'tiger'))

# 自定义每个值组的模板，保持默认的(%s, %s)即可
execute_values(cur, SQL, valuesList, template="(%s, %s)", page_size=1000000)

⚠️ 注意：如果子查询中的条件（比如Boston）是用户输入的动态值，这种直接拼接的方式会有SQL注入风险，不推荐。这种情况下建议用方案1或者方案3。

方案3：使用INSERT ... SELECT语法批量插入 #

如果你的批量插入混合了直接值和子查询取值，用INSERT ... SELECT结合UNION ALL会更高效也更安全：

cur.execute("""
INSERT INTO sample (id, name)
-- 第一条直接值的插入
SELECT 5, 'wolf'
UNION ALL
-- 第二条从city表取id的插入
SELECT id, 'tiger' FROM city WHERE name = %s
""", ('Boston',))

这种方式完全通过参数化处理动态值，避免了SQL注入风险，同时也适合扩展到更多批量数据的场景。

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