SQL(Python with CSV)

1. csv파일 읽기

import pandas as pd

df = pd.read_csv("csv File_name")
df.head()

1-1) 한글파일 같은 경우 깨지는 경우가 많음! (인코딩을 euc-kr로 해주기)

import pandas as pd

df = pd.read_csv("csv File_name",encoding ='euc-kr')
df.head()

2. 제로베이스에 연결

import mysql.connector

conn = mysql.connector.connect(
	host = "엔드포인트",
    port = "포트넘버",
    user = "username",
    password = "password",
    database = "zerobase"
    
)

3. cursor 만들기
   읽어올 데이터 양이 많을시 buffered = true 설정해주기!

cursor = conn.cursor(buffered=true)

4. Insert문 만들기

sql = "Insert into name values(%s,%s...)"

5. 데이터입력
   df.iterrows()?
   dataframe에서 행(row)를 반복!

for i, row in df.iterrows():
	cursor.execute (sql,tuple(row))
    print(tuple(row))
    conn.commit()

commit 뒤에 꼭 괄호 쓰기!!!

데이터 입력과정에서 에러가 나서 당황스러웠다...
창을 새로 만들고 여러번 돌리니 겨우 성공...!

6. 데이터확인

cursor.execute(select * from file_name)

result = cursor.fetchall()
for row in result:
	print(row)

6-1) 검색결과 pandas로 확인

df = pd.dataframe(result)
df