python将dataframe数据导入MySQL

**Python 将 DataFrame 数据导入 MySQL**

在实际项目中，经常需要将 pandas 的 DataFrame 数据导入到 MySQL 中。下面我们将一步步地讲解如何实现这一点。

### **安装必要的库**

首先，我们需要安装两个重要的库：`pandas` 和 `mysql-connector-python`。

pip install pandas mysql-connector-python

### **连接 MySQL**

接下来，我们需要连接到 MySQL 数据库。我们可以使用以下代码来实现：

import mysql.connector# 连接配置config = {
 'host': 'localhost',
 'database': 'mydb',
 'user': 'root',
 'password': '123456'
}

# 创建连接对象cnx = mysql.connector.connect(**config)

# 打印连接状态print("Connected to MySQL database.")

### **导入 DataFrame 数据**

现在，我们需要将 pandas 的 DataFrame 数据导入到 MySQL 中。我们可以使用以下代码来实现：

import pandas as pd# 创建一个示例的DataFramedata = {
 'id': [1,2,3],
 'name': ['Alice', 'Bob', 'Charlie'],
 'age': [25,30,35]
}
df = pd.DataFrame(data)

# 打印原始数据print("Original DataFrame:")
print(df)

### **将 DataFrame 数据导入 MySQL**

下面是将 DataFrame 数据导入到 MySQL 中的关键代码：

# 创建一个 cursor 对象cursor = cnx.cursor()

# 将 DataFrame 数据导入到 MySQL 中for index, row in df.iterrows():
 # 使用 INSERT INTO语句插入数据 query = "INSERT INTO mytable (id, name, age) VALUES (%s, %s, %s)"
 cursor.execute(query, (row['id'], row['name'], row['age']))

# 提交事务cnx.commit()

# 关闭 cursor 对象cursor.close()

### **关闭连接**

最后，我们需要关闭 MySQL 连接：

# 关闭连接cnx.close()

print("Disconnected from MySQL database.")

**完整的示例代码**

以下是完整的示例代码：

import mysql.connectorimport pandas as pd# 连接配置config = {
 'host': 'localhost',
 'database': 'mydb',
 'user': 'root',
 'password': '123456'
}

# 创建连接对象cnx = mysql.connector.connect(**config)

# 打印连接状态print("Connected to MySQL database.")

# 创建一个示例的DataFramedata = {
 'id': [1,2,3],
 'name': ['Alice', 'Bob', 'Charlie'],
 'age': [25,30,35]
}
df = pd.DataFrame(data)

# 打印原始数据print("Original DataFrame:")
print(df)

# 创建一个 cursor 对象cursor = cnx.cursor()

# 将 DataFrame 数据导入到 MySQL 中for index, row in df.iterrows():
 # 使用 INSERT INTO语句插入数据 query = "INSERT INTO mytable (id, name, age) VALUES (%s, %s, %s)"
 cursor.execute(query, (row['id'], row['name'], row['age']))

# 提交事务cnx.commit()

# 关闭 cursor 对象cursor.close()

# 关闭连接cnx.close()

print("Disconnected from MySQL database.")

**注意**

* 在实际项目中，需要根据具体的需求调整连接配置和 SQL语句。
* 这个示例代码仅供参考，不一定适用于所有情况。

希望这个示例能够帮助你理解如何将 pandas 的 DataFrame 数据导入到 MySQL 中。