pandas.read_sql() 仅适用于查询类语句（如 SELECT），无法处理 DELETE、INSERT 或 UPDATE 等不返回结果集的 DML 操作；直接调用会触发 ResourceClosedError。应改用 Connection.exec_driver_sql() 配合上下文管理器安全执行并自动提交。
`pandas.read_sql()` 仅适用于查询类语句（如 `select`），无法处理 `delete`、`insert` 或 `update` 等不返回结果集的 dml 操作；直接调用会触发 `resourceclosederror`。应改用 `connection.exec_driver_sql()` 配合上下文管理器安全执行并自动提交。
在使用 Pandas 与 SQLAlchemy 交互时，一个常见误区是误将 pd.read_sql() 用于非查询类 SQL 操作。例如，当尝试通过 DELETE 清理上月数据时：
# ❌ 错误示例：read_sql 期望返回 DataFrame，但 DELETE 不产生结果集
df_month_exist = pd.read_sql('''
DELETE FROM DATATABLE
WHERE RECORD_MONTH = DATEADD(MONTH, DATEDIFF(MONTH, -1, GETDATE()) - 1, -1)
''', con=engine)上述代码会抛出 sqlalchemy.exc.ResourceClosedError: This result object does not return rows —— 因为 read_sql() 内部调用 execute() 后立即尝试 fetchall()，而 DELETE 语句本身不返回行，连接资源被自动关闭，导致异常。
✅ 正确做法是：使用 Connection.exec_driver_sql()（SQLAlchemy 2.0+ 推荐）或 Connection.execute()，并在 with engine.begin() 上下文内执行，确保事务自动提交（成功）或回滚（异常）：
from sqlalchemy import text
with engine.begin() as conn:
conn.exec_driver_sql("""
DELETE FROM DATATABLE
WHERE RECORD_MONTH = DATEADD(MONTH, DATEDIFF(MONTH, -1, GETDATE()) - 1, -1)
""")✅ engine.begin() 提供事务性上下文：退出 with 块时自动 COMMIT；若发生异常则自动 ROLLBACK。
✅ exec_driver_sql() 直接传递原始 SQL 字符串给底层驱动（如 pyodbc），无需参数绑定（若需防注入，请改用 text() + 参数化）。
? 进阶建议（推荐生产环境使用）：
-
使用参数化查询避免 SQL 注入和日期计算歧义：
from datetime import datetime, timedelta from sqlalchemy import text # 计算上月最后一天（更清晰、跨数据库兼容） now = datetime.now() last_day_of_last_month = (now.replace(day=1) - timedelta(days=1)) with engine.begin() as conn: conn.execute( text("DELETE FROM DATATABLE WHERE RECORD_MONTH = :target_date"), {"target_date": last_day_of_last_month} )
⚠️ 注意事项：
- 不要使用 SET NOCOUNT ON（SQL Server 特有）来“修复”该错误——它解决的是消息计数干扰，而非根本问题（read_sql 的语义不匹配）；
- 避免裸调用 engine.connect().execute(...)，易遗漏 commit() 或连接泄漏；务必使用 with engine.begin() 或显式 commit()/close()；
- 若需获取影响行数，可在执行后调用 result.rowcount（exec_driver_sql 返回 Result 对象）：
with engine.begin() as conn: result = conn.exec_driver_sql("DELETE ...") print(f"Deleted {result.rowcount} rows")
总结：牢记 read_sql() = 查询专用；DML 操作请统一走 Connection.exec_driver_sql() + 事务上下文。这是 SQLAlchemy 2.0+ 的最佳实践，兼顾安全性、可维护性与明确性。
