如何向函数传递不同参数并解决sqlite3参数绑定报错

需要实现支持多同结构CSV文件导入的交易数据入库函数，初始代码运行触发SQLite绑定参数数量不匹配错误，报错信息显示SQL语句需要4个绑定值，实际仅传入1个。

初始实现代码：

def transaction_import(path):
   with open (path, 'r') as f:
       reader = csv.reader(f)
       columns = next(reader)
       query = 'insert into transactions({0}) values ({1})'
       query = query.format(','.join(columns), ','.join('?' * len(columns)))
       cursor = conn.cursor()
       for data in reader:
          cursor.execute(query, data)

transactions = transaction_import('../data/budapest.csv')

c.execute("select * from transactions")
transactions = c.fetchall()
for row in transactions:
   print(row)

目标调用方式：

• transactions = transaction_import('../Data/Source/ny.csv')
• transactions = transaction_import('../Data/Source/london.csv')

报错栈里明确显示实际运行的代码是cursor.execute(query,(data,))，这就是核心问题：
csv.reader迭代返回的data本身是和列数等长的列表，直接作为第二个参数传入execute时，会被自动解包为和占位符数量匹配的参数。但如果把data包裹在元组里写成(data,)，相当于把整行数据的列表作为单个值传入，4个占位符只收到1个列表参数，自然触发数量不匹配错误。

另外三个会触发同类报错或数据异常的常见场景：

• CSV文件存在空行，读取到的行数据长度和列数不一致
• 列名拼接时存在格式错误，导致生成的SQL占位符数量和实际列数不符
• 插入后未提交事务，数据不会实际写入数据库

import csv
import sqlite3

# 全局初始化一次数据库连接即可，多文件导入复用连接
conn = sqlite3.connect('your_database.db')

def transaction_import(path):
    # 打开文件时显式指定编码，避免乱码
    with open(path, 'r', encoding='utf-8') as f:
        reader = csv.reader(f)
        columns = next(reader)
        col_count = len(columns)
        # 生成插入SQL
        insert_query = f"INSERT INTO transactions ({','.join(columns)}) VALUES ({','.join(['?'] * col_count)})"
        cursor = conn.cursor()
        
        for row in reader:
            # 跳过空行、长度不匹配的异常行
            if not row or len(row) != col_count:
                continue
            # 直接传入行数据即可，无需额外包裹元组
            cursor.execute(insert_query, row)
    
    # 提交事务，确保数据持久化
    conn.commit()
    # 查询返回当前全量交易数据
    cursor.execute("SELECT * FROM transactions")
    return cursor.fetchall()

# 多文件导入调用
ny_trans = transaction_import('../Data/Source/ny.csv')
london_trans = transaction_import('../Data/Source/london.csv')
budapest_trans = transaction_import('../data/budapest.csv')

# 打印验证
for record in budapest_trans:
    print(record)

• 不要在函数内部重复创建数据库连接，多文件导入复用同一个连接即可，减少资源开销同时避免锁库问题
• 如果CSV文件体积较大，可以改用cursor.executemany()批量插入，性能会比逐行execute高很多
• 导入前可以加一步列名校验，判断当前读取的CSV列名和目标表结构是否匹配，避免导错文件

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