Categories : Python
Python 을 이용한 SQL의 데이터 임포트 / 엑스포트
MySQL 입출력 코드에 대한 예시 코드
데이터 임포트 / 엑스포트 할때 사용했던 명령어
0. Import
import pandas as pd
from sqlalchemy import create_engine
import pymysql
# CSV 파일을 DataFrame으로 불러오기
df = pd.read_csv('A.csv')
# MySQL 엔진 생성
engine = create_engine('mysql+pymysql://user:password@host(ip)/database')
# DataFrame을 MySQL에 업로드
df.to_sql('table_name', con=engine, if_exists='append', index=False)
A.csv를 읽고mysql의database에table_name이라는 이름으로 Import
0. Export
import pandas as pd
from sqlalchemy import create_engine
import pymysql
# MySQL 엔진 생성
engine = create_engine('mysql+pymysql://user:password@host(ip)/database')
# SQL 쿼리를 사용하여 데이터를 DataFrame으로 불러오기
query = "SELECT * FROM {database}.{table_name}"
df = pd.read_sql_query(query, con=engine)
# DataFrame을 CSV 파일로 저장
df.to_csv('B.csv', index=False, encoding='utf-8')
query를 읽고B.csv로 Export