mysql connection issue - Printable Version

mysql connection issue - Printable Version

+- Python Forum (https://python-forum.io)
+-- Forum: Python Coding (https://python-forum.io/forum-7.html)
+--- Forum: Data Science (https://python-forum.io/forum-44.html)
+--- Thread: mysql connection issue (/thread-10838.html)

mysql connection issue - aaditya2000 - Jun-09-2018

Hello:
Below is the connection code & i am getting following error, please me what wrong i am doing.

Any help is greatly appreciated.

import pandas as pd
import sqlalchemy as sa
import mysql.connector as mc

cnx = mc.connect(host='11.11.11.11',port=3306,database='kafka',user='root',password='xxxxxxx')

cur=cnx.cursor()

query = ("select * from kafka_test where flag = 0 order by id limit 20")

df = pd.read_sql_query(query,con=cnx)

print(df)

ERROR:-

Error:Traceback (most recent call last):

  File "<ipython-input-102-a83485540962>", line 13, in <module>
    df = pd.read_sql_query(query,con=cnx)

  File "E:\ProgramData\Anaconda3\lib\site-packages\pandas\io\sql.py", line 311, in read_sql_query
    pandas_sql = pandasSQL_builder(con)

  File "E:\ProgramData\Anaconda3\lib\site-packages\pandas\io\sql.py", line 507, in pandasSQL_builder
    if _is_sqlalchemy_connectable(con):

  File "E:\ProgramData\Anaconda3\lib\site-packages\pandas\io\sql.py", line 68, in _is_sqlalchemy_connectable
    return isinstance(con, sqlalchemy.engine.Connectable)

AttributeError: module 'sqlalchemy' has no attribute 'engine'