python把数据框写入MySQL的方法

Python 具有丰富的数据库操作模块，例如 SQLite、MySQL、PostgreSQL 等。在实际项目中，通常需要将数据以数据框的形式导入数据库。接下来，将使用 Python 将数据框写入 MySQL 的方法，详细说明数据框导入 MySQL 的步骤。

准备工作

在使用 Python 之前，需要安装 mysql-connector-python 模块，此模块提供了连接 MySQL 数据库的功能。可以通过 pip 安装：

pip install mysql-connector-python

另外，还需要连接到 MySQL 数据库，并创建对应的数据库表，准备好数据后可以将数据导入 MySQL 中。

将数据框写入 MySQL 的步骤

1. 导入模块并连接 MySQL 数据库

```
import pandas as pd
import mysql.connector

# 连接 MySQL 数据库
mydb = mysql.connector.connect(
host="localhost",
user="yourusername",
passwd="yourpassword",
database="yourdatabase"
)
```

1. 加载数据框，并将数据框中的数据导出到 MySQL

```
# 创建数据框
df = pd.read_csv('data.csv')

# 创建游标对象
cursor = mydb.cursor()

# 创建表
cursor.execute("CREATE TABLE users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)")

# 插入数据，使用 execute() 方法执行 SQL 命令
for index, row in df.iterrows():
sql = "INSERT INTO users (name, age) VALUES (%s, %s)"
val = (row['name'], row['age'])
cursor.execute(sql, val)

# 提交更改，如果没有提交，数据库中的数据不会被保存
mydb.commit()
```

在此示例中，通过 create table 创建了一个名为 users 的表，其中 id 是主键，name 和 age 是列名。接着使用 iterrows()方法遍历数据框中的每一行，并使用 execute() 方法将其插入到 MySQL 数据库的表格中。

1. 查询并检查数据是否写入到 MySQL 数据库

```
# 查询表中的所有数据
cursor.execute("SELECT * FROM users")

# 获取所有记录
result = cursor.fetchall()

# 输出记录
for x in result:
print(x)
```

在此示例中，通过 SELECT 语句从 MySQL 数据库中检索 users 表格中的所有数据。接着使用 cursor.fetchall() 方法检索所有数据并将其保存到 results 列表中。最后使用 for 循环遍历列表并输出结果。

示例

下面是两个示例：

# 示例1：将数据框写入 MySQL 中
import pandas as pd
import mysql.connector

# 连接 MySQL 数据库
mydb = mysql.connector.connect(
    host="localhost",
    user="yourusername",
    passwd="yourpassword",
    database="yourdatabase"
)

# 创建数据框
df = pd.read_csv('data.csv')

# 创建游标对象
cursor = mydb.cursor()

# 创建表
cursor.execute("CREATE TABLE users (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)")

# 插入数据
for index, row in df.iterrows():
    sql = "INSERT INTO users (name, age) VALUES (%s, %s)"
    val = (row['name'], row['age'])
    cursor.execute(sql, val)

# 提交更改
mydb.commit()

# 示例2：输出数据框中的数据
# 查询表中的所有数据
cursor.execute("SELECT * FROM users")

# 获取所有记录
result = cursor.fetchall()

# 输出记录
for x in result:
    print(x)

# 示例2：将数据框写入 MySQL 中
import pandas as pd
import mysql.connector

# 连接 MySQL 数据库
mydb = mysql.connector.connect(
    host="localhost",
    user="yourusername",
    passwd="yourpassword",
    database="yourdatabase"
)

# 创建数据框
df = pd.DataFrame({
    'name': ['Tom', 'Jack', 'Jane'],
    'age': [18, 22, 27]
})

# 创建游标对象
cursor = mydb.cursor()

# 创建表
cursor.execute("CREATE TABLE users2 (id INT AUTO_INCREMENT PRIMARY KEY, name VARCHAR(255), age INT)")

# 插入数据
for index, row in df.iterrows():
    sql = "INSERT INTO users2 (name, age) VALUES (%s, %s)"
    val = (row['name'], row['age'])
    cursor.execute(sql, val)

# 提交更改
mydb.commit()

# 示例2：输出数据框中的数据
# 查询表中的所有数据
cursor.execute("SELECT * FROM users2")

# 获取所有记录
result = cursor.fetchall()

# 输出记录
for x in result:
    print(x)

以上是使用 Python 将数据框写入 MySQL 的完整攻略，需要提醒的是，在实际项目中，需要根据具体的需求进行配置和修改。