使用MySql如何插入数据呢
class MysqlPipeline(object):
def __init__(self):
self.conn = MySQLdb.connect('127.0.0.1', 'root', 'root', 'xxx', charset="utf8", use_unicode=True)
self.cursor = self.conn.cursor()
def process_item(self, item, spider):
insert_sql = """ INSERT INTO `xxxxx` (xx) VALUES (%s)"""
value = (item['xx'])
self.cursor.execute(insert_sql, value)
self.conn.commit()INSERT INTO 表名 ( 列名1, 列名2,列名3,列名N )VALUES( 数据1, 数据2,数据3,数据N);