Python with MySQL_1

🗂️ 실습환경 만들기

Jupyter Notebook 실행

VSCode 혹은 Web Browser 를 통해 실행하고, ds_study 환경에서 작업합니다.

실행 위치

Jupyter notebook 과 mysql 은 모두 sql_ws 폴더에서 시작합니다.

1. 데이터 삭제

mysqldump --set-gtid-purged=OFF -h"엔드 포인트" -P 3306 -u
admin -p zerobase police_station >backup_police.sql

use zerobase;

delete from police_station;

❗python.ipyb 파일을 만든 후 오른쪽 상단에 ds_study를 선택한다.
ds_study가 없을 시 terminal에 conda create -n ds_study
python=3.8 을 입력해준다

여기서 오류가 나서 anaconda를 설치해준다
또 오류가 나서 환경변수 설정 후 anaconda에서
conda create -n ds_study python=3.8를 입력 후
scode에서 설정을 해주었다.

🗂️ Python with MySQL

Python 으로 MySQL 접속 후 사용하는 방법

1. Python 에서 MySQL 을 사용하기 위해서는 먼저 MySQL Driver 를 설치한다.

pip install mysql-connector-python
import mysql.connector -설치 확인

📂MySQL 에 접속하기 위한 코드

Create connection 예제1

     > Local Database 연결
     **local = mysql.connector.connect
     (
     host = "localhost",
     user = "root",
     password = "비밀번호"
     )

Create Connection 예제2

AWS RDS(database -1)연결
remote = mysql.connector.connect
(
host ="엔드포인트",
port = 3306,
user ="admin",
password ="비밀번호"
)

close Database

remote.close()
❗실행 후 바로바로 닫아줘야 나중에 복잡해지지 않는다.

Create Connection 예제3

Local MySQL의 zerobase에 연결
local =mysql.connector.connect
(
host ="localhost",
user ="root",
password ="비밀번호",
database ="zerobase"
)

local.close()

Create Connection 예제4

AWS RDS(database-1)의 zerobase에 연결
remote = mysql.connector.connect
(
host ="엔드포인트",
port = 3306,
user ="admin",
password ="비밀번호",
database ="zerobase"
)

remote.close()

📂Query 를 실행하기 위한 코드

-접속 후 cursor를 만든 후 exeute로 쿼리를 보내주는 코드

Execute SQL 예제1

테이블 생성
remote =mysql.connector.connect(
host = "엔드포인트",
port = 3306,
user = "admin",
password ="비밀번호",
database ="zerobase"

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

remote.close()

밑에 터미널에서 확인 (vscode)
서버에 접속
mysql -h "엔드포인트" -P 3306 -u admin -p zerobase
show tables;
desc sql_file;

-> 생성된 것을 확인 할 수 있다.

Execute sql 예제2

-테이블 삭제
import mysql.connector

remote = mysql.connector.connect(
host = "database-1.cvs6igoc6b14.us-east-2.rds.amazonaws.com",
port =3306,
user ="admin",
password ="비밀번호",
database ="zerobase"
)

cur = remote.cursor()
cur.execute("DROP TABLE sql_file")

remote.close()

밑에 터미널에서 확인 (vscode)
mysql> desc sql_file;
ERROR 1146 (42S02): Table 'zerobase.sql_file' doesn't exist

Execute SQL File 예제1

-1.test03.sql 생성

왼쪽에 파일 생성 후 입력
CREATE TABLE sql_file
(
id int,
filename VARCHAR(16)
);

Execute SQL File 예제1

-2. 실행 (python.ipynb파일에서)

remote = mysql.connector.connect(
host = "database-1.cvs6igoc6b14.us-east-2.rds.amazonaws.com",
port =3306,
user ="admin",
password ="비밀번호",
database ="zerobase"
)
cur = remote.cursor()
sql =open ("test03.sql").read() -파일을 열고 읽어주세요
cur.execute(sql)
remote.close()

❗test03.sql 같은 경로라 이렇게 적지만 다른 경로라면 경로 적어줘야한다.

3. 확인

sql_file이 다시 생겨남

Execute SQL File 예제2

-SQL File내에 Query가 여러 개 존재하는 경우
1. test04.sql 생성

왼쪽에 파일 생성 후 입력
INSERT INTO sql_file VALUES(1,"test01.sql")
INSERT INTO sql_file VALUES(2,"test02.sql")
INSERT INTO sql_file VALUES(3,"test03.sql")
INSERT INTO sql_file VALUES(4,"test04.sql")

2. 실행-(python.ipynb파일에서)

remote = mysql.connector.connect(
host = "database-1.cvs6igoc6b14.us-east-2.rds.amazonaws.com",
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.statment)

remote.commit()
remote.close()

3. 확인

show tables;
select *from sql_file