flask - ohsangwon777/flask-sqlalchemy-test GitHub Wiki

모델의 상태값들

모델은 여러 상태값을 가지며 session에서 add, commit, delete, flush 등이 발생했때 상태값이 바뀐다.

transient : 세선에 추가되지 않은 모델의 상태. ModelClass(name='aaa')등으로 생성만 해놓았거나, session에서 제거되었을 경우

pending : session.add()로 세션에 추가 예정인 모델이 가지는 상태. session.flush()를 하게되면 persistent상태로 바뀐다.

persistent : 세션에도 존재하고, 실제로 데이터 베이스에도 존재하는 모델이 가지는 상태. pending상태 모델이 flush되거나, 데이터 베이스에서 쿼리로 조회해온 경우

detached : 데이터베이스상에는 존재하지만 세션에는 존재하지 않는 상태. 추가로 쿼리를 실행 시킬 수 없다.

expired : session.commit()이 실행된 후 세션에 있던 persistent상태 모델들이 가지는 상태. expired로 마킹되면 새로운 값을 조회하게 된다. expire_on_commit=False으로 설정 할 수 있다.(흠...)

scoped_session

@db_test_api.route('/request_1')
class Request_1(Resource):
    def get(self):

        logger.info('request_1 session : {}'.format(db.session))
        logger.info('request_1 session.identity_map: {}'.format(db.session.identity_map))

        return 200

@db_test_api.route('/request_2')
class Request_2(Resource):
    def get(self):

        logger.info('request_2 session : {}'.format(db.session))
        logger.info('request_2 session.identity_map: {}'.format(db.session.identity_map))

        return 200

[INFO] request_1 session : <sqlalchemy.orm.scoping.scoped_session object at 0x05AD3630>
[INFO] request_2 session : <sqlalchemy.orm.scoping.scoped_session object at 0x05AD3630>
[INFO] request_1 session.identity_map: <sqlalchemy.orm.identity.WeakInstanceDict object at 0x065C8090>
[INFO] request_2 session.identity_map: <sqlalchemy.orm.identity.WeakInstanceDict object at 0x065ACFB0>

flask-sqlalchemy 초기화 될때 scoped_session을 하나 생성해서 세팅해준다.

각 리퀘스트별로 session객체는 같다.

하지만 각 리퀘스트에서 조회하는 session객체들은 _app_ctx_stack.__ident_func__로 구분되어 각각 다른 scope를 가진다.

session의 identity_map은 persist 상태인 모델들을 저장한다.

다른 스코프의 session은 서로 다른 identity_map을 가진다.

세션 변경값 추적

@db_test_api.route('/request_1')
class Request_1(Resource):
    def get(self):

        new_model = SessionTestModel(name='lee', desc='hoho')
        db.session.add(new_model)

        model_han = SessionTestModel.query.filter_by(name='han').first()
        model_han.desc = 'jehyun-moded'

        model_oh = SessionTestModel.query.filter_by(name='oh').first()
        db.session.delete(model_oh)

        logger.info('session.new : {}'.format(db.session.new))
        logger.info('session.dirty : {}'.format(db.session.dirty))
        logger.info('session.deleted : {}'.format(db.session.deleted))

        db.session.flush()
        logger.info('session.flush()호출')

        logger.info('session.new : {}'.format(db.session.new))
        logger.info('session.dirty : {}'.format(db.session.dirty))
        logger.info('session.deleted : {}'.format(db.session.deleted))

        return 200

[INFO] session.new : IdentitySet([<SessionTestModel (transient 113757904)>])
[INFO] session.dirty : IdentitySet([<SessionTestModel 16>])
[INFO] session.deleted : IdentitySet([<SessionTestModel 1>])
[INFO] session.flush()호출
[INFO] session.new : IdentitySet([])
[INFO] session.dirty : IdentitySet([])
[INFO] session.deleted : IdentitySet([])

한 스코프의 세션에 추가, 변경, 삭제되는 모델 인스턴스들은 세션의 new, dirty, deleted속성값으로 추적/확인할 수 있다.

new : session.add()로 pending상태인 모델 인스턴스들

dirty : 속성값이 변경된 persistent상태인 모델 인스턴스들

deleted : session.delete()로 detached 예정인 모델 인스턴스들

flush, commit(commit을 하면 반드시 직전에 flush를 수행)시 세션의 변경값이 적용된다.

flush란

@db_test_api.route('/request_1')
class Request_1(Resource):
    def get(self):

        new_model = SessionTestModel(name='han', desc='jehyun')

        db.session.add(new_model)

        logger.info('session.new : {}'.format(db.session.new))

        model = SessionTestModel.query.filter_by(name='han').first()

        logger.info('model : {}'.format(model))

        return 200

[INFO] session.new : IdentitySet([<SessionTestModel (transient 115920592)>])
[INFO] model : None

@db_test_api.route('/request_1')
class Request_1(Resource):
    def get(self):

        new_model = SessionTestModel(name='han', desc='jehyun')

        db.session.add(new_model)

        logger.info('session.new : {}'.format(db.session.new))

        # 플러시
        db.session.flush()

        model = SessionTestModel.query.filter_by(name='han').first()

        logger.info('model : {}'.format(model))

        return 200

[INFO] session.new : IdentitySet([<SessionTestModel (transient 121364144)>])
[INFO] model : <SessionTestModel 15>

@db_test_api.route('/request_1')
class Request_1(Resource):
    def get(self):

        new_model = SessionTestModel(name='lee', desc='hoho')
        db.session.add(new_model)

        model_han = SessionTestModel.query.filter_by(name='han').first()
        model_han.desc = 'jehyun-moded'

        model_oh = SessionTestModel.query.filter_by(name='oh').first()
        db.session.delete(model_oh)

        for value in db.session.identity_map.values():
            
            logger.info(value)


        db.session.flush()
        logger.info('session.flush() 호출')

        for value in db.session.identity_map.values():
            
            logger.info(value)

        return 200

[INFO] <SessionTestModel 16> <-- SessionTestModel.query.filter_by(name='han').first() 조회 후 수정
[INFO] <SessionTestModel 1> <-- SessionTestModel.query.filter_by(name='oh').first() 조회 후 삭제 예약
[INFO] session.flush() 호출
[INFO] <SessionTestModel 16> <-- SessionTestModel.query.filter_by(name='han').first() 수정된 모델
[INFO] <SessionTestModel 24> <-- SessionTestModel(name='lee', desc='hoho') 새로 생성된 모델 
                                 SessionTestModel.query.filter_by(name='oh').first() 는 삭제됨

flush를 했을때는 세션의 ORM 매핑이 갱신된다.

flush를 해도 DB에는 적용되지 않는다.