scrapy mysql测试连接

import pymysql
from scrapy.utils.project import get_project_settings

class MySQLPipeline(object):
    def __init__(self):
        settings = get_project_settings()
        self.host = settings.get('MYSQL_HOST')
        self.port = settings.get('MYSQL_PORT')
        self.user = settings.get('MYSQL_USER')
        self.password = settings.get('MYSQL_PASSWORD')
        self.db = settings.get('MYSQL_DB')
        self.connection = None

    def open_spider(self, spider):
        self.connection = pymysql.connect(
            host=self.host,
            port=self.port,
            user=self.user,
            password=self.password,
            db=self.db,
            charset='utf8mb4',
            cursorclass=pymysql.cursors.DictCursor
        )

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

    def process_item(self, item, spider):
        with self.connection.cursor() as cursor:
            sql = "INSERT INTO table_name (column1, column2) VALUES (%s, %s)"
            cursor.execute(sql, (item['value1'], item['value2']))
        self.connection.commit()
        return item