pymysql을 써서 request에 담긴 데이터를 db에 저장하거나, request에 대한 response를 보내는 방법을 공부 목적으로 정리했다.

잔재미코딩에 매우 정리가 잘 되어있어 고대로 가져온 점 참고!

여기도 좋은 것 같다.
https://www.tutorialspoint.com/python_data_access/python_mysql_select_data.htm

mysql을 python에서 사용할 수 있는 라이브러리는

• pymysql 라이브러리
• MySQLdb(Mysql-pytion)
• MySQL connector 등 다양한 라이브러리 존재

pymysql

1. pymysql.connect() 메소드를 사용하여 MySQL에 연결. 호스트명, 포트, 로그인, 암호, 접속할 DB 등을 파라미터로 지정

2. MySQL 접속이 성공하면, 위에서 만든 Connection 객체로부터 cursor() 메서드를 호출하여 Cursor 객체를 가져옴
   - Cursor: SQL 구문을 실행하기 위해서 만드는 객체 (Executes a SQL statement.)

참고링크: https://www.tutorialspoint.com/python_data_access/python_mysql_cursor_object.htm

The MySQLCursor of mysql-connector-python (and similar libraries) is used to execute statements to communicate with the MySQL database.

Using the methods of it you can execute SQL statements, fetch data from the result sets, call procedures.

You can create Cursor object using the cursor() method of the Connection object/class.

-> cursor 는 control structure of database (연결된 객체)

4. SQL 쿼리의 경우 Cursor 객체의 fetchall(), fetchone(), fetchmany() 등의 메서드를 사용하여 서버로부터 가져온 데이터를 코드에서 활용

5. 삽입, 갱신, 삭제 등의 DML(Data Manipulation Language) 문장을 실행하는 경우, INSERT/UPDATE/DELETE 후 Connection 객체의 commit() 메서드를 사용하여 데이타를 확정

6. Connection 객체의 close() 메서드를 사용하여 DB 연결을 닫음
   
   

insert data(Create)

import pymysql

# 접속
# 비밀번호가 포함되어 있기 때문에 보통 config파일에서 key값으로 부른다.
# 해당 코드는 예시이기 때문에 직접 입력되어 있는 형태인 점을 참고!
db = pymysql.connect(
                    host='127.0.0.1', 
                    port=3306, 
                    user='root', 
                    passwd='your_password', 
                    db='your_dbname', 
                    charset='utf8'
                    )

# Cursor Object 가져오기
cursor = db.cursor()

# SQL 문 만들기
sql = '''
            CREATE TABLE your_table (
                   id INT UNSIGNED NOT NULL AUTO_INCREMENT,
                   name VARCHAR(20) NOT NULL,
                   model_num VARCHAR(10) NOT NULL,
                   model_type VARCHAR(10) NOT NULL,
                   PRIMARY KEY(id)
            );
        '''

# SQL 실행하기
cursor.execute(sql)

# 실행 mysql 서버에 확정 반영하기
db.commit()

# DB 연결 닫기
db.close()

get data (Read)

db = pymysql.connect(
                    host='127.0.0.1', 
                    port=3306, 
                    user='root', 
                    passwd='your_password', 
                    db='your_dbname', 
                    charset='utf8'
                    )

try:
    with db.cursor() as cursor:
        sql = "SELECT * FROM cpu_info WHERE name = 'i5'"
        cursor.execute(sql)
        
        while result:
            result = cursor.fetchone()
            print(result)        
finally:
    db.close()

update

db = pymysql.connect(
                    host='127.0.0.1', 
                    port=3306, 
                    user='root', 
                    passwd='your_password', 
                    db='your_dbname', 
                    charset='utf8'
                    )
try:
    with db.cursor() as cursor:
        sql = "UPDATE cpu_info SET model_type='%s' WHERE name = 'i7'" % '카비레이크'
        cursor.execute(sql)
        db.commit()
        print(cursor.rowcount)
finally:
    db.close()

delete

db = pymysql.connect(
                    host='127.0.0.1', 
                    port=3306, 
                    user='root', 
                    passwd='your_password', 
                    db='your_dbname', 
                    charset='utf8'
                    )
hit_count = 20
try:
    with db.cursor() as cursor:
        sql = "DELETE FROM cpu_info WHERE name = '%s'" % 'i7'
        cursor.execute(sql)
        db.commit()
        print(cursor.rowcount)
finally:
    db.close()