pipelines.py:
class MySQLStorePipeline(object):
def __init__(self):
self.conn = MySQLdb.connect(host ='localhost', user ='root', passwd ='', db ='imoveis', charset="utf8", use_unicode=True)
self.cursor = self.conn.cursor()
def process_item(self, item, spider):
try:
self.cursor.execute("""INSERT INTO imovel (Titulo, Tipo_Negocio, Preco, Localizacao, Tipo_Imovel, Condicao, Numero_Divisoes, Numero_Quartos, Numero_Casas_Banho, Certificado_Energetico, Ano_Construcao, Area_Util, Area_Bruta, Piso)
VALUES (%s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s, %s)""",
(item['Titulo'],
item['Tipo_Negocio'],
item['Preco'],
item['Localizacao'],
item['Tipo_Imovel'],
item['Condicao'],
item['Numero_Divisoes'],
item['Numero_Quartos'],
item['Numero_Casas_Banho'],
item['Certificado_Energetico'],
item['Ano_Construcao'],
item['Area_Util'],
item['Area_Bruta'],
item['Piso']))
self.conn.commit()
except MySQLdb.Error as e:
print('Error %d: %s' % (e.args[0], e.args[1]))
sys.exit(1)
return item