🗂️ Fetch All

실행하는 쿼리가 아니라 조회하는 select문을 실행한 경우에는 데이터를 가지고 오는데 그 데이터를 fetch all을 써서 변수에 담을 수가 있다.

📂 SQL File내에 Query가 여러 개 존재하는 경우

> import mysql.connector
  remote = mysql.connector.connect(
  host = "엔드포인트",
  port =3306,
  user ="admin",
  password ="비밀번호",
  database ="zerobase"
)

>cur = remote.cursor()
sql = open("test04.sql").read()
for result_iterator in cur.execute(sql, multi=True):
    if result_iterator.with_rows:
        print(result_iterator.fetchall())
    else:
        print(result_iterator.statement)
        
>remote.commit()
 remote.close()

🗂️Python with CSV

CSV 에 있는 데이터를 Python 으로 INSERT 큰 데이터들이 엑셀이나 scv파일에 들어있는 경우가 있다.
이런한 것을 db에 넣고 쿼리를 해보고 싶을 때 파이썬으로 한꺼번에 넣는 방법

📂 CSV에 있는 데이터를 PYTHON으로 INSERT

police_station.csv를 Pandas로 읽어오기

import pandas as pd
df = pd.read_csv("police_station.csv") ** # 파일을 가져와서 읽어본다.**
df.tail()                              ** # 데이터가 몇개 있는지 확인-30개**

📂 zerobase에 연결

import mysql.connector

conn = mysql.connector.connect(
host ="엔드포인트",
port =3306,
user ="zero",
password = "비밀번호",
database ="zerobase" #zero라는 계정은 zerobase라는 데이터베이스에만 권한을 줬기 때문에 접근 가능
)

❗여기서 오류 발생.

ERROR 1045 (28000) 쳐보니 비밀번호를 올바르게 쓰라는데 올바르게 썼는데 오류가 나서 사용자의 비밀번호를 변경해주어서 해결!
ALTER USER 'zero'@'%' IDENTIFIED BY '비밀번호';

📌 mysql.connector excute- 자세히 보고 싶으면 공식 문서 참조

📂 cursor 만들기

• 읽어올 양이 많은 경우 buffer 설정을 해준다.
• Buffer 옵션은 결과를 볼꺼니까 true로 해준다.

cursor = conn.cursor(buffered= True)

📂 insert문 만들기

컬럼 2개의 정보를 넣어주기 위해서 2개의 string값을 받아줄 수 있는 설정을 해준것이다.

sql =" insert into police_station values (%s, %s)" 

📂 데이터 입력

commit()은 database에 적용하기 위한 명령

for i, row in df.iterrows():
    cursor.execute(sql, tuple(row)) #cursor에 execute sql문을 실행하면 그걸 날려준다.
    print (tuple(row))
    conn.commit()
    ```
    ![](https://velog.velcdn.com/images/quf277/post/eec47edc-c0d3-46f6-8d3d-5abe044cb376/image.png)

📂 결과확인

cursor.execute("select * from police_station")
result =cursor.fetchall()
result[3]

for row in result:
    print(row)
    ```

📂 검색 결과를 pandas로 읽기

df =pd.DataFrame(result)
 df.tail()

📂 python with CSV 예제

crime_status 테이블에 2020_crime.csv를 입력하는 코드를 작성

import mysql.connector

conn =mysql.connector.connect(
    host ="엔드포인트",
    port = 3306,
    user ="zero",
    password ="비밀번호",
    database ="zerobase"
)

🗒️ 2020_crime.csv 데이터 (encoding ="euc-kr")읽어오기

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

🗒️ insert 쿼리 작성

 sql = " insert into crime_status values ('2020', %s, %s, %s, %s)"
cursor =conn.cursor(buffered=True)

🗒️ 데이터를 crime_status 테이블에 insert

for i, row in df.iterrows():
    cursor.execute(sql, tuple(row))
    print(tuple(row))
    conn.commit()
    ```
    ![](https://velog.velcdn.com/images/quf277/post/695fd18d-e1ac-47b9-b57a-4c8a8dac9002/image.png)

🗒️ crime_status 테이블의 데이터 조회

cursor.execute("select * from crime_status")

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

🗒️ 조회한 결과를 pandas로 변환해서 확인

 df=pd.DataFrame(result)
 df.head()