Передача результатов скрапа в базу данных mysql

Question

Я пытаюсь создать небольшой скребок, чтобы отсортировать какую-то новость в качестве хобби-проекта (я не профессиональный разработчик или техник, и я новичок в OOP и Python, у меня есть некоторый опыт работы с php иязык программирования Arduino).Мне удалось понять scrapy и частично mysql pipe.Если я заменю item ['titlu'] и item ['articol'] простой строкой, база данных будет заполнена этим.У меня был поиск и прочитал много информации, но я полностью не могу решить мою проблему.Я полагаю, что item ['titlu'] и item ['articol'] - это какой-то тип массива или что-то, что mysql не любит.я опубликую код и ошибки для помощи.Закомментированные строки кода - это некоторые из моих попыток решить проблему с таблицей базы данных mysql:

CREATE TABLE `ziare_com` (
  `id` int(11) NOT NULL,
  `titlu` text CHARACTER SET utf8 COLLATE utf8_bin NOT NULL,
  `articol` varchar(20000) CHARACTER SET utf8 COLLATE utf8_bin NOT NULL

Я также пытался изменить тип текста titlu и articol на varchar.В качестве цели я привел пример таблицы (такой как один текстовый файл и другой varchar), чтобы вы знали, какие настройки я пробовал.

Спасибо:

Паук:

  def parse(self, response):
     #pass
     for link in response.xpath('//h2[@class="titlu_sec"]/a/@href').extract():
         yield response.follow(link, callback=self.parse_detail)
 def parse_detail(self, response):
     item = RezultScrap()
     #for quote in response.css('div.quote')
     item['titlu'] = response.css(".titlu_stire::text").extract()
     item['articol'] = response.css(".descriere_main::text").extract()
     return item

         #item['titlu'] = response.xpath('//div[contains(@id, "interior_left")]/h1/text()').extract_first()
         #item['articol'] = response.xpath('//div[contains(@id, "content_font_resizable")]//text()').extract()
     #titlu = response.css(".titlu_stire::text").extract()
     #articol = response.css(".descriere_main::text").extract()
         #yield item
     #titul1 = re.sub(r"['\\]","", titlu)
     #articol1 =  re.sub(r"['\\]","", articol)


    # yield {
     #        'titlu':titlu,
      #       'articol':articol
             #titlu,
             #articol
     #}

items.py:

import scrapy


 class FirstItem(scrapy.Item):
     # define the fields for your item here like:
     # name = scrapy.Field()
     pass
 class RezultScrap(scrapy.Item):
     titlu=scrapy.Field()
     articol=scrapy.Field()

pipelines.py:

import pymysql
 #from scrapy.exceptions import DropItem
 #pmysql.escape_string("'")
 from first.items import RezultScrap


 class Mysql(object):
         def __init__(self):
             self.connection = pymysql.connect("localhost","xxxxxx","xxxx","ziare")
             self.cursor = self.connection.cursor()


         def process_item(self, item, spider):
             #titlu1 = [pymysql.escape_string(item['titlu'])]
             #articol1 = [pymysql.escape_string(item['articol'])]
             #self.cursor.execute
             #query ="INSERT INTO ziare_com (titlu, articol) VALUES (%s, %s)"
             query ="INSERT INTO ziare_com (titlu, articol) VALUES (%s, %s) % (item['titlu'], item['articol'])"
             self.cursor.execute(query)
             #self.cursor.executemany(query)
             self.connection.commit()
             #return item

         def close_spider(self, spider):
             self.cursor.close()
             self.connection.close()

Ошибки следующие:

Это когда я использую self.cursor.executemany (запрос)

TypeError: executemany () отсутствует 1 обязательный позиционный аргумент: 'args'

и это когда я использую self.cursor.execute (запрос) Я получаю это:

pymysql.err.ProgrammingError: (1064, "У вас есть ошибка в вашем синтаксисе SQL; обратитесь к руководству, соответствующему вашей версии сервера MySQL, чтобы узнать правильный синтаксис для использования рядом с"% s,% s)% (item ['titlu'], item ['articol']) 'в строке 1 ")

Answer 1

Правильный код в process_item:

def process_item(self, item, spider):

    query ="INSERT INTO ziare_com (titlu, articol) VALUES (%s, %s)"
    self.cursor.execute(query, [ item['titlu'], item['articol'] ])
    self.connection.commit()
    return item

Вам просто нужно написать %s для значений, а затем передать их как список (массив) в execute метод

Кроме того,Вы должны узнать о форматировании строки

Вы делали

"INSERT INTO ziare_com (titlu, articol) VALUES (%s, %s) % (item['titlu'], item['articol'])"

Вся эта строка является строкой, вы вообще не передаете значения своей строке

здесь исправлено утверждение

"INSERT INTO ziare_com (titlu, articol) VALUES (%s, %s) " % ((item['titlu'], item['articol']))