Database Manager

Database operation handler module.

This module provides functionality for: - Managing MariaDB connections and transactions - Processing different types of database requests - Handling state vector data insertion - Comprehensive error handling and logging

db_manager.run_db_manager(db_request: List[str], db_logger: Logger) → None[source]

Execute database operations for incoming requests.

Handles the full database operation lifecycle: 1. Parse incoming request data 2. Establish database connection 3. Generate appropriate SQL statement 4. Execute transaction 5. Handle connection cleanup

Parameters:

  • db_request (List[str]) – List of string elements comprising the request

  • db_logger (logging.Logger) – Configured logger instance

Raises:

  • json.JSONDecodeError – If invalid JSON is received

  • mariadb.Error – For database connection/operation failures

Example

>>> run_db_manager(['StateVector', '{"time": "2023-01-01"}'], logger)
db_manager.message_management(db_data: Tuple[str, Dict[str, Any]], db_logger: Logger) → Tuple[str, tuple, str][source]

Generate SQL statements and values based on request type.

Parameters:

  • db_data (Tuple[str, Dict[str, Any]]) – Tuple containing: - Request type identifier as string - Data dictionary with field/value pairs

  • db_logger (logging.Logger) – Configured logger instance

Returns:

Contains:

  • SQL query string

  • Parameter values tuple

  • Log message

Return type:

Tuple[str, tuple, str]

Raises:

ValueError – For unsupported request types

Example

>>> message_management(('StateVector', {...}), logger)