<< 순서>>
1. csv에 있는 데이터 python으로 insert
: police_station.csv파일 pandas로 읽어오기
2. zerobase 데이터베이스에 연결
3. cursor 만들기 # cursor 통해서 sql문 실행
4. sql문 실행 (insert문)
5. 결과확인
6. 검색결과 가져오기 (pandas로 읽기)
1.
import pandas as pd
df=pd.read_csv('police_station.csv')
df.tail()
2.
import mysql.connector
conn=mysql.connector.connect(
host="database-1.cwqkoizytqee.ap-northeast-1.rds.amazonaws.com",
port=3306,
user='zero',
password='zerobase',
database='zerobase'
)
3.
cursor=conn.cursor(buffered=True) # 읽어올 데이터 많을 경우 buffered=True
4.
sql='insert into police_station values (%s, %s)' # 컬럼 2개
# sql문이랑 연결
for i, row in df.iterrows():
cursor.execute(sql,tuple(row))
print(tuple(row))
conn.commit()
5.
cursor.execute('select * from police_station')
result=cursor.fetchall()
result
6.
df=pd.DataFrame(result)
df.tail()