[python][자료구조] Python - MySQL 데이터 추가, 삭제, 업데이트

파이썬에서 pymysql을 이용하여 MySQL에 데이터를 추가(INSERT), 업데이트(UPDATE), 삭제(DELETE)하는 방법을 소개합니다.

MySQL의 다른 글들도 참고해주세요.

1. pymysql 설치

pymysql는 파이썬의 MySQL 라이브러리입니다. pip 명령어로 설치할 수 있습니다.

$ python3 -m pip install PyMySQL

2. 데이터 추가(INSERT)

다음 코드는 데이터를 추가하는 예제입니다.

MySQL 서버가 설치되어있고, 계정이 모두 생성된 상태에서 connect()로 서버에 접속합니다. cursor를 통해 SQL을 실행하여 데이터를 추가합니다. with 구문을 사용하기 때문에 cursor, conn의 close()를 호출할 필요가 없습니다. with 구문 종료 시점에 자동으로 호출됩니다.

import pymysql

conn = pymysql.connect(host='localhost',
                       user='testuser',
                       password='Fktm068**',
                       db='testdb',
                       charset='utf8')

sql = "INSERT INTO user (name, email) VALUES (%s, %s)"

with conn:
    with conn.cursor() as cur:
        cur.execute(sql, ('Jaehee', 'jaehee@example.com'))
        cur.execute(sql, ('Jeongeun', 'jeongeun@example.com'))
        conn.commit()

MySQL 콘솔에서 다음과 같이 데이터가 추가되었는지 확인할 수 있습니다.

mysql> select * from testdb.user;
+----+----------+----------------------+
| id | name     | email                |
+----+----------+----------------------+
|  1 | Jaehee   | jaehee@example.com   |
|  2 | Jeongeun | jeongeun@example.com |
+----+----------+----------------------+

3. 데이터 추가 확인

다음과 같이 파이썬에서 SELECT SQL을 실행하여 추가된 데이터를 확인할 수 있습니다. 하기 SQL은 user table에 있는 모든 데이터를 name으로 정렬하여 가져옵니다.

import pymysql

conn = pymysql.connect(host='localhost',
                       user='testuser',
                       password='Fktm068**',
                       db='testdb',
                       charset='utf8')

sql = "SELECT * FROM user ORDER BY name"

with conn:
    with conn.cursor() as cur:
        cur.execute(sql)
        result = cur.fetchall()
        for data in result:
            print(data)

Output:

경축! 아무것도 안하여 에스천사게임즈가 새로운 모습으로 재오픈 하였습니다.
어린이용이며, 설치가 필요없는 브라우저 게임입니다.
https://s1004games.com

(1, 'Jaehee', 'jaehee@example.com')
(2, 'Jeongeun', 'jeongeun@example.com')

4. 데이터 업데이트(UPDATE)

다음과 같이 기존에 추가된 항목들의 데이터를 업데이트할 수 있습니다. WHERE를 이용하여 변경하려는 데이터에 대한 조건을 설정합니다. email이 jahee@example.com인 데이터를 찾고, email을 jahee@test.com으로 변경합니다.

import pymysql

conn = pymysql.connect(host='localhost',
                       user='testuser',
                       password='Fktm068**',
                       db='testdb',
                       charset='utf8')

sql = "UPDATE user SET email = %s WHERE email = %s"

with conn:
    with conn.cursor() as cur:
        cur.execute(sql, ('jaehee@test.com', 'jaehee@example.com'))
        conn.commit()

MySQL 콘솔에서 다음과 같이 데이터가 업데이트되었는지 확인할 수 있습니다.

mysql> select * from testdb.user;
+----+----------+----------------------+
| id | name     | email                |
+----+----------+----------------------+
|  1 | Jaehee   | jaehee@test.com      |
|  2 | Jeongeun | jeongeun@example.com |
+----+----------+----------------------+

SELECT SQL으로 데이터가 업데이트되었는지 확인할 수도 있습니다.

5. 데이터 삭제(DELETE)

다음과 같은 SQL로 데이터를 삭제할 수 있습니다. WHERE를 이용하여 조건에 맞는 데이터만 삭제할 수 있습니다. cur.rowcount는 삭제된 항목들의 개수입니다.

import pymysql

conn = pymysql.connect(host='localhost',
                       user='testuser',
                       password='Fktm068**',
                       db='testdb',
                       charset='utf8')

sql = "DELETE FROM user WHERE name = %s"

with conn:
    with conn.cursor() as cur:
        cur.execute(sql, ('Jaehee'))
        conn.commit()
        print(cur.rowcount, "rows deleted")

Output:

1 rows deleted

MySQL 콘솔에서 다음과 같이 데이터가 삭제되었는지 확인할 수 있습니다.

mysql> select * from testdb.user;
+----+----------+----------------------+
| id | name     | email                |
+----+----------+----------------------+
|  2 | Jeongeun | jeongeun@example.com |
+----+----------+----------------------+
[출처] https://codechacha.com/ko/python-mysql-insert-update-delete/

 

 

본 웹사이트는 광고를 포함하고 있습니다.
광고 클릭에서 발생하는 수익금은 모두 웹사이트 서버의 유지 및 관리, 그리고 기술 콘텐츠 향상을 위해 쓰여집니다.
번호 제목 글쓴이 날짜 조회 수
66 [Django] 장고 CORS 크로스 도메인 이슈 졸리운_곰 2023.12.17 504
65 [django] CORS(Cross Origin Resource Sharing) in Django 졸리운_곰 2023.12.17 421
64 [django] Forbidden (CSRF cookie not set.) 오류 해결하기 file 졸리운_곰 2023.12.17 346
63 [Django] Django 서버를 domain forwarding 시 : Django nginx Refused to display in a frame because it set 'X-Frame-Options' to 'SAMEORIGIN' 졸리운_곰 2023.12.17 404
62 [Django] Django SSLServer 설정 및 구동 방법 file 졸리운_곰 2023.12.16 288
61 [Django][Django restframework] Django REST framework 시작하기 file 졸리운_곰 2023.05.07 365
60 [Django] REST API 로그인 서버 만들기 (2) - DB 연동, 테스트 file 졸리운_곰 2023.05.07 803
59 [Django] REST API 로그인 서버 만들기 (1) - 코드 졸리운_곰 2023.05.07 430
58 [Django] user의 ip address 가지고 오기 졸리운_곰 2023.05.07 461
57 [Django] [Python_Django] You are trying to add a non-nullable field '필드명' to post without a default 해결 졸리운_곰 2023.05.07 325
56 [Django] [Python_Django] 관리자 계정에서 테이블 관리하기 file 졸리운_곰 2023.05.06 397
55 [Django] TIP - 장고 데이터베이스 여러개 사용하기 (Django multidatabase) file 졸리운_곰 2023.05.05 345
54 [Django] 장고 동작 flow에 대해 알아보자! file 졸리운_곰 2023.05.01 455
53 [python django] 내 이해를 도울 Django flow file 졸리운_곰 2023.05.01 502
52 [Django] 개발 Flow & 개발 환경 세팅 file 졸리운_곰 2023.05.01 386
51 [Django] 장고 명령어 기초 정리 졸리운_곰 2023.05.01 439
50 [python django] 장고 자주 쓰는 manage.py 명령 졸리운_곰 2023.05.01 610
49 [python][Django] Python Package Trends: Visualize Package Download Stats in Django file 졸리운_곰 2023.03.18 368
48 [python][Django] Django Workflow and Architecture 장고 개발 워크플로우 및 구조 file 졸리운_곰 2023.03.12 338
47 [python][Django] DRF(장고 rest framework)와 REST API서버 개발 file 졸리운_곰 2023.03.12 341
대표 김성준 주소 : 경기 용인 분당수지 U타워 등록번호 : 142-07-27414
통신판매업 신고 : 제2012-용인수지-0185호 출판업 신고 : 수지구청 제 123호 개인정보보호최고책임자 : 김성준 sjkim70@stechstar.com
대표전화 : 010-4589-2193 [fax] 02-6280-1294 COPYRIGHT(C) stechstar.com ALL RIGHTS RESERVED