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"))