pip install mysql-connector-python
# 연결
import mysql.connector
# Python - SQL
local = mysql.connector.connect(
host = "",
user = "",
password = "",
database = "" # 생략 가능
)
# Python - AWS RDS
remote = mysql.connector.connect(
host = "앤드포인트"
port = 3306,
user = "",
password = "",
database = "" # 생략 가능
)
# 연결 마침
local.close()
remote.close()
쿼리 작성 - execute SQL
Table 생성시 - CRAETE TABLE ~~~ 쿼리
Table 삭제시 - DROP TABLE ~~~ 쿼리
cursor = db.cursor()
cursor.execute("<query>");
cursor = db.cursor()
sql = open("파일명").read()
cursor.execute(sql)cursor = db.cursor()
sql = open("파일명").read()
cursor.execute(sql, multi = True)데이터가 결과값에 담김
result = cursor.fetchall()
읽어올 데이터 양이 많을 경우
cursor = db.cursor(bufferd = True)
cursor = db.cursor()
cursor.execute("쿼리")
result = cursor.fetchall()
result
csv에 있는 데이터를 Python으로 INSERT
df = pd.read_csv("파일명.csv")
db = mysql.connector.connect(
~~
)
cursor = db.cursor()
sql = "insert into 테이블명 values (%s, %s)"
for i, row in df.iterrows()
cursor.execute(sql, tuple(row))
db.commit()