如何判断pandas调用to_sql的append模式时是否创建了新表

下面提供两种可直接落地的实现方式：

方案1：提前查询表状态（最常用，兼容性最高） #

在调用to_sql之前先主动查询目标表是否存在，执行完插入操作后对比初始状态即可判断是否有新表创建，完全不依赖pandas内部实现逻辑，适配所有pandas版本和支持sqlalchemy的数据库类型。

代码示例：

from sqlalchemy import create_engine, inspect
import pandas as pd

# 初始化数据库连接
engine = create_engine("mysql+pymysql://user:password@host:port/db_name")
target_table = "你的目标表名"
# 如果表在指定schema下，填写对应schema，否则设为None
schema = None

# 提前查询表是否已存在
inspector = inspect(engine)
table_existed = inspector.has_table(target_table, schema=schema)

# 执行append模式插入
df.to_sql(
    name=target_table,
    con=engine,
    if_exists="append",
    index=False,
    schema=schema
)

# 判断是否为新创建的表
if not table_existed:
    # 此处写入你的自定义操作，比如添加索引、配置表权限、初始化字段注释等
    print(f"新表{target_table}已创建，执行自定义逻辑")

方案2：事件监听（适合多表批量操作场景） #

如果需要统一处理所有to_sql操作中新创建表的自定义逻辑，可以绑定sqlalchemy的after_create事件，只要有新表创建就会自动触发你定义的回调函数，不需要每次调用to_sql都单独判断。

代码示例：

from sqlalchemy import create_engine, event, Table
import pandas as pd

engine = create_engine("mysql+pymysql://user:password@host:port/db_name")

# 定义新表创建后的回调逻辑
def custom_after_create(target, connection, **kw):
    print(f"检测到新表{target.name}创建，执行全局自定义操作")
    # 写入你的全局自定义逻辑

# 绑定表创建事件监听
event.listen(Table, "after_create", custom_after_create)

# 后续所有to_sql操作都不需要额外加判断，新表创建会自动触发回调
df1.to_sql(name="table1", con=engine, if_exists="append", index=False)
df2.to_sql(name="table2", con=engine, if_exists="append", index=False)

注意：如果只需要处理单张表的新表逻辑，优先选择方案1，逻辑更直观，调试成本更低。

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