69 lines
2.8 KiB
Python
69 lines
2.8 KiB
Python
# encoding: UTF-8
|
||
from ..model.updateSqlProjectModel import UpdateSqlProject
|
||
from logger import logger
|
||
|
||
|
||
class UpdateSqlProjectDao(object):
|
||
|
||
@staticmethod
|
||
def get_sql_project_by_id(session, sql_id):
|
||
return session.query(UpdateSqlProject).filter(
|
||
UpdateSqlProject.id == int(sql_id), UpdateSqlProject.is_delete == 0
|
||
).first()
|
||
|
||
@staticmethod
|
||
def delete_sql_project_by_id(session, sql_id):
|
||
delete_res = session.query(UpdateSqlProject).filter(
|
||
UpdateSqlProject.id == int(sql_id), UpdateSqlProject.is_delete == 0
|
||
).update({'is_delete': 1})
|
||
err = session.done(close=False)
|
||
if err:
|
||
logger.error('delete update_sql_project db失败！sql_id: {}, err: {}'.format(sql_id, err))
|
||
return 0, f'删除记录失败！{err}'
|
||
if not delete_res:
|
||
return 0, '未查询到对应记录！'
|
||
return int(sql_id), ''
|
||
|
||
@staticmethod
|
||
def create_sql_project(session, add_info):
|
||
if not isinstance(add_info, dict):
|
||
logger.error('create_sql_project不支持其他类型。')
|
||
return 0, '入参类型错误！'
|
||
sql_project_obj = UpdateSqlProject(**add_info)
|
||
session.add(sql_project_obj)
|
||
err = session.done(close=False)
|
||
create_id = sql_project_obj.id
|
||
if err:
|
||
logger.warning(f'create_sql_project新增记录失败！{err}')
|
||
return 0, f'新增记录失败！{err}'
|
||
if not create_id:
|
||
logger.warning('获取update_sql_project记录id失败！')
|
||
return 0, f'{add_info}获取update_sql_project记录id失败！'
|
||
return create_id, ''
|
||
|
||
@staticmethod
|
||
def get_sql_by_filters(session, filter_list, page=1, limit=20):
|
||
rets = session.query(UpdateSqlProject)\
|
||
.filter(*filter_list) \
|
||
.filter(UpdateSqlProject.is_delete == 0) \
|
||
.order_by(UpdateSqlProject.created_time.desc()) \
|
||
.offset((int(page) - 1) * int(limit)) \
|
||
.limit(limit) \
|
||
.all()
|
||
total = session.query(UpdateSqlProject).filter(*filter_list).filter(
|
||
UpdateSqlProject.is_delete == 0).count()
|
||
return rets, total
|
||
|
||
@staticmethod
|
||
def update_sql_project_by_id(session, sql_id, update_info):
|
||
update_res = session.query(UpdateSqlProject).filter(
|
||
UpdateSqlProject.id == int(sql_id), UpdateSqlProject.is_delete == 0
|
||
).update(update_info)
|
||
err = session.done(close=False)
|
||
if err:
|
||
logger.error('update update_sql_project db失败！sql_id: {}, update_info:{}, err: {}'.format(sql_id, update_info, err))
|
||
return 0, f'更新记录失败！{err}'
|
||
if not update_res:
|
||
return 0, '未查询到对应记录！'
|
||
return int(sql_id), ''
|