连接mysql并读取指定表单数据到DataFrame

提问

python 如何连接mysql并读取指定表单数据到DataFrame

解答

要在Python中连接MySQL并读取指定表单数据到DataFrame，你可以使用pandas库结合sqlalchemy引擎或者mysql-connector-python。这里我将展示两种方法的示例代码。

使用pandas和sqlalchemy

确保安装了必要的库：

pip install pandas sqlalchemy mysqlclient

如果你使用的是MySQL 8.0+可能需要：

pip install pandas sqlalchemy pymysql

可以使用以下代码连接MySQL并读取数据：

from sqlalchemy import create_engine
import pandas as pd

# 定义连接参数
USERNAME = 'your_username'
PASSWORD = 'your_password'
HOST = 'your_host'
PORT = '3306'
DATABASE = 'your_database'
TABLE_NAME = 'your_table_name'

# 创建数据库引擎
engine = create_engine(f'mysql+pymysql://{USERNAME}:{PASSWORD}@{HOST}:{PORT}/{DATABASE}')

# 使用pandas的read_sql_table读取数据
df = pd.read_sql_table(TABLE_NAME, con=engine)

print(df)

使用pandas和mysql-connector-python

安装必要的库：

pip install pandas mysql-connector-python

使用以下代码连接MySQL并读取数据：

import mysql.connector
import pandas as pd

# 定义连接参数
config = {
  'user': 'your_username',
  'password': 'your_password',
  'host': 'your_host',
  'database': 'your_database',
  'raise_on_warnings': True
}

# 建立连接
cnx = mysql.connector.connect(**config)

# 使用pandas的read_sql_query读取数据
query = f'SELECT * FROM your_table_name'
df = pd.read_sql_query(query, con=cnx)

print(df)

# 关闭连接
cnx.close()

这两种方法都可以实现从MySQL数据库读取数据到DataFrame的目的，可以根据自己的环境和偏好选择适合的方法。