1) sql_ws로 가서 sandwich.csv 파일 확인
2) 새로운 sandwich.ipynb 생성
3) mysql connector연결, pandas 불러오기
import mysql.connector
import pandas as pd
4) 접속변수 만들기
conn = mysql.connector.connect(
host = "엔드포인트"
port = 3306
user = "admin"
password = "*****"
database = "zerobase"
)
5) csv파일 read하기
df = pd.read_csv("path/sandwich.csv", encoding = "utf-8")
df.tail()
6) 데이터 (columns, datatype...) 살펴보기
df.info
7) 테이블 만들기
sql = "create table sandwich
(ranking int, cafe varchar(32), menu varchar(32), price int, address varchar(32))"
cur = conn.cursor(buffered=True)
cur.execute(sql)
8) 확인하기
cur.execute("desc sandwich")
result = cur.fetchall()
result
9) 테이블 안에 데이터 넣기
sql = "insert into values (%s,%s,%s,%s,%s)"
for i,row in df.iterrows():
cur.execute(sql, tuple(row))
print tuple(row)
conn.commit()
10) 연결 끊기
conn.close()
11) 생성된 테이블 확인하기
show tables;
select * from sandwich;