如何使用“mysql.connector”使用“pd.read_sql”

Question

我知道我们可以sql使用不同的包来读取，mysql.connector但因为我只知道mysql.connector，我想用它来读取表格sql并将其保存为dataframepandas。我的代码如下。

import mysql.connector
import pandas as pd

mydb = mysql.connector.connect(
    host = 'localhost',
    user = 'root',
    passwd = '*',
    database = 'mydatabase'
)

mycursor = mydb.cursor()

query = "SELECT * FROM my table"
df = pd.read_sql(query, mycursor)

我不确定最后一行，即df = pd.read_sql(query, mycursor). 我想我在这里遗漏了一些论点。你能帮我吗？

Answer 1

您需要替换df = pd.read_sql(query, mycursor)为，df = pd.read_sql_query(query, mydb)因为您想要使用查询进行操作DataFrame（确保传递mydbnot mycursor）。