add delete function
This commit is contained in:
@@ -123,6 +123,17 @@ class KomCache:
|
|||||||
log.error(f"Error updating data: {e}")
|
log.error(f"Error updating data: {e}")
|
||||||
return False
|
return False
|
||||||
|
|
||||||
|
def delete(self, query: str, args: dict[str, Any]) -> bool:
|
||||||
|
try:
|
||||||
|
session = self.Session()
|
||||||
|
session.execute(text(query), args)
|
||||||
|
session.commit()
|
||||||
|
session.close()
|
||||||
|
return True
|
||||||
|
except SQLAlchemyError as e:
|
||||||
|
log.error(f"Error deleting data: {e}")
|
||||||
|
return False
|
||||||
|
|
||||||
def get_last_update_date(self, series_name: str) -> str:
|
def get_last_update_date(self, series_name: str) -> str:
|
||||||
try:
|
try:
|
||||||
session = self.Session()
|
session = self.Session()
|
||||||
|
|||||||
Reference in New Issue
Block a user