mysql - 使用sqlalchemy，mysql和pandas读取框架

我正在尝试连接到mysql数据库，
与选项1配合使用:

from sqlalchemy import create_engine
engine = create_engine('mysql://root:root@localhost/lend', echo=True)
cnx = engine.connect()
x = cnx.execute("SELECT * FROM user")

但在这里分割:

from pandas.io import sql
xx = sql.read_frame("SELECT * FROM user", cnx)
cnx.close()

和

AttributeError:“连接”对象没有属性“回滚”

最佳答案

您需要具有原始数据库连接，而不是 Connection 的实例。为了得到它，请调用 engine.raw_connection() 或 engine.connect().connection :

from pandas.io import sql
#cnx = engine.connect().connection # option-1
cnx = engine.raw_connection() # option-2
xx = sql.read_frame("SELECT * FROM user", cnx)
cnx.close()

关于mysql - 使用sqlalchemy，mysql和pandas读取框架，我们在Stack Overflow上找到一个类似的问题：https://stackoverflow.com/questions/20401392/