格式化字符串参数不足求助：CSV数据插入数据库报错排查

嘿，这个错误其实很好定位——核心问题就是你的CSV数据字段数量和SQL插入语句的占位符数量完全不匹配，咱们一步步拆解来看：

问题出在哪？ #

先对照你给出的信息：

• 你的CSV只有4个字段：Date, portfolioValue, pID, FinancialInstrument，每行数据也就4个值（比如第一行是2018-03-27,4937.395022140785,1,Oil）
• 但你写的INSERT语句却要插入8个字段：Date, Open, Settle, High, Low, HorizonType, InstrumentName, PredictorType，对应8个%s占位符，后面的ON DUPLICATE KEY UPDATE里还有更多占位符。

你想想，每行CSV只有4个值，却要填充十几个%s，参数肯定不够，自然会抛出Not enough arguments的错误。

怎么修正？ #

1. 先对齐SQL和CSV的字段对应关系

首先得明确：你CSV里的字段，到底对应PredictionData表中的哪些字段？比如：

• Date → 表的Date
• portfolioValue → 表的Settle？
• FinancialInstrument → 表的InstrumentName？
• pID 如果没用可以直接忽略

如果表中其他字段（比如Open, High, Low, HorizonType等）有默认值，那你完全可以只插入有数据的字段，减少占位符数量。

比如调整后的SQL语句可以是：

stmt = ("INSERT INTO PredictionData (Date, Settle, InstrumentName) VALUES (%s, %s, %s) "
        "ON DUPLICATE KEY UPDATE Settle=%s")

这里一共4个%s，刚好可以用CSV里的3个有效值+更新的Settle值来填充。

2. 修正循环逻辑（别把表头当数据）

你的代码里写了for row in df_header:，这明显有问题——df_header是CSV的表头行，你应该跳过表头，遍历实际的数据行。正确的循环写法应该是：

import csv

with open(portfolio_file, 'r') as file:
    csv_data = csv.reader(file, delimiter=',')
    next(csv_data)  # 跳过表头，这步很重要！
    for row in csv_data:
        # row现在是每行的实际数据，比如['2018-03-27', '4937.395022140785', '1', 'Oil']
        # 提取需要的字段
        date = row[0]
        settle_val = row[1]
        instrument = row[3]
        # 执行SQL时，参数数量要和%s完全匹配
        cursor.execute(stmt, (date, settle_val, instrument, settle_val))

3. 关键注意点

• 永远确保cursor.execute(stmt, params)里的params长度和SQL中%s的总数一致，包括ON DUPLICATE KEY UPDATE部分的占位符。
• 如果表中某些字段没有默认值，你要么在CSV里补充对应数据，要么在SQL语句中手动指定默认值（比如HorizonType='Day'）。

完整的修正示例 #

假设你的PredictionData表中未指定的字段有默认值，这里给你一个可直接参考的完整代码：

import csv
# 替换成你用的数据库连接库，比如MySQLdb、psycopg2等
import MySQLdb

# 建立数据库连接
db = MySQLdb.connect(host="localhost", user="your_username", passwd="your_password", db="your_database")
cursor = db.cursor()

portfolio_file = "your_portfolio.csv"

try:
    with open(portfolio_file, 'r') as file:
        csv_data = csv.reader(file, delimiter=',')
        next(csv_data)  # 跳过表头
        for row in csv_data:
            # 解析CSV数据
            date = row[0]
            portfolio_value = row[1]
            instrument_name = row[3]
            
            # 调整后的SQL语句
            insert_sql = """
                INSERT INTO PredictionData (Date, Settle, InstrumentName)
                VALUES (%s, %s, %s)
                ON DUPLICATE KEY UPDATE Settle = %s
            """
            # 参数顺序要和%s完全对应
            params = (date, portfolio_value, instrument_name, portfolio_value)
            
            cursor.execute(insert_sql, params)
    db.commit()
    print("数据插入成功！")
except Exception as e:
    print(f"插入出错: {str(e)}")
    db.rollback()
finally:
    # 关闭连接
    cursor.close()
    db.close()

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