pandas mysql

import pandas as pd
from sqlalchemy import create_engine

# 创建数据库连接引擎
# 'mysql+pymysql://用户名:密码@主机名/数据库名'
engine = create_engine('mysql+pymysql://root:password@localhost/mydatabase')

# 读取MySQL表到DataFrame
query = "SELECT * FROM my_table"
df = pd.read_sql(query, engine)

# 显示前几行数据
print(df.head())

# 将DataFrame写入MySQL表
# if_exists='replace'表示如果表存在则替换，也可以是'append'或'fail'
df.to_sql(name='new_table', con=engine, if_exists='replace', index=False)

解释说明：

1. 导入库：我们首先导入了 pandas 和 sqlalchemy 库。pandas 用于数据处理，sqlalchemy 用于创建数据库连接。
2. 创建数据库连接引擎：使用 create_engine 函数创建一个数据库连接引擎，连接字符串包含用户名、密码、主机名和数据库名。
3. 读取MySQL表到DataFrame：通过 pd.read_sql 函数执行SQL查询并将结果存储在 DataFrame 中。
4. 显示数据：使用 df.head() 查看前几行数据。
5. 将DataFrame写入MySQL表：使用 df.to_sql 函数将 DataFrame 写入MySQL表中，if_exists 参数指定表存在时的行为。

如果你需要更多帮助或有其他问题，请告诉我！