def?process_item(self,?item,?spider):
????data?=?dict(item)
????#mysql插入數(shù)據(jù)
????keys?=?','.join(data.keys())
????values?=?','.join(['%s']?*?len(data))
????sql?=?'INSERT?INTO?{table}({keys})?VALUES({values})'.format(table=self.sheetname,?keys=keys,?values=values)
????self.cursor.execute(sql,tuple(data.values()))
????self.conn.commit()
????#self.cursor.close()
????#self.conn.close()
????return?item
??我怎么判斷存儲(chǔ)到最后一個(gè)然后執(zhí)行self.cursor.close()
????self.conn.close()
添加回答
舉報(bào)
0/150
提交
取消