scrapy 操作MYSQL

scrapy piplines操作mysql数据库：

class EducationPipeline:
    def __init__(self):
        self.connect = pymysql.connect(host='localhost',                                       
port=3306,                                       
user='root',                                       
password='123456',  # 密码是字符串类型                                       
database='czxx',                                       
charset='utf8',                                       
use_unicode=True)
        self.cursor = self.connect.cursor()  # 创建游标        print("连接数据库成功")
    def process_item(self, item, spider):
          insert_sql = """insert into schoolinfo(region,school,address,telephone,postcode,period) VALUES                         (%s,%s,%s,%s,%s,%s)"""        # 执行插入数据到数据库操作        
    self.cursor.execute(insert_sql,(item['Region'], item['School'], item['Address'], item['Telephone'],                                         item['PostCode'], item['Period']))
        # 提交，不进行提交无法保存到数据库        self.connect.commit()
        return item
    def close_spider(self, spider):
        # 关闭游标和连接       
  self.cursor.close()
        self.connect.close()

以上为个人使用经验，如有不足，欢迎指正。

最后

以上就是喜悦钢笔为你收集整理的scrapy 操作MYSQL的全部内容，希望文章能够帮你解决scrapy 操作MYSQL所遇到的程序开发问题。

如果觉得靠谱客网站的内容还不错，欢迎将靠谱客网站推荐给程序员好友。