先看代码
class mysqlPipeline(object):
conn = None
cursor = None
# 连接数据库
def opens_spider(self, spider):
self.conn = pymysql.Connect(host='127.0.0.1', port=3306, user='root', password='123456', db='test',
charset='utf8')
def process_item(self, item, spider):
self.cursor = self.conn.cursor()
try:
self.cursor.execute('insert into qiubai values("%s","%s")' % (item["author"], item["content"]))
self.conn.commit()
except Exception as e:
print(e)
self.conn.rollback() # 回滚
return item
def close_spider(self, spider):
self.cursor.close()
self.conn.close()
这是错误提示
AttributeError: 'NoneType' object has no attribute 'close'
我猜测是使用数据库进行连接是出了问题,但是不知道怎么改,请大佬们看看,谢谢