给我这个步骤的代码示例 将清洗后的数据存储到mysql数据库中
时间: 2023-11-28 18:48:30 浏览: 26
以下是将清洗后的数据存储到MySQL数据库的代码示例:
```python
import pandas as pd
import pymysql
# 读取清洗后的数据
data = pd.read_csv('cleaned_data.csv')
# 连接MySQL数据库
connection = pymysql.connect(host='localhost',
user='root',
password='password',
db='database_name')
# 创建游标对象
cursor = connection.cursor()
# 创建表格
create_table_query = """
CREATE TABLE IF NOT EXISTS cleaned_data (
id int(11) NOT NULL AUTO_INCREMENT,
column1 varchar(255) NOT NULL,
column2 varchar(255) NOT NULL,
PRIMARY KEY (id)
) ENGINE=InnoDB DEFAULT CHARSET=utf8mb4 COLLATE=utf8mb4_unicode_ci;
"""
cursor.execute(create_table_query)
# 将数据插入数据库
for index, row in data.iterrows():
insert_query = f"INSERT INTO cleaned_data (column1, column2) VALUES ('{row['column1']}', '{row['column2']}')"
cursor.execute(insert_query)
# 提交更改并关闭连接
connection.commit()
cursor.close()
connection.close()
```
在这个示例中,我们首先使用Pandas库读取清洗后的数据文件。然后,我们使用Pymysql库连接到MySQL数据库,并创建一个游标对象以执行SQL查询。接下来,我们创建一个表格,其中包含要存储的数据列。最后,我们使用一个循环遍历数据,并使用INSERT语句将每行插入数据库。最后,我们提交更改并关闭数据库连接。