import pandas as pd
import mysql.connector as msql
from mysql.connector import Error
HOST = "localhost"
DATABASE = "Employees"
USER = "root"
PATH = "data/employees.csv"
data = pd.read_csv(PATH)
data = data.to_dict(orient="records")
val = [(dept["emp_no"], dept["emp_title_id"],dept["birth_date"], dept["first_name"], dept["last_name"], dept["sex"], dept["hire_date"]) for dept in data]
try:
conn = msql.connect(host= HOST, database=DATABASE, user=USER, password='')
if conn.is_connected():
cursor = conn.cursor()
sql = "INSERT INTO employees (emp_no,emp_title, birth_date,first_name,last_name,gender,hire_date) VALUES (%s, %s, %s, %s, %s, %s, %s)"
cursor.executemany(sql, val)
conn.commit()
print("Completed process")
except Error as e:
print("Error while connecting to MySQL", e)
Comments
Post a Comment