student_manage_system/stu_jiuye/dao.py

import like

from model import Employments,Address,Company


def add_employment_dao(o,db):
    try:
        # r = db.query(Employments).filter(Employments.id == o['id'] ).all()
        o.pop('id', None)
        o1 = Employments( **o)
        db.add(o1)

    except Exception as e:
        print(f'添加失败，{e}')
        db.rollback()
        return False
    else:
        db.commit()
        return True

def add_company_dao(o,db):
    try:
        o.pop('id', None)
        o1 = Company( **o)
        db.add(o1)
    except Exception as e:
        print(f'添加失败，{e}')
        db.rollback()
        return False
    else:
        db.commit()
        return True
def add_address_dao(o,db):
    try:
        o.pop('id', None)
        o1 = Address( **o)
        db.add(o1)
    except Exception as e:
        print(f'添加失败，{e}')
        db.rollback()
        return False
    else:
        db.commit()
        return True


def update_emp_dao(id,update_data,db):
    try: # 数据更新是有返回值的，返回的是影响的行数
        rows = db.query( Employments ).filter( Employments.id == id ).update( update_data )
    except Exception as e:
        print(f'更新失败，{e}')
        db.rollback()
        return False
    else:
        db.commit()
        return rows

def get_emp_dao(
        # stuid,
                   stuname
                    ,compname
                   ,db
                   , min_salary: int = 0
                   , max_salary: int | None = None
                   # ,page
                   # ,page_size
                   ):
    q = db.query(Employments,Company.compname,Address.somewhere)\
        .join(Company,Employments.company_id==Company.id)\
        .join(Address,Company.address_id==Address.id)\
        .filter(Employments.is_deleted == 0)
    # if stuid:
    #     q = q.filter( Employments.id == stuid )

    if stuname:
        q = q.filter( Employments.stuname == stuname )
    if compname:
        q=q.filter(Company.compname.like(f'%{compname}%'))
    # r = q.offset( (page-1)*page_size ).limit( page_size ).all()
    if min_salary is not None:
        q = q.filter(Employments.salary >= min_salary)
    if max_salary is not None:
        q = q.filter(Employments.salary <= max_salary)
    r= q.all()
    if r:
        return [ {"id": i.id,
                  'stuname':i.stuname,
                  'stuclass':i.stuclass,
                 "company_name": compname,
                  "address":somewhere,
                  # "company_id": i.company_id,
                  "salary":i.salary,
                 # "address_id": i.address_id,
                  "employment_open_date":i.employment_open_date,
                  "offer_date":i.offer_date,
                 "created_date": i.created_date,
                "updated_date": i.updated_date,
                 "is_deleted":i.is_deleted } for i,compname,somewhere in r ]


def delete_emp_dao(id,db):
    try:  # 删除有返回值，删除的行数
        rows = db.query(Employments).filter(Employments.id == id).update( {'is_deleted':1} )

    except Exception as e:
        print(f'删除失败，{e}')
        db.rollback()
        rows = 0
    else:
        db.commit()
    return rows