crud operation second

.idea/sonarlint/issuestore/index.pb

+
+N
+script/core/schema/__init__.py,8\4\84b7e789bb411a2f2e44fa4f79362bae15a9ca5e
+\
+,.idea/inspectionProfiles/Project_Default.xml,4\9\496a238a6afa168dbaf6efd37bb459331589579c
+^
+..idea/inspectionProfiles/profiles_settings.xml,1\e\1e9075f5bf079c01ef2c910709e91a497d262080
+4
+.env,3\c\3c84dcdc6bbe3d7817c49dcdc327b926fea1808a
+E
+conf/application.conf,6\4\644f59db746795ef1538ef95c4cbc0eab6663e28
\ No newline at end of file

.idea/sonarlint/securityhotspotstore/index.pb

+
+N
+script/core/schema/__init__.py,8\4\84b7e789bb411a2f2e44fa4f79362bae15a9ca5e
+\
+,.idea/inspectionProfiles/Project_Default.xml,4\9\496a238a6afa168dbaf6efd37bb459331589579c
+^
+..idea/inspectionProfiles/profiles_settings.xml,1\e\1e9075f5bf079c01ef2c910709e91a497d262080
+4
+.env,3\c\3c84dcdc6bbe3d7817c49dcdc327b926fea1808a
+E
+conf/application.conf,6\4\644f59db746795ef1538ef95c4cbc0eab6663e28
\ No newline at end of file

script/core/errors/__init__.py

@@ -2,5 +2,5 @@ class ErrorMessage(Exception):
     ERRORS_INSERT = "Due to value error in insertion"
     ERRORS_FETCH = "Due to value error in fetch"
     ERRORS_UPDATE = "Due to value error in update"
-    ERRORS_DELETE  = "Due to value error in deletion"
+    ERRORS_DELETE = "Due to value error in deletion"
 

script/core/handlers/inventory.py

-from sqlalchemy import Column, Integer, String, MetaData, text
-from sqlalchemy import Table
+from sqlalchemy import MetaData
 
 from script.core.db.postgresql_connector import session
-from script.core.schema.inventory import Inventory
+from script.utils.inventory_utils import SqlUtility
 
 metadata = MetaData()
 
+SqlUtility = SqlUtility()
+
 
 class PostgresqlCollectRecords:
     @staticmethod
     def create_table():
         try:
-            inventory_table = Table('inventory_data', metadata,
-                                    Column('order_id', Integer, primary_key=True, index=True),
-                                    Column('customer_name', String),
-                                    Column('status', String),
-                                    Column('sales_order', Integer, index=True)
-                                    )
-            return inventory_table
+            data = SqlUtility.create_file()
+            return data
         except Exception as e:
             print(e, "Error detected in creating the table")
 
     @staticmethod
     def insert_data(request_data):
         try:
-            new_inventory_data = Inventory(customer_name=request_data.customer_name,
-                                           status=request_data.status, sales_order=request_data.sales_order)
-            session.add(new_inventory_data)
+            data = SqlUtility.insert_file(request_data)
+            session.add(data)
             session.commit()
-            return {"order_id": new_inventory_data.order_id, "customer_name": new_inventory_data.customer_name,
-                    "status": new_inventory_data.status,
-                    "sales_order": new_inventory_data.sales_order}
+            return {"order_id": data.order_id, "customer_name": data.customer_name,
+                    "status": data.status,
+                    "sales_order": data.sales_order}
         except Exception as e:
             print(e, "Error detected in inserting")
 
     @staticmethod
     def fetch_records():
         try:
-            inventory_data = session.query(Inventory).all()
-            list_ = []
-            for data in inventory_data:
-                list_.append({"order_id": data.order_id, "customer_name": data.customer_name, "status": data.status,
-                              "sales_order": data.sales_order})
-            return list_
+            data = SqlUtility.fetch_file()
+            return data
         except Exception as e:
             print(e, "Error detected in fetching the data")
 
     @staticmethod
     def update_records(request_data, order_id):
         try:
-            get_update = {key: value for key, value in request_data if
-                          value is not None and value != 'string' and value != 0}
-            update_data = session.query(Inventory).filter(
-                text(str(f"order_id={order_id}"))
-            ).update(
-                get_update
-            )
+            data = SqlUtility.update_file(request_data, order_id)
             session.commit()
-            print(update_data)
-            return update_data
+            return data
         except Exception as e:
             print(e, "Error detected in updating")
 
     @staticmethod
     def delete_records(order_id):
         try:
-            data = session.query(Inventory).filter_by(order_id=order_id).first()
+            data = SqlUtility.delete_file(order_id)
             session.delete(data)
             session.commit()
             return data

script/service/inventory.py

@@ -5,7 +5,7 @@ from fastapi import APIRouter
 from script.constants import APIEndpoints
 from script.core.errors import ErrorMessage
 from script.core.handlers.inventory import PostgresqlCollectRecords
-from script.core.schema.inventory import Inventory, InventoryData, UpdateInventoryData
+from script.core.schema.inventory import InventoryData, UpdateInventoryData
 from script.core.schema.responses import DefaultResponse
 
 router = APIRouter(prefix=APIEndpoints.inventory_base)
@@ -16,7 +16,7 @@ handler = PostgresqlCollectRecords()
 async def insert_item(request_data: InventoryData):
     try:
         data = handler.insert_data(request_data)
-        return DefaultResponse(message="Successfully inserted", status="success", data = data)
+        return DefaultResponse(message="Successfully inserted", status="success", data=data)
     except ValueError:
         return DefaultResponse(message=ErrorMessage.ERRORS_INSERT)
     except Exception as e: