Finish kt

DB/NEW_KT_DB/Controller/DBClusterParameterGroupController.py

@@ -0,0 +1,18 @@
+from NEW_KT_DB.Service.Classes.DBClusterParameterGroupService import DBClusterParameterGroupService
+from typing import Optional, Dict
+
+class DBClusterParameterGroupController:
+    def __init__(self, service: DBClusterParameterGroupService):
+        self.service = service
+
+    def create_db_cluster_parameter_group(self, group_name: str, group_family: str, description: Optional[str]=None):
+        return self.service.create(group_name, group_family, description)
+
+    def delete_db_cluste_parameter_group(self, group_name: str):
+        self.service.delete(group_name)
+
+    def describe_db_cluste_parameter_group(self, group_name: str = None, max_records: int = 100, marker: str = None) -> Dict:
+        return self.service.describe_group('DBClusterParameterGroup', group_name, max_records, marker)
+
+    def modify_db_cluste_parameter_group(self, group_name: str, parameters: list[Dict[str, any]]):
+        self.service.modify('DBClusterParameterGroup', group_name, parameters)

DB/NEW_KT_DB/DataAccess/DBClusterManager.py

@@ -1,8 +1,8 @@
 from typing import Dict, Any
 import json
 import sqlite3
-from DataAccess import ObjectManager
-from Models.DBClusterModel import Cluster
+from NEW_KT_DB.DataAccess import ObjectManager
+from NEW_KT_DB.Models.DBClusterModel import Cluster
 from typing import Optional
 
 class DBClusterManager:

DB/NEW_KT_DB/DataAccess/DBClusterParameterGroupManager.py

@@ -0,0 +1,35 @@
+from typing import Dict, Any
+import json
+import sqlite3
+from NEW_KT_DB.DataAccess.ObjectManager import ObjectManager
+from NEW_KT_DB.Models.DBClusterParameterGroupModel import DBClusterParameterGroup
+
+class DBClusterParameterGroupManager:
+    def __init__(self, db_file: str):
+        '''Initialize ObjectManager with the database connection.'''
+        self.object_manager = ObjectManager(db_file)
+        self.object_manager.create_management_table(
+        DBClusterParameterGroup.get_object_name(), DBClusterParameterGroup.table_structure, pk_column_data_type='TEXT')
+
+
+    def createInMemoryDBCluster(self, data):
+        self.object_manager.save_in_memory(self.__class__.__name__[:-len("Manager")], data)
+
+
+    def deleteInMemoryDBCluster(self, group_name):
+        self.object_manager.delete_from_memory_by_pk(self.__class__.__name__[:-len("Manager")], pk_column=DBClusterParameterGroup.pk_column, pk_value=group_name)
+
+    def modifyDBCluster(self, group_name, data):
+        self.object_manager.update_in_memory(self.__class__.__name__[:-len("Manager")], updates=data, criteria=f'{DBClusterParameterGroup.pk_column} = "{group_name}"')
+
+    def get(self, group_name):
+        return self.object_manager.get_from_memory(self.__class__.__name__[:-len("Manager")], columns='*', criteria=f'{DBClusterParameterGroup.pk_column} = "{group_name}"')
+
+    def get_all_groups(self):
+        return self.object_manager.get_all_objects_from_memory(self.__class__.__name__[:-len("Manager")])
+
+    def is_identifier_exist(self, group_name):
+        result= self.object_manager.get_from_memory(self.__class__.__name__[:-len("Manager")], columns='*', criteria=f'{DBClusterParameterGroup.pk_column} = "{group_name}"')  
+        if result !=[]:
+            return True
+        return False