Запись новых строк в mySQL

class Sql_remedy:
    def __init__(self):
        log.info('инициализация класса Sql')
        print('инициализация класса Sql')
    def con_sql(self):
        print('открытие соединения в БД')
        self.con = pymysql.connect(host='10.10.000.000', user='123', password='123', db='dd')
        self.cur = self.con.cursor()
        return self.cur
    def record_sql(self, pd_rec):
        for index, row in pd_rec.iterrows():
            log.info('запись в БД : %s', row[0])
            self.str1 = "(Номер, Статус, `Время регистрации`)"
            self.str2 = ""
            for string in row:
                if string and str(string) != 'NaT':
                    self.str2 = self.str2 + "'" + str(string) + "',"
                else:
                    self.str2 = self.str2 + "NULL,"
            self.str2 = self.str2[:-1]#удалить последний символ в строке
            self.str_record = "INSERT INTO 1492 " + self.str1 + " VALUES " + "(" + self.str2 + ")"
            print(self.str_record)
            try:
                self.cur.execute(self.str_record)
            except ValueError as vx:
                log.error("!!! Ошибка записи sql: %" + vx)
                print(vx)
            except Exception as ex:
                print(ex)
                log.error("!!! Ошибка записи sql: %" + ex)
        return 0
    def protokol(self, ei):
        self.cur.execute("""SELECT * FROM 1492 """)  
        rows = self.cur.fetchall()
        self.pd_protokol = pd.DataFrame(rows)
        return self.pd_protokol
    def __exit__(self, exc_type, exc_value, exc_trace):
        self.con.commit()
        self.cur.close()
        self.con.close()
        print('закрытие соединения')
 
s1 = Sql_remedy() 
df_SI = s1.protokol
s1.record_sql(df_SI)