SQLAlchemy：to_sql 在检查后创建空表

Question

我在这里有奇怪的行为。在我初始化inspect(cn)后，to_sql将一个空表写入数据库。

 def save_data_to_sql(df, table_name, cn):

    df.to_sql(con=cn, name='test_1', if_exists='replace', index=False) << Table with data

    # Check if the table exists
    inspector = inspect(cn)
    if inspector.has_table(table_name):
        logger.info(f"Table exists")
    else:
        logger.info(f"Table does not exist")

    
    df.to_sql(con=cn, name='test_2', if_exists='replace', index=False) << Empty table?!?!

有人知道出了什么问题吗？

Answer 1

问题是我如何创建与 MariaDB 的连接。所以这个有效：

def crcn():
    """Create and return a database connection with SQLAlchemy."""

    try:
        engine = create_engine(
            f"mysql+mysqlconnector://{DB_CONFIG['user']}:{DB_CONFIG['password']}@{DB_CONFIG['host']}/{DB_CONFIG['database']}",
            connect_args={
                "charset": "utf8mb4",
                "collation": "utf8mb4_general_ci"
            }
        )
        print("Connected to MariaDB using SQLAlchemy")
        return engine

    except SQLAlchemyError as e:
        print(f"Error: {e}")
        return None