求助：SQLAlchemy基于CSV首行动态生成数据表仅含ID列

原代码的核心问题是：用declarative_base定义的类属于编译时固定结构，__init__里的setattr仅给实例添加内存属性，不会同步到数据库表的列定义中，因此数据库只会生成提前写死的id列，无法动态创建CSV对应的列。

以下是正确的实现方案，全程在运行时根据CSV结构动态生成表并导入数据：

from sqlalchemy import create_engine, MetaData, Table, Column, Integer, String
from sqlalchemy.orm import sessionmaker
import csv

# 初始化数据库连接
engine = create_engine("my_pattern", echo=True)
meta = MetaData()

csv_file_path = 'myfile.csv'
with open(csv_file_path, 'r') as csvfile:
    reader = csv.DictReader(csvfile)
    # 处理CSV表头：替换空格、冒号为下划线，符合数据库列名规范
    processed_cols = [col.strip().replace(" ", "_").replace(":", "_") for col in reader.fieldnames]
    
    # 动态构建表结构
    dataset_reference = Table(
        'dataset_reference', meta,
        Column('id', Integer, primary_key=True, autoincrement=True),
        # 遍历处理后的表头，批量添加列（示例用String类型，可根据实际数据调整）
        *[Column(col, String(255)) for col in processed_cols]
    )
    
    # 创建表（仅当表不存在时执行）
    meta.create_all(engine)
    
    # 初始化会话
    Session = sessionmaker(bind=engine)
    session = Session()
    
    # 逐行插入CSV数据
    for row in reader:
        # 转换行数据的键名，和表列名匹配
        processed_row = {
            col.strip().replace(" ", "_").replace(":", "_"): value
            for col, value in row.items()
        }
        insert_stmt = dataset_reference.insert().values(**processed_row)
        session.execute(insert_stmt)
    
    # 提交事务并关闭会话
    session.commit()
    session.close()

关键说明 #

1. 动态表创建：通过Table类结合CSV表头生成列定义，完全在运行时完成表结构的构建，会同步到数据库。
2. 列类型适配：示例中用String(255)作为通用列类型，如果CSV包含数字、日期等数据，可将对应列的类型改为Integer、DateTime等。
3. 性能优化：如果CSV数据量极大，可改用批量插入（将多行数据打包成一个insert语句）提升效率。

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