[Python] MariaDB select/insert/update/delete

day06/mari_select.py

import pymysql

con = None
cur = None

sql = ""

#메인코드
con = pymysql.connect(host='localhost', port=포트번호, user='root', password='python',
                       db='python', charset='utf8') #접속 정보
cur = con.cursor() #커서 생성

sql = "select * from emp"
cur.execute(sql)

#cur.fetchone() -> 하나만 가져옴
rows = cur.fetchall()
print(rows)

con.commit()
cur.close()
con.close()

day06/mari_select_json.py

import pymysql

con = None
cur = None

sql = ""

#메인코드
con = pymysql.connect(host='localhost', port=포트번호, user='root', password='python',
                       db='python', charset='utf8') #접속 정보
cur = con.cursor(pymysql.cursors.DictCursor) #커서 생성

sql = "select * from emp"
cur.execute(sql)

#cur.fetchone() -> 하나만 가져옴
rows = cur.fetchall()
print(rows)

cur.close()
con.close()

∴ 실행 결과
[{'e_id': 1, 'e_name': '1', 'gen': '1', 'addr': '1'}, {'e_id': 2, 'e_name': '2', 'gen': '2', 'addr': '2'}, {'e_id': 3, 'e_name': '3', 'gen': '3', 'addr': '3'}, {'e_id': 4, 'e_name': '4', 'gen': '4', 'addr': '4'}, {'e_id': 6, 'e_name': '1', 'gen': '1', 'addr': '1'}]

day06/mari_insert.py

import pymysql

#메인코드
con = pymysql.connect(host='localhost', port=포트번호, user='root', password='python',
                       db='python', charset='utf8') #접속 정보
cur = con.cursor() #커서 생성

sql = """INSERT INTO emp (e_id, e_name, gen, addr) VALUES (%s, %s, %s, %s)"""

#모든 컬럼에 데이터 3 insert
cur.execute(sql, ("3", "3", "3", "3"))

con.commit()
cur.close()
con.close()

day06/mari_insert2.py

import pymysql

#메인코드
con = pymysql.connect(host='localhost', port=포트번호, user='root', password='python',
                       db='python', charset='utf8') #접속 정보
cur = con.cursor() #커서 생성

e_id = "6"
e_name = "6"
gen = "6"
addr = "6"

sql = f"""
INSERT INTO emp
    (e_id, e_name, gen, addr)
VALUES
    ('{e_id}', '{e_name}', '{gen}', '{addr}')
"""

# 삽입된 행이 몇 개인지 가져오기
# cnt = cur.rowcount
cnt = cur.execute(sql)
cur.execute(sql)
print("cnt", cnt)

con.commit()
con.close()

day06/mari_update.py

import pymysql

#메인코드
con = pymysql.connect(host='localhost', port=포트번호, user='root', password='python',
                       db='python', charset='utf8') #접속 정보
cur = con.cursor() #커서 생성

e_id = "6"
e_name = "1"
gen = "1"
addr = "1"

sql = f"""
UPDATE emp
SET e_name = '{e_name}', gen = '{gen}', addr = '{addr}'
WHERE e_id = '{e_id}'
"""

# 삽입된 행이 몇 개인지 가져오기
# cnt = cur.rowcount
cnt = cur.execute(sql)
cur.execute(sql)
print("cnt", cnt)

con.commit()
con.close()

day06/mari_delete.py

# 전역변수 선언부
import pymysql

#메인코드
con = pymysql.connect(host='localhost', port=포트번호, user='root', password='python',
                       db='python', charset='utf8') #접속 정보
cur = con.cursor() #커서 생성

e_id = "5" 

sql = f"""
DELETE FROM emp
WHERE
    (e_id = '{e_id}')
"""

# 삽입된 행이 몇 개인지 가져오기
# cnt = cur.rowcount
cnt = cur.execute(sql)
cur.execute(sql)
print("cnt", cnt)

con.commit()
con.close()