如何在psycopg3中向VALUES传递嵌套元组构建临时表？

你遇到的错误是因为Psycopg3直接将嵌套元组作为单个参数传入时，会被转义成字符串，不符合PostgreSQL的VALUES语法要求。以下是几种替代Psycopg2中extras.execute_values的可行方案：

方法1：动态生成VALUES占位符 #

通过psycopg.sql模块动态构造符合语法的VALUES子句，实现批量参数传递：

from psycopg import sql

with connection.cursor() as cur:
    # 根据数据行数生成对应数量的占位符
    placeholders = sql.SQL(', ').join([sql.Placeholder() for _ in data])
    # 拼接完整SQL语句
    query = sql.SQL("WITH sources (a,b,c) AS (VALUES {}) SELECT a,b+c FROM sources;").format(placeholders)
    cur.execute(query, data)
    print(cur.fetchone())

方法2：创建临时表+批量插入 #

如果需要对临时表执行更多后续操作，可以先创建临时表，再用execute_batch批量插入数据：

from psycopg import execute_batch

with connection.cursor() as cur:
    # 创建临时表（会话结束自动销毁）
    cur.execute("CREATE TEMP TABLE sources (a text, b int, c int);")
    # 批量插入数据
    execute_batch(cur, "INSERT INTO sources (a,b,c) VALUES (%s,%s,%s);", data)
    # 执行查询
    cur.execute("SELECT a,b+c FROM sources;")
    print(cur.fetchone())

方法3：使用数组+unnest函数 #

将数据拆分为字段数组，通过PostgreSQL的unnest函数展开成临时表：

with connection.cursor() as cur:
    query = """
    WITH sources AS (
        SELECT unnest(%s) AS a, unnest(%s) AS b, unnest(%s) AS c
    )
    SELECT a, b + c FROM sources;
    """
    # 将原始数据按字段拆分
    a_list = [row[0] for row in data]
    b_list = [row[1] for row in data]
    c_list = [row[2] for row in data]
    cur.execute(query, (a_list, b_list, c_list))
    print(cur.fetchone())

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