import mysql.connector import pandas as pd conn = mysql.connector.connect( host ="엔드포인트", port = 3306, user ="zero", password ="비밀번호", database = "zerobase" )
df =pd.read_csv("data/sandwich.csv", encoding="utf-8") df.tail()
↪️ csv 파일을 읽어온다.
결과
df.info()
↪️ 5개의 컬럼을 가지고 있는 것 과 각각의 데이터 타입 확인 가능
sql = "create table sandwich (ranking int, cafe varchar(32), menu varchar(32), price float, address varchar(32))" cursor = conn.cursor(buffered=True) cursor.execute(sql)
cursor.execute("desc sandwich") result =cursor.fetchall() for row in result: print(row)
↪️ 확인 가능
sql = "insert into sandwich values (%s, %s, %s, %s, %s)" for i, row in df.iterrows(): cursor.execute(sql, tuple(row)) print(tuple(row)) conn.commit()
↪️ 튜플 형태로 바꿔주고 받고 제대로 들어갔는지 하나씩 확인해준다.
하나 들어갈때마다 커밋을 해준다.
conn.close
mysql -h 엔드포인트 -P 3306 -u admin -p zerobase
show tables;
↪️ sandwich 확인 가능
select * from sandwich;
↪️ 잘 들어가 있는 것을 확인 가능