@@ -380,6 +380,18 @@ def database_error_handling_to_log(self, error, sql_statement):
380380 log_message = {'status' : 'BAD' ,
381381 'error_message' : f"Error : { error } " ,
382382 'sql_statement' : sql_statement }
383+ elif error .errno == errorcode .ER_DUP_ENTRY :
384+ service_name = self .pm_logger .get_service_name ()
385+ if service_name == "Orders" :
386+ return {"log_id" : "Orders duplicate error" ,
387+ "status_code" : "BAD" ,
388+ "sql_error_code" : pm_db_errno ,
389+ "error_message" : f"Error : { error } " }
390+ else :
391+ log_message = {'status' : 'BAD' ,
392+ 'error_message' : f"Error : { error } " ,
393+ 'sql_statement' : sql_statement ,
394+ 'errno' : error .errno }
383395 else :
384396 log_message = {'status' : 'BAD' ,
385397 'error_message' : f"Error : { error } " ,
@@ -388,14 +400,6 @@ def database_error_handling_to_log(self, error, sql_statement):
388400 else :
389401 log_message = {'status' : 'BAD' , 'error_message' : "Something went wrong on" }
390402
391- if error .errno == errorcode .ER_DUP_ENTRY :
392- service_name = self .pm_logger .get_service_name ()
393- if service_name == "Orders" :
394- return {"log_id" : "Orders duplicate error" ,
395- "status_code" : "BAD" ,
396- "sql_error_code" : pm_db_errno ,
397- "error_message" : log_message .get ("error_message" )}
398-
399403 log_id , _ = self .pm_logger .insert_log (
400404 _message = log_message .get ("error_message" ),
401405 _func_name = 'database_error_handling_to_log' ,
0 commit comments