feapder框架的item一条条插入数据给mysql示例
时间: 2024-05-13 13:14:57 浏览: 60
假设已经通过Feapder获取了需要插入数据库的数据,可以按照以下步骤将数据插入到MySQL数据库中:
1. 连接数据库
```python
import pymysql
# 连接MySQL数据库
db = pymysql.connect(host='localhost', user='root', password='password', db='test', port=3306)
```
2. 创建游标对象
```python
# 创建游标对象
cursor = db.cursor()
```
3. 准备SQL语句
```python
# 准备SQL语句
sql = "INSERT INTO table_name (col1, col2, col3) VALUES (%s, %s, %s)"
```
其中,`table_name`为要插入数据的表名,`col1`、`col2`、`col3`为表中的列名。
4. 插入数据
```python
# 插入数据
for item in items:
try:
# 执行SQL语句,将数据插入到数据库中
cursor.execute(sql, (item['col1'], item['col2'], item['col3']))
# 提交事务
db.commit()
except Exception as e:
# 发生错误时回滚
db.rollback()
print(e)
```
其中,`items`为需要插入数据库的数据,`item['col1']`、`item['col2']`、`item['col3']`为数据中的字段名。
5. 关闭连接
```python
# 关闭连接
db.close()
```
完整示例代码如下:
```python
import pymysql
# 连接MySQL数据库
db = pymysql.connect(host='localhost', user='root', password='password', db='test', port=3306)
# 创建游标对象
cursor = db.cursor()
# 准备SQL语句
sql = "INSERT INTO table_name (col1, col2, col3) VALUES (%s, %s, %s)"
# 插入数据
for item in items:
try:
# 执行SQL语句,将数据插入到数据库中
cursor.execute(sql, (item['col1'], item['col2'], item['col3']))
# 提交事务
db.commit()
except Exception as e:
# 发生错误时回滚
db.rollback()
print(e)
# 关闭连接
db.close()
```
阅读全文