Upload 12 files

app/utils/db_http.py

@@ -361,14 +361,19 @@ def select_records(table: str, columns: List[str] = None, condition: str = None,
                         value = row[i]["value"]
 
                         # Convert value based on type
-                        if row[i]["type"] == "integer":
-                            value = int(value)
-                        elif row[i]["type"] == "float":
-                            value = float(value)
-                        elif row[i]["type"] == "null":
-                            value = None
-
-                        record[col_name] = value
+                        try:
+                            if row[i]["type"] == "integer":
+                                value = int(value)
+                            elif row[i]["type"] == "float":
+                                value = float(value)
+                            elif row[i]["type"] == "null":
+                                value = None
+
+                            record[col_name] = value
+                        except (KeyError, TypeError, ValueError) as e:
+                            # Handle missing or invalid values
+                            logger.warning(f"Error converting value for column {col_name}: {str(e)}")
+                            record[col_name] = None
 
                     records.append(record)
 
@@ -397,15 +402,62 @@ def get_record_by_id(table: str, id: int, columns: List[str] = None, operation_i
     if operation_id is None:
         operation_id = f"get_by_id_{int(time.time())}"
 
-    condition = "id = ?"
-    condition_params = [{"type": "integer", "value": str(id)}]
+    try:
+        condition = "id = ?"
+        condition_params = [{"type": "integer", "value": str(id)}]
+
+        records = select_records(table, columns, condition, condition_params, limit=1, operation_id=operation_id)
 
-    records = select_records(table, columns, condition, condition_params, limit=1, operation_id=operation_id)
+        if records and len(records) > 0:
+            logger.debug(f"[{operation_id}] Found record by ID {id}: {records[0]}")
+            return records[0]
 
-    if records:
-        return records[0]
+        logger.warning(f"[{operation_id}] No record found with ID {id} in table {table}")
+        return None
+    except Exception as e:
+        logger.error(f"[{operation_id}] Error getting record by ID {id}: {str(e)}")
 
-    return None
+        # Try a direct query as a fallback
+        try:
+            logger.info(f"[{operation_id}] Trying direct query as fallback")
+            cols = "*" if not columns else ", ".join(columns)
+            sql = f"SELECT {cols} FROM {table} WHERE id = ? LIMIT 1"
+
+            result = execute_query(sql, [{"type": "integer", "value": str(id)}], operation_id=f"{operation_id}_fallback")
+
+            if "results" in result and len(result["results"]) > 0 and result["results"][0]["type"] == "ok":
+                response = result["results"][0]["response"]
+                if "result" in response and "rows" in response["result"] and len(response["result"]["rows"]) > 0:
+                    row = response["result"]["rows"][0]
+                    cols = response["result"]["cols"]
+
+                    record = {}
+                    for i, col in enumerate(cols):
+                        try:
+                            col_name = col["name"]
+                            value = row[i]["value"]
+
+                            # Convert value based on type
+                            if row[i]["type"] == "integer":
+                                value = int(value)
+                            elif row[i]["type"] == "float":
+                                value = float(value)
+                            elif row[i]["type"] == "null":
+                                value = None
+
+                            record[col_name] = value
+                        except (KeyError, TypeError, ValueError) as e:
+                            logger.warning(f"[{operation_id}] Error converting value for column {col['name'] if 'name' in col else i}: {str(e)}")
+                            continue
+
+                    logger.info(f"[{operation_id}] Found record by ID {id} using fallback: {record}")
+                    return record
+
+            logger.warning(f"[{operation_id}] No record found with ID {id} using fallback")
+            return None
+        except Exception as e2:
+            logger.error(f"[{operation_id}] Error in fallback query: {str(e2)}")
+            return None
 
 def count_records(table: str, condition: str = None, condition_params: List[Dict[str, Any]] = None, operation_id: str = None) -> int:
     """