Update app.py

app.py

@@ -321,7 +321,7 @@ async def update_company_in_db(company_id: int, company_data: dict):
             raise HTTPException(status_code=500, detail="Failed to connect to the database")
         cursor = cnx.cursor()
         update_query = """
-        UPDATE u852023448_redmindgptcompany_detail cd
+        UPDATE u852023448_redmind.gptcompany_detail cd
         SET cd.company_name = %s, cd.company_code = %s, cd.domain = %s, cd.llm_tools = %s
         WHERE cd.company_id = %s;
         """
@@ -433,8 +433,8 @@ async def get_document(company_id: str = Query(...), company_name: str = Query(.
         cursor = cnx.cursor()
         query = """
             SELECT kb.kid,kb.company_id, kb.file_path, kb.document_name, kb.document_desc,kb.department,kb.version,kb.vectorDBflag,kb.last_updated
-            FROM u852023448_redmindgptknowledge_base kb
-            JOIN u852023448_redmindgptcompany_detail cd ON kb.company_id = cd.company_id 
+            FROM u852023448_redmindgp.tknowledge_base kb
+            JOIN u852023448_redmindgpt.company_detail cd ON kb.company_id = cd.company_id 
             WHERE kb.company_id = %s and cd.company_name=%s
         """
         logging.info(f"Executing query: {query} with company_id: {company_id}")
@@ -481,8 +481,8 @@ async def get_document(company_id: str = Query(...), company_name: str = Query(.
         cursor = cnx.cursor()
         query = """
             SELECT kb.kid,kb.company_id, kb.file_path, kb.document_name, kb.document_desc,kb.department,kb.version,kb.vectorDBflag,kb.last_updated
-            FROM u852023448_redmindgptknowledge_base kb
-            JOIN u852023448_redmindgptcompany_detail cd ON kb.company_id = cd.company_id 
+            FROM u852023448_redmindgpt.knowledge_base kb
+            JOIN u852023448_redmindgpt.company_detail cd ON kb.company_id = cd.company_id 
             WHERE kb.company_id = %s 
         """
         logging.info(f"Executing query: {query} with company_id: {company_id}")
@@ -492,7 +492,7 @@ async def get_document(company_id: str = Query(...), company_name: str = Query(.
 
         cursor.execute(query, values)  # Pa
         result = cursor.fetchall()
-        logging.info(f"Query result: {result}")
+        logging.info(f"Query result: {r.esult}")
         cursor.close
         cnx.close()
         companies=[]
@@ -610,7 +610,7 @@ async def update_knowledge_in_db(kid: int, company_data: dict):
 
         cursor = cnx.cursor()
         update_query = """
-        UPDATE u852023448_redmindgptknowledge_base kb
+        UPDATE u852023448_redmindgpt.knowledge_base kb
         SET kb.company_id = %s, kb.document_name = %s, kb.document_desc = %s, 
             kb.department = %s, kb.version = %s, kb.vectorDBflag = %s, kb.last_updated = %s
         WHERE kb.kid = %s;
@@ -764,8 +764,8 @@ async def get_data_connectors(company_id: str = Query(...), company_name: str =
         cursor = cnx.cursor()
         query = """
             SELECT dc.company_id, dc.databasetype, dc.serverip, dc.port,dc.database_name, dc.username, dc.password ,dc.dbtablename
-            FROM u852023448_redmindgptdata_connectors dc
-            JOIN u852023448_redmindgptcompany_detail cd ON dc.company_id = cd.company_id 
+            FROM u852023448_redmindgpt.data_connectors dc
+            JOIN u852023448_redmindgpt.company_detail cd ON dc.company_id = cd.company_id 
             WHERE dc.company_id = %s and cd.company_name=%s
         """
         logging.info(f"Executing query: {query} with company_id: {company_id}")
@@ -842,8 +842,8 @@ async def get_api_connectors(company_id: str = Query(...), company_name: str = Q
         cursor = cnx.cursor()
         query = """
             SELECT ac.id, ac.company_id, ac.api_name, ac.api_endpoint,ac.auth_token,ac.input_param, ac.output_json, ac.description
-            FROM u852023448_redmindgptapi_connectors ac
-            JOIN u852023448_redmindgptcompany_detail cd ON ac.company_id = cd.company_id 
+            FROM u852023448_redmindgpt.api_connectors ac
+            JOIN u852023448_redmindgpt.company_detail cd ON ac.company_id = cd.company_id 
             WHERE ac.company_id = %s and cd.company_name=%s
         """
         logging.info(f"Executing query: {query} with company_id: {company_id}")
@@ -948,7 +948,7 @@ async def update_api_in_db(id: int, company_data: dict):
 
         cursor = cnx.cursor()
         update_query = """
-        UPDATE u852023448_redmindgptapi_connectors ac
+        UPDATE u852023448_redmindgpt.api_connectors ac
         SET ac.company_id = %s, ac.api_name = %s, ac.api_endpoint= %s, 
             ac.auth_token= %s, ac.input_param= %s,ac.output_json = %s, ac.description= %s
         WHERE ac.id = %s;
@@ -1003,8 +1003,8 @@ async def get_document(company_id: str = Query(...)):
         cnx = get_db_connection()
         cursor = cnx.cursor()
         query="""  SELECT ac.id,ac.company_id, ac.api_name, ac.api_endpoint,ac.auth_token,ac.input_param, ac.output_json, ac.description
-            FROM u852023448_redmindgptapi_connectors ac
-            JOIN u852023448_redmindgptcompany_detail cd ON ac.company_id = cd.company_id 
+            FROM u852023448_redmindgpt.api_connectors ac
+            JOIN u852023448_redmindgpt.company_detail cd ON ac.company_id = cd.company_id 
             WHERE ac.company_id = %s 
         """
         logging.info(f"Executing query: {query} with company_id: {company_id}")
@@ -1109,8 +1109,8 @@ async def get_prompt_connectors(company_id: str = Query(...), company_name: str
         cursor = cnx.cursor()
         query = """
             SELECT pt.id,pt.company_id,pt.scenario,pt.prompts,pt.comments
-            FROM u852023448_redmindgptprompt_templates pt
-            JOIN u852023448_redmindgptcompany_detail cd ON pt.company_id = cd.company_id 
+            FROM u852023448_redmindgpt.prompt_templates pt
+            JOIN u852023448_redmindgpt.company_detail cd ON pt.company_id = cd.company_id 
             WHERE pt.company_id = %s and cd.company_name=%s
         """
         logging.info(f"Executing query: {query} with company_id: {company_id}")
@@ -1243,7 +1243,7 @@ async def update_prompt_in_db(kid: int, company_data: dict):
         
         cursor = cnx.cursor()
         update_query = """
-        UPDATE redmind_gptprompt_templates pt
+        UPDATE redmind_gpt.prompt_templates pt
         SET pt.scenario=%s, pt.prompts=%s, pt.comments=%s
         WHERE pt.id = %s;
         """
@@ -1281,8 +1281,8 @@ async def get_document(company_id: str = Query(...)):
         cursor = cnx.cursor()
         query = """
              SELECT pt.id,pt.company_id,pt.scenario,pt.prompts,pt.comments
-            FROM u852023448_redmindgptprompt_templates pt
-            JOIN u852023448_redmindgptcompany_detail cd ON pt.company_id = cd.company_id 
+            FROM u852023448_redmindgpt.prompt_templates pt
+            JOIN u852023448_redmindgpt.company_detail cd ON pt.company_id = cd.company_id 
             WHERE pt.company_id = %s 
         """
         logging.info(f"Executing query: {query} with company_id: {company_id}")