Python Forum
Thread Rating:
  • 0 Vote(s) - 0 Average
  • 1
  • 2
  • 3
  • 4
  • 5
mysql connection issue
#1
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'
Reply


Forum Jump:

User Panel Messages

Announcements
Announcement #1 8/1/2020
Announcement #2 8/2/2020
Announcement #3 8/6/2020