flask09

SQLAlchemy로 데이터베이스 CRUD를 실행해 본다.
SQLite에 row 데이터를 생성 (Input 또는 Insert ) 하게 될 것이다.

model.py 파일

from flask_sqlalchemy import SQLAlchemy

db = SQLAlchemy()

class User(db.Model):
    id = db.Column(db.Integer, primary_key = True, autoincrement=True)
    userid = db.Column(db.String(32), nullable=False)
    username = db.Column(db.String(32), nullable=False)
    created_date = db.Column(db.DateTime(), nullable=False)

    #id는 primary_key이고 자동 증가한다, 따라서 생성자 매개변수에서 빼도 된다.
    def __init__(self, userid, username, created_date):
        self.userid = userid
        self.username = username
        self.created_date = created_date

    @property
    def serialize(self):
        return {
            'id': self.id,
            'userid': self.userid,
            'username': self.username,
            'created_date': self.created_date
        }

앞에서 시리얼라이징 할때, 생성자가 왜 필요한지 몰랐다.
생성자가 왜 필요한지 곧 이유를 설명한다.

그리고, 생성자를 만들때, primary_key도 포함 시키고 있는 오류를 범했다.
primary_key이고 autoincrement이면 생성자 매개변수에 빼도 된다.

C : row 데이터 생성

def create_row():
    from model import User

    record = User(userid=32, username="aaa", created_date=datetime.datetime.now())
    db = model.db
    db.session.add(record)
    db.session.commit()

데이터베이스에 입력할 row 데이터를 생성한다. 생성자에 맞게끔 데이터를 지정한다.
record = User(userid=32, username="aaa", created_date=datetime.datetime.now())

다음 명령으로 데이터를 추가한다.
commit 함수에 의해 변경 사항이 적용된다.
db.session.add(record)
db.session.commit()

R: row 데이터 읽기

데이터를 읽어오는 여러가지 방법이 있다. 간단하게 자주 사용되는것만 언급 하겠다.
query.get 함수로 ID를 가진 레코드를 읽어 온다.

query.filter("쿼리 조건").all 함수는 조건에 맞는 리스트를 가져온다.

query.filter("쿼리 조건").first 함수는 조건에 맞는 첫번째 레코드를 가져온다.
조건에 해당되는 리스트가 없으면 'None'을 리턴한다.

for 루프문에서 다른 증가 변수를 추가 할려면 enumerate를 사용한다.

def read_row1():
    print('read_row1----------------------------------')
    user = User.query.get(2)
    print(user.username)

def read_row2():
    print('read_row2----------------------------------')
    #user_list = User.query.filter(User.username == 'bbb') 결과는 아래와 동일하다
    user_list = User.query.filter(User.username == 'bbb').all()
    for u in user_list:
        print(u)
        print(u.serialize)

    user = User.query.filter(User.username == 'king').first()
    if user == None:
        print('King is None')

def read_row3():
    print('read_row3----------------------------------')

    user_list = User.query.filter(User.username == 'bbb').all()
    for n, u in enumerate(user_list):
        print(u)
        print(f'number {n}: {u.serialize}')

def read_row4():
    print('read_row4----------------------------------')

    user_list = User.query.filter(User.username.like('%ap%')).all()
    for n, u in enumerate(user_list):
        print(u)
        print(f'number {n}: {u.serialize}')

U: row 데이터 수정

읽어 온 레코드를 수정하고 커밋하면 데이터가 수정이 된다.

def update_row():
    print('update_row----------------------------------')

    user1 = User.query.get(1)
    user1.username = "jung"

    user_kim = User.query.filter(User.username == 'kim').first()
    if user_kim != None:
        user_kim.username = 'park'
    db = model.db
    db.session.commit()

D: row 데이터 삭제

읽어 온 레코드를 delete 함수로 삭제후 커밋하면 삭제 된다.

def delete_row():
    print('delete_row----------------------------------')

    db = model.db
    user_list = User.query.filter(User.username == 'aaa').all()
    for u in user_list:
        db.session.delete(u)
        db.session.commit()

DB 레코드 덤프하기

import json
from flask import render_template, Blueprint

bp = Blueprint('main',
               __name__,
               url_prefix='/main')

from model import User

#URL : http://localhost:8888/main/dbdump
@bp.route('/dbdump')
def dodump():
    print("dbdump")

    user = User.query.get(2)

    print(user.serialize)
    response = json.dumps([user.serialize], default=str, ensure_ascii=False)
    return response

json.dump 함수로 시리얼라이징 한값을 넘겨주면 된다.

실행)

소스)
main.py
model.py
controller/main_controller.py

참고)
SQLAlchemy Query
https://engineer-mole.tistory.com/327