first

.idea/sonarlint/issuestore/index.pb

@@ -7,7 +7,7 @@ w
 G.idea/sonarlint/issuestore/4/0/40143b61ec022045fa562c6d31ea2c886dd2f4b5,e\4\e4e6c66b897df14d56a75c299879dbe09d5dc0f8
 

 Q.idea/sonarlint/securityhotspotstore/4/0/40143b61ec022045fa562c6d31ea2c886dd2f4b5,7\5\75fce93979f8f7d0b463a17996643c419b5503f5
-E
-employee_details.json,2\6\26d582e31ae3bfa82a16a35d19aa5678e0598026
-4
-.env,3\c\3c84dcdc6bbe3d7817c49dcdc327b926fea1808a
\ No newline at end of file
+K
+script/core/schema/model.py,c\c\cc570add5ea2bb8012c2ccbc7918942db96ddf16
+N
+script/core/schema/__init__.py,8\4\84b7e789bb411a2f2e44fa4f79362bae15a9ca5e
\ No newline at end of file

.idea/sonarlint/securityhotspotstore/index.pb

@@ -7,7 +7,7 @@ w
 G.idea/sonarlint/issuestore/4/0/40143b61ec022045fa562c6d31ea2c886dd2f4b5,e\4\e4e6c66b897df14d56a75c299879dbe09d5dc0f8
 

 Q.idea/sonarlint/securityhotspotstore/4/0/40143b61ec022045fa562c6d31ea2c886dd2f4b5,7\5\75fce93979f8f7d0b463a17996643c419b5503f5
-E
-employee_details.json,2\6\26d582e31ae3bfa82a16a35d19aa5678e0598026
-4
-.env,3\c\3c84dcdc6bbe3d7817c49dcdc327b926fea1808a
\ No newline at end of file
+N
+script/core/schema/__init__.py,8\4\84b7e789bb411a2f2e44fa4f79362bae15a9ca5e
+K
+script/core/schema/model.py,c\c\cc570add5ea2bb8012c2ccbc7918942db96ddf16
\ No newline at end of file

script/config/app_config.py

@@ -10,6 +10,7 @@ class Service:
     port = config.getint('service', 'port')
     host = config.get('service', 'host')
 
+
 class Sqlite:
     db_uri = os.environ.get('DB_URI')
 

script/constants/__init__.py

@@ -4,6 +4,7 @@ class APIEndpoints:
     insert = "/insert"
     subordinates = "/subordinates"
     find = "/find"
+    list ="/list"
 
 
 class Place:

script/core/handlers/emp_info.py

 import numpy as np
 import pandas as pd
-from sqlalchemy import MetaData
 from sqlalchemy.testing.schema import Table
 from script.constants import Place
-from script.utils.sqlite_connection import engine
+from script.utils.sqlite_connection import engine, metadata, conn
 from script.utils.sqlite_utils import Utils
 
 my_data = Utils
@@ -31,8 +30,7 @@ class Userdetails:
     @staticmethod
     def find_data():
         try:
-            conn = engine.connect()
-            metadata = MetaData()
+
             user_info = Table('user_info', metadata, autoload=True, autoload_with=engine)
             subordinates_info = Table('subordinates_info', metadata, autoload=True, autoload_with=engine)
             user_info_columns = [col.name for col in user_info.columns]
@@ -49,4 +47,4 @@ class Userdetails:
             return {"header": user_info_columns, "body": user_info_body, "subordinate_header": subordinate_columns,
                     "subordinate_body": subordinate_body}
         except Exception as e:
-            print(e, "Error detected in finding employee data")
\ No newline at end of file
+            print(e, "Error detected in finding employee data")

script/service/user_details.py

@@ -4,7 +4,7 @@ from fastapi import APIRouter, UploadFile, File
 from script.constants import APIEndpoints
 from script.core.handlers.emp_info import Userdetails
 from script.core.schema.response import DefaultResponse
-from script.utils.sqlite_utils import Utils
+
 
 user_details = Userdetails()
 
@@ -24,15 +24,6 @@ async def upload_file(file: UploadFile = File()):
         print(e, "uploading failed")
 
 
-@router.post("/create_db")
-async def db_creation():
-    try:
-        Utils.create_db()
-        return "db created"
-    except Exception as e:
-        print(e, "db not created")
-
-
 @router.post(APIEndpoints.insert)
 async def insert_item():
     try:
@@ -45,8 +36,8 @@ async def insert_item():
         return DefaultResponse(message="Insertion Failed due to server error")
 
 
-@router.get(APIEndpoints.find)
-async def find_item():
+@router.get(APIEndpoints.list)
+async def list_item():
     try:
         data = handler.find_data()
         return DefaultResponse(message="Successfully Found", status="success", data=data)

script/utils/sqlite_connection.py

@@ -2,6 +2,7 @@ from sqlalchemy import create_engine, MetaData
 from sqlalchemy.orm import sessionmaker
 
 from script.config.app_config import create_sqlite_connection
+from script.core.schema.model import Base
 
 db = create_sqlite_connection()
 
@@ -9,3 +10,5 @@ engine = create_engine('sqlite:///internsb2.db', echo=True)
 LocalSession = sessionmaker(bind=engine)
 session = LocalSession()
 metadata = MetaData()
+Base.metadata.create_all(engine)
+conn = engine.connect()
\ No newline at end of file

script/utils/sqlite_utils.py

@@ -34,6 +34,3 @@ class Utils:
             return list_
         return {"message": "successfully founded"}
 
-    @staticmethod
-    def create_db():
-        Base.metadata.create_all(engine)