add class for connect to database

src/database/Connector.py

+from sqlalchemy import create_engine
+from sqlalchemy.orm import sessionmaker
+from scrapy.conf import settings
+
+
+class Connector:
+    connection = None
+    engine = create_engine(settings['CONNECTION_STRING'])
+    Session = sessionmaker(bind=engine)
+
+    @staticmethod
+    def get_session():
+        return Connector.Session()
+
+    @staticmethod
+    def get_connection():
+        if not Connector.connection:
+            Connector.connection = Connector.engine.connect()
+        return Connector.connection

src/database/connectors/BookConnector.py

+from ..Connector import Connector
+from ..models.Book import Book
+
+
+class BookConnector(Connector):
+    def save_book(self, item):
+        session = self.get_session()
+
+        book = Book()
+        book.update(item)
+        book.image_path = item['images'][0]['path']
+
+        session.add(book)
+        session.commit()
\ No newline at end of file

src/pipelines/DatabasePipeline.py

+
+
+class DatabasePipeline:
+    name = 'DatabasePipeline'
+
+    def process_item(self, item, spider):
+        spider.save_book(item)
+        return item

src/spiders/books_spider.py

 import scrapy
 import re
 from items.BookItem import BookItem
+from database.connectors.BookConnector import BookConnector
+import logging
 
 
 class BooksSpider(scrapy.Spider):
+class BooksSpider(BookConnector, scrapy.Spider):
     name = 'books'
     start_urls = [
         'http://books.toscrape.com/catalogue/page-1.html'