使用psycopg2将API响应name字段存入PostgreSQL遇错误求解决

让我帮你拆解一下代码里的核心问题，然后给出修复后的完整实现：

问题分析 #

你遇到的几个报错对应这些具体问题：

1. SQL语法错误：你的INSERT语句格式写错了，少了关键的右括号，正确格式应该是INSERT INTO table_items (column) VALUES (%s)，原代码里的(NAME VALUES (%s)语法不完整，直接触发了syntax error at or near "VALUES"报错。
2. 数据库连接频繁开闭：你把连接的创建和关闭放在了for循环内部，每次循环都新建连接然后立即关闭，不仅效率极低，还容易出现PostgreSQL connection is closed这类连接状态异常。
3. 插入参数无效：你用print(item['name'])赋值record_to_insert，但print()函数返回值是None，导致execute执行时传入无效参数，根本没法正确插入数据。

修复后的完整代码 #

import json
import requests
import psycopg2

def my_func():
    # 先批量获取所有API数据
    all_results = []
    response = requests.get("https://path/to/api/")
    current_data = response.json()
    all_results.extend(current_data['results'])
    
    # 处理分页，拉取剩余数据
    while current_data['next'] is not None:
        response = requests.get(current_data['next'])
        current_data = response.json()
        all_results.extend(current_data['results'])
    
    # 数据库操作：仅创建一次连接
    connection = None
    cursor = None
    try:
        # 建立数据库连接
        connection = psycopg2.connect(
            user="user",
            password="user",
            host="127.0.0.1",
            port="5432",
            database="mydb"
        )
        cursor = connection.cursor()
        # 修正后的SQL插入语句
        postgres_insert_query = """ INSERT INTO table_items (name) VALUES (%s) """
        
        # 循环插入数据
        for item in all_results:
            # 构造元组格式的插入参数（注意末尾逗号，确保是元组类型）
            record_to_insert = (item['name'],)
            cursor.execute(postgres_insert_query, record_to_insert)
            connection.commit()
            print(f"插入成功，影响行数：{cursor.rowcount}")
    
    except (Exception, psycopg2.Error) as error:
        print("Failed to insert record into table_items table", error)
        # 出错时回滚事务，避免数据不一致
        if connection:
            connection.rollback()
    finally:
        # 统一关闭游标和连接，确保资源释放
        if cursor:
            cursor.close()
        if connection:
            connection.close()
        print("数据库连接已关闭")

my_func()

关键修复点说明 #

• SQL语句修正：补全了缺失的右括号，确保语句符合PostgreSQL语法规范。
• 连接优化：将数据库连接移到循环外部，整个函数仅建立一次连接，避免频繁创建销毁连接的性能损耗和状态异常。
• 参数修正：用(item['name'],)构造了合法的元组参数，去掉了无效的print()调用。
• 事务处理：增加了出错时的事务回滚逻辑，避免部分插入导致的数据不一致。
• 资源清理：在finally块统一关闭游标和连接，确保数据库资源被正确释放。

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