用sqlalchemy,mysql和pandas读取框架

Question

我正在尝试连接到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'对象没有属性'rollback'

Answer 1

您需要具有原始数据库连接,而不是实例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()