我可以看到您已经有了execute()函数。批量插入应该更快。

args= ', '.join(map(str, df.to_records().tolist()))

sql = "
INSERT INTO table1 (value1,
                    value2,
                    value3,
                    value4,
                    value5,
                    value6,
                    value7)
VALUES {}".format(args)

connection_factory = ConnectionFactory()
connection_factory.execute(sql)

创建新方法以从不带参数的字符串执行查询。

def execute2(self, query):
    try:
        cursor = self.connection.cursor()
        cursor.execute(query)
    except Exception as e:
        print(e)
    finally:
        cursor.close()
        return

这是另一个答案。使用 CASE 和 IFNULL

SELECT id AS ID
   , CASE WHEN IFNULL(first_name, '') = '' THEN 'NULL' ELSE first_name END AS Name 
FROM tbl_user