스터디 노트 (Python with MySQL)

📌 Python with MySQL

- mysql.connector library를 설치 및 import

pip install mysql-connector-python

 

import mysql.connector

📌 mysql 접속하기

- 로컬 호스트로 접속하는 경우

import mysql.connector
mydb = mysql.connector.connect(
    host = "localhost"
    user = "root"
    password = "******"
)

- AWS 환경으로 접속하는 경우

import mysql.connector
remote = mysql.connector.connect(
    host = "end_point"
    port = port_number
    user = "admin"
    password = "******"
)

- 사용을 다 했다면 connect를 종료

mydb.close()

📌 connect to database

- 특정 데이터베이스에 바로 접속하기

- 기존 connect 문에 database 항목이 추가된다.

import mysql.connector
mydb = mysql.connector.connect(
    host = "localhost"
    user = "root"
    password = "******"
    database = "db_name"
)

📌 execute로 쿼리를 날려보자

- execute로 sql에서 사용하는 쿼리를 사용할 수 있다.

remote = mysql.connector.connect(
    host = "host_name"
    port = "port_number"
    user = "admin"
    password = "******"
    database = "db_name"
)

cur = remote.cursor()
cur.execute("query")

🧷 예시

cur = remote.cursor()
cur.execute("create table sql_file (id int, filename varchar(16))")

query를 날리고, sql로 접속하면 확인 가능

cur = remote.cursor()
sql = open("test03.sql").read()
cur.execute(sql)

해당 sql 파일을 실행할 수 있다.

📌 복수 쿼리 사용하기

- execute 문에 쿼리와 함께 multi=True옵션을 준다.

cur = remote.cursor()
sql = open("test04.sql").read()
for result_iterator in cur.execute(sql, multi=True): #multi=True 값을 준다
    if result_iterator.with_rows:
        print(result_iterator.fetchall())
    else:
        print(result_iterator.statement)
remote.commit()

복수의 Query가 작성되어 있는 파일

📌 fetchall()

- 불러올 데이터가 많을 때, buffered = True 옵션을 줄 수 있다

- fetchall() 함수로 쿼리에 대한 출력 값을 return 받을 수 있다 (다양한 것을 할 수 있음!)

cur = remote.cursor(buffered=True)
cur.execute("query")
result = cur.fetchall()
result

복수의 tuple로 이루어진 list 형태의 값을 반환 받는다

for result_iterator in result:
	print(result_iterator)

for문을 통해 튜플 형태로 반환 받는다.

🧷 pandas 형태로 불러오기 

import pandas as pd
df = pd.DataFrame(result)
df.head()

Pandas DataFrame 형태로 결과 값을 불러올 수 있다.