import mysql.connector
import pandas as pd
conn = mysql.connector.connect(
host = '...',
port = 3306,
user = "...",
password = "...",
database = "..."
)
df = pd.read_csv("./csvs/my_table.csv")
sql = """INSERT INTO my_table VALUES (%s, %s, %s, %s, %s, %s)"""
cursor = conn.cursor(buffered=True)
for i, row in df.iterrows():
cursor.execute(sql, tuple(row))
print(tuple(row))
conn.commit()
cursor.execute("SELECT * FROM movie")
result = cursor.fetchall()
for row in result:
print(row)
conn.close()