使用动态字段名向上插入数据

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

# 创建数据库连接
engine = create_engine('sqlite:///example.db')
metadata = MetaData()
Session = sessionmaker(bind=engine)
session = Session()

# 定义用户表
users = Table('users', metadata,
    Column('id', Integer, primary_key=True),
    Column('name', String),
)

# 创建表
metadata.create_all(engine)

# 动态插入数据
def insert_user(name, **kwargs):
    ins = users.insert().values(name=name, **kwargs)
    session.execute(ins)
    session.commit()

# 使用示例
insert_user('Alice', age=30, email='alice@example.com')
insert_user('Bob', age=25, phone='123-456-7890')

# 使用参数化查询
def safe_insert_user(name, **kwargs):
    query = users.insert().values(name=name)
    for key, value in kwargs.items():
        query = query.values(**{key: value})
    session.execute(query)
    session.commit()