feat: リポジトリでエラーログ出力を変更
This commit is contained in:
parent
1081b3b21b
commit
19901bf80e
@ -1,5 +1,8 @@
|
||||
from src.repositories.base_repository import BaseRepository
|
||||
from src.model.db.master_mente_count import MasterMenteCountModel
|
||||
from src.logging.get_logger import get_logger
|
||||
|
||||
logger = get_logger('ビジネスユニットマスタ')
|
||||
|
||||
|
||||
class BuMasterRepository(BaseRepository):
|
||||
@ -23,7 +26,7 @@ class BuMasterRepository(BaseRepository):
|
||||
return 0
|
||||
return models[0].count
|
||||
except Exception as e:
|
||||
print(f"[ERROR] DB Error : Exception={e.args}")
|
||||
logger.exception(f"DB Error : Exception={e.args}")
|
||||
raise e
|
||||
finally:
|
||||
self._database.disconnect()
|
||||
|
||||
@ -1,5 +1,8 @@
|
||||
from src.repositories.base_repository import BaseRepository
|
||||
from src.model.db.master_mente_count import MasterMenteCountModel
|
||||
from src.logging.get_logger import get_logger
|
||||
|
||||
logger = get_logger('従業員担当施設マスタ')
|
||||
|
||||
|
||||
class EmpChgInstRepository(BaseRepository):
|
||||
@ -66,7 +69,7 @@ class EmpChgInstRepository(BaseRepository):
|
||||
'update_user_name': update_user_name
|
||||
})
|
||||
except Exception as e:
|
||||
print(f"[ERROR] DB Error : Exception={e.args}")
|
||||
logger.exception(f"DB Error : Exception={e.args}")
|
||||
raise e
|
||||
|
||||
UPDATE_SQL = """\
|
||||
@ -94,7 +97,7 @@ class EmpChgInstRepository(BaseRepository):
|
||||
'update_user_name': update_user_name
|
||||
})
|
||||
except Exception as e:
|
||||
print(f"[ERROR] DB Error : Exception={e.args}")
|
||||
logger.exception(f"DB Error : Exception={e.args}")
|
||||
raise e
|
||||
|
||||
UPDATE_SQL = """\
|
||||
@ -121,7 +124,7 @@ class EmpChgInstRepository(BaseRepository):
|
||||
'update_user_name': update_user_name
|
||||
})
|
||||
except Exception as e:
|
||||
print(f"[ERROR] DB Error : Exception={e.args}")
|
||||
logger.exception(f"DB Error : Exception={e.args}")
|
||||
raise e
|
||||
|
||||
FETCH_COUNT_SQL = """\
|
||||
@ -146,7 +149,7 @@ class EmpChgInstRepository(BaseRepository):
|
||||
return 0
|
||||
return models[0].count
|
||||
except Exception as e:
|
||||
print(f"[ERROR] DB Error : Exception={e.args}")
|
||||
logger.exception(f"DB Error : Exception={e.args}")
|
||||
raise e
|
||||
finally:
|
||||
self._database.disconnect()
|
||||
|
||||
@ -1,5 +1,8 @@
|
||||
from src.repositories.base_repository import BaseRepository
|
||||
from src.model.db.master_mente_count import MasterMenteCountModel
|
||||
from src.logging.get_logger import get_logger
|
||||
|
||||
logger = get_logger('従業員マスタ')
|
||||
|
||||
|
||||
class EmpMasterRepository(BaseRepository):
|
||||
@ -26,7 +29,7 @@ class EmpMasterRepository(BaseRepository):
|
||||
return 0
|
||||
return models[0].count
|
||||
except Exception as e:
|
||||
print(f"[ERROR] DB Error : Exception={e.args}")
|
||||
logger.exception(f"DB Error : Exception={e.args}")
|
||||
raise e
|
||||
finally:
|
||||
self._database.disconnect()
|
||||
|
||||
@ -1,5 +1,8 @@
|
||||
from src.repositories.base_repository import BaseRepository
|
||||
from src.model.db.master_mente_count import MasterMenteCountModel
|
||||
from src.logging.get_logger import get_logger
|
||||
|
||||
logger = get_logger('メルク施設マスタ')
|
||||
|
||||
|
||||
class MstInstRepository(BaseRepository):
|
||||
@ -10,20 +13,20 @@ class MstInstRepository(BaseRepository):
|
||||
FROM
|
||||
src05.mst_inst
|
||||
WHERE
|
||||
mst_inst.inst_cd = :instcd
|
||||
mst_inst.inst_cd = :inst_cd
|
||||
"""
|
||||
|
||||
def fetch_count(self, instcd) -> MasterMenteCountModel:
|
||||
def fetch_count(self, inst_cd) -> MasterMenteCountModel:
|
||||
try:
|
||||
self._database.connect()
|
||||
query = self.FETCH_COUNT_SQL
|
||||
result = self._database.execute_select(query, {'instcd': instcd})
|
||||
result = self._database.execute_select(query, {'inst_cd': inst_cd})
|
||||
models = [MasterMenteCountModel(**r) for r in result]
|
||||
if len(models) == 0:
|
||||
return 0
|
||||
return models[0].count
|
||||
except Exception as e:
|
||||
print(f"[ERROR] DB Error : Exception={e.args}")
|
||||
logger.exception(f"DB Error : Exception={e.args}")
|
||||
raise e
|
||||
finally:
|
||||
self._database.disconnect()
|
||||
|
||||
Loading…
x
Reference in New Issue
Block a user