Chunk #497

Die Tools folgen dem Single Responsibility Principle:

def register_select_tool(mcp: FastMCP):
    logger = ProtokollLogger()

    @mcp.tool()
    def db_select(query, database, max_rows, params) -> dict:
        # 1. Validierung (SRP: QueryValidator)
        valid, error = QueryValidator.validate_query(query, database, max_rows)
        if not valid:
            logger.log(LogEntry(request=query[:200], status="denied", error_message=error))
            return QueryResponse(status=QueryStatus.DENIED, error=error).to_dict()

        # 2. Request erstellen
        request = QueryRequest(
            query=query,
            params=tuple(params) if params else None,
            database=database,
            max_rows=min(max_rows, Config.MAX_ROWS)
        )

        # 3. Ausführung (SRP: SelectExecutor)
        response = SelectExecutor.execute(request)

        # 4. Logging (SRP: ProtokollLogger)
        logger.log(LogEntry(
            request=query[:200],
            status=response.status.value,
            duration_ms=int(response.execution_ms),
            error_message=response.error
        ))

        return response.to_dict()