# -*- coding: utf-8 -*- import mysql.connector # Python 操作 mysql # class mysqldb(object): def process_item(self, item, spider): db = mysql.connector.connect(host='localhost', user='root', passwd='123456', db='python') # 链接数据库 cur = db.cursor() # 获取数据库游标 title = item['title'] cur.execute("insert into pb2 VALUES ('"+title+"')") # 执行语句 db.commit() # 提交事务,没有此句在数据库中不能查询到数据 cur.close() # 关闭游标 db.close() # 关闭数据库
这篇文档对您是否有帮助?