[ Python ] Python ORM sqlalchemy 이용한 DataFrame Data Insert

 

 

 

SQLAlchemy 은 대표적인 파이썬 ORM 이다.

 

ORM이란 객체 관계 매핑(Object Relational Mapping)으로 데이터베이스 내의 테이블들을 객체화하여 각 DBMS에 대해서 CRUD (Create(생성), Read(읽기), Update(갱신), Delete(삭제)) 등 을 사용할 수 있다.

 

프로그램이 커지게 되면, SQL쿼리도 많아지게 되는 데, 반복되는 SQL 쿼리를 처리하기 유용하다. 

 

 

 

 

 

 

1. 모듈설치

 

pip install pandas
pip install SQLAlchemy

 

 

2. 접속

 

import pandas as pd
from sqlalchemy import create_engine

# DataFrame 생성

df = pd.DataFrame(rows,columns=['Col_A','Col_B','Col_C','Col_D','Col_E','Col_F'])

# 컬럼은 DB컬럼과 동일

db_connection = 'mysql+pymysql://{user}:{password}@{host}/{database}'
db_connection = create_engine(db_connection)
conn = db_connection.connect()


df.to_sql(name='{table_name}', con=db_connection, if_exists='append',index=False)

# Databse Name : table_name