import pymysql

#查詢資料庫
def findFromDB( query_id):
    db = pymysql.connect(host='localhost', user='root', passwd='', db='test', port=3306, charset='utf8')
    cursor = db.cursor()
    sql = ' select * from amazon_aces where asin = %s '
    cursor.execute(sql, (query_id))
    db.commit()
    cursor.close()
    db.close()
    return cursor.fetchone() is not None

#插入資料庫
def insertIntoDB( asin, checked):
    db = pymysql.connect(host='localhost', user='root', passwd='', db='test', port=3306, charset='utf8')
    cursor = db.cursor()
    sql = " insert into amazon_aces(asin , checked)  values(%s , %s) "
    cursor.execute(sql, (asin, checked))
    db.commit()
    cursor.close()
    db.close()


def createTable():
    '''建立表'''
    db = pymysql.connect(host='localhost', user='root', passwd='', db='test', port=3306, charset='utf8')
    cursor = db.cursor()
    cursor.execute('''
        CREATE TABLE `amazon_aces` (
          `asin` varchar(200) NOT NULL ,
          `checked` varchar(200) ,
          PRIMARY KEY  (`asin`)
        ) 
        ''')
    db.commit()
    cursor.close()
    db.close()

#刪除資料庫表
def dropTable():
    db = pymysql.connect(host='localhost', user='root', passwd='', db='test', port=3306, charset='utf8')
    cursor = db.cursor()
    cursor.execute('''
    DROP TABLE IF EXISTS `amazon_aces`
    ''')
    db.commit()
    cursor.close()
    db.close()


if __name__ == '__main__':
    dropTable()
    createTable()
    insertIntoDB("1","aaa")
    insertIntoDB("2","bb")
 

模組開發：

import pymysql
import pandas as pd
import re
import os
import requests
import time
class Database():
    def __init__(self):
        self.tablename = "category" # 可以設定表名
        self.host = "localhost"
        self.user = "root"
        self.password ="123456"
        self.database="ebay"
        self.charset = "utf8"
        self.connect = pymysql.connect(host = self.host, user = self.user,password = self.password, database = self.database, charset =  self.charset)
        self.cursor = self.connect.cursor()
    #刪表
    def dropTable(self):
        sql = 'drop table if exists '+self.tablename
        self.cursor.execute(sql)
        print("刪表")
    #建表
    def createTable(self):
        sql = 'create table if not exists '+ self.tablename+ '''
        (
            id int(11) primary key auto_increment,
            ebayno varchar(100) not null,
            category varchar(1000)  
        )
        '''
        self.cursor.execute(sql)
        print("建表")
    #判斷是否存在ebayno
    def is_exists_ebayno(self,ebayno):
        sql = 'select * from '+self.tablename + ' where ebayno = %s'
        self.cursor.execute(sql,ebayno)
        if self.cursor.fetchone() is None:
            return False
        return True
    #儲存資料
    def save(self,ebayno,category):
        sql = 'insert into '+self.tablename+' (ebayno , category) values (%s,%s)'
        self.cursor.execute(sql,(ebayno,category))
        self.connect.commit()




db = Database()
db.dropTable()
db.createTable()
print(db.is_exists_ebayno("111"))
db.save("111","adaa")
print(db.is_exists_ebayno("111"))