Python 读取txt，数据库连接，批量存入数据库

Python 第一次用，做个记录
import textwrap
import pymssql
from datetime import datetime, timedelta


class Data:
    # 数据库连接
    server = ""
    user = ""
    password = ''
    database = ''
    list = []  # 定义列表用来存放SQL语句

    def __init__(self, LogFileName):

        self.LogFileName = LogFileName

    # 格林时间转北京时间
    def UTCtoBJS(self, UTC):
        # UTC_format = "%Y-%m-%dT%H:%M:%S.%fZ"
        BJS_format = "%Y-%m-%d %H:%M:%S"
        UTC = datetime.strptime(UTC, BJS_format)
        # 格林威治时间+8小时变为北京时间
        BJS = UTC + timedelta(hours=8)
        BJS = BJS.strftime(BJS_format)
        return BJS

    # 批量导入数据库
    def StoreToDatabase(self):
        try:
            connect = pymssql.connect(self.server, self.user, self.password, self.database)  # 建立连接
            if connect:
                print("连接成功!")

                cursor = connect.cursor()  # 创建一个游标对象,python里的sql语句都要通过cursor来执行

                sql = ''  # 循环拼接SQL
                for items in self.list:
                    sql += textwrap.dedent(items)

                cursor.execute(sql)  # 执行sql语句
                connect.commit()  # 提交
                self.list.clear()  # 清空 list
                cursor.close()
                connect.close()

            else:
                print("连接失败!")

        except BaseException as ex:
            print('抛出异常', ex)

    def main(self):
        f = open(self.LogFileName, 'r', encoding='UTF-8', errors='replace')
        lines = f.readlines()
        self.list.clear()  # list全局变量清空

      

        print('开始执行，打印文件名', self.LogFileName)

        for line in lines:
            if SourceSite in line:
                array = line.split(' ', 5)

                AccessDate = self.UTCtoBJS('%s %s' % (array[0], array[1]))  # 时间
                SystemPage = array[4][1:len(array[4])]  

              
                if 'App Store' in SystemPage:
                    # txt记录一份 可直接删除
                    # with open('lucky.txt', "a", encoding='UTF-8') as file:  # ”w"代表着每次运行都覆盖内容
                    #     file.write(
                    #         '%s %s %s %s \n' % (time, array[2], array[3], myPageURL))

                    sql = "INSERT dbo.ChemicalbookAccessData (AccessDate,SourceSite,SystemPage,CreateDate)VALUES(\'%s\',\'%s\',\'%s\',GETDATE());" % (
                        AccessDate, SourceSite, SystemPage)
                    self.list.append(sql)  # list 存储 SQL 每20条执行一次

                    if len(self.list) == 20:
                        self.StoreToDatabase()
                        print('每次导入20条数据,导入成功')
        # 再来一个导入
        if len(self.list) > 0:
            print('再来一个导入%s条数据' % (len(self.list)))
            self.StoreToDatabase()
            print('最后一次导入成功')

        print('------------程序结束执行---------------')


if __name__ == '__main__':
    dateNow = datetime.now().strftime('u_ex%C%m%d.log')  # 生成文件名
    mm = ChemicalbookAccessData('D:/Projects/' + dateNow)  # 直接传路径
    mm.main()