在使用read_sql_query时可能会报错:
复制代码
1
2
3
4
5
6>>> from sqlalchemy import create_engine >>> import pandas as pd >>> engine = create_engine('mysql+pymysql://{}:{}@{}:{}/{}'.format(user, password, address, port, databass)) >>> pd.read_sql_query("DELETE FROM {} WHERE {}".format(table, data), engine) sqlalchemy.exc.ResourceClosedError: This result object does not return rows. It has been closed automatically.
这是由于这条sql执行完成后没有返回
因而在执行非查询类sql时最好使用如下方式:
复制代码
1
2
3
4
5>>> from sqlalchemy import create_engine >>> engine = create_engine('mysql+pymysql://{}:{}@{}:{}/{}'.format(user, password, address, port, databass)) >>> with engine.begin() as conn: conn.execute("DELETE FROM {} WHERE {}".format(table, data))
参考:
- https://stackoverflow.com/a/51724985/7151777
- https://docs.sqlalchemy.org/en/13/core/connections.html
最后
以上就是懵懂发箍最近收集整理的关于python执行非查询类sql时最好使用conn.execute的全部内容,更多相关python执行非查询类sql时最好使用conn内容请搜索靠谱客的其他文章。
本图文内容来源于网友提供,作为学习参考使用,或来自网络收集整理,版权属于原作者所有。
发表评论 取消回复