3.编程实现利用 DataFrame 读写 MySQL 的数据 (1)在 MySQL 数据库中新建数据库 sparktest,再创建表 employee,包含的两行数据。id name gender Age: 1 ,Alice, F, 22; 2, John, M,,25
时间: 2024-02-29 13:51:37 浏览: 28
下面是基于Python语言的DataFrame读写MySQL的实现代码:
```python
# 导入相关的库
import pandas as pd
from sqlalchemy import create_engine
# 创建连接MySQL的Engine对象
engine = create_engine('mysql+pymysql://username:password@localhost:3306/sparktest')
# 创建DataFrame
df = pd.DataFrame({'id': [1, 2], 'name': ['Alice', 'John'], 'gender': ['F', 'M'], 'Age': [22, 25]})
# 将DataFrame写入MySQL数据库中的employee表中
df.to_sql('employee', con=engine, if_exists='replace', index=False)
# 从MySQL数据库中读取数据到DataFrame
df = pd.read_sql('employee', con=engine)
# 打印读取到的数据
print(df)
```
需要注意的是,在代码中需要将`username`和`password`替换成自己的MySQL用户名和密码。同时,这里使用了`sqlalchemy`库来创建连接MySQL的Engine对象。在创建DataFrame时,我们可以直接传入一个字典来表示数据,然后使用`to_sql`方法将DataFrame写入MySQL数据库中的employee表中。最后,我们使用`read_sql`方法从MySQL数据库中读取数据到DataFrame中。