|
发表于 2022-6-22 20:38:53
|
显示全部楼层
本帖最后由 白two 于 2022-6-22 20:41 编辑
肯定都要初始化的时候创建或者打开文件, 创建或者连接数据库, 在分别定义读, 和写的方法
例如下面写入 sqlite3 的例子
- class JobPipeline:
- def __init__(self):
- # 连接 or 创建数据库
- self.conn = sqlite3.connect("job_info.sqlite3")
- self.cursor = self.conn.cursor()
- self.cursor.execute('CREATE TABLE IF NOT EXISTS jobs(City TEXT, name TEXT)')
- # 每次写入都删除之前的数据
- self.cursor.execute('DELETE FROM jobs')
- def process_item(self, item, spider):
- City = item['workCity']
- name = item['name']
- sql = '''insert into jobs values ("%s", "%s"")''' % (
- City, name)
- print(sql)
- self.cursor.execute(sql)
- self.conn.commit()
- return item
- def close_spider(self, spider):
- # 关闭连接
- self.conn.close()
复制代码
文件类似, 无非就是将连接改成打开文件就成了 |
|