my_function.py

def df_to_mysql(df,table_name):

    import pyodbc

    cn = pyodbc.connect('DRIVER={MySQL ODBC 8.0 ANSI Driver};SERVER=localhost;DATABASE=my_db;USER=;PASSWORD=;OPTION=3;')

    cn.execute("truncate table " + table_name)

    for row in df.values:

        SQL = ""

        for i in row:

            if SQL == "":

                SQL = "insert into " + table_name + " values ('" + str(i) + "'"

            else:

                SQL += ",'" + str(i) + "'"

        SQL += ")"

        #print(SQL)

        cn.execute(SQL)

    cn.commit()

    cn.close()

    return "df_to_mysql1 execute completed"

#執行前確認DaraFrame與DB Schema一致

from my_function import df_to_mysql

print(df_to_mysql(df,"iris"))