from core.database import  db_session   # db_session 임포트

 

@router.get('/URL 작명')

async def insert (db: db_session):  # db = db_session 인자로 받아주기

obj = 모델(id=1,title="제목",content="내용")

    db.add(obj)

    db.commit()

 

@router.get('/{id}')

async def read (db: db_session , id:int):  # db = db_session 인자로 받아주기

  object = db.query(모델).filter(모델.id == id).first() # 조회

# 또는  object = db.query(모델).filter_by(id=id).all()

# 또는  object = db.query(모델).get(id)

  print("단일행 조회 :", vars(object))

 

@router.delete('/{id}')

async def delete (db: db_session , id:int )  # 삭제

  delete_obj = db.query(모델).get(id)

  db.delete(delete_obj )

  db.commit()