Package org.gridgain.internal.mcp.tools

Class SqlQueryExecutor

java.lang.Object

org.gridgain.internal.mcp.tools.SqlQueryExecutor

public class SqlQueryExecutor
extends Object

Executes read-only SQL SELECT queries against GridGain.

Features:

• Query validation (SELECT/WITH only)
• LIMIT enforcement (max 1000 rows)
• Query timeout support
• Structured JSON results with metrics

Constructor Summary

Constructors

Constructor	Description
SqlQueryExecutor()

Method Summary

Modifier and Type	Method	Description
static McpResponse	execute(org.apache.ignite.client.IgniteClient client, String query)	Execute SQL query using provided connection pool.
static reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.CallToolResult>	handleSelectQuery(io.modelcontextprotocol.server.McpAsyncServerExchange exchange, Map<String,Object> arguments)	Handles execution of the connect_with_retry tool.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

SqlQueryExecutor

public SqlQueryExecutor()

Method Details

handleSelectQuery

public static reactor.core.publisher.Mono<io.modelcontextprotocol.spec.McpSchema.CallToolResult> handleSelectQuery(io.modelcontextprotocol.server.McpAsyncServerExchange exchange,
 Map<String,Object> arguments)

Handles execution of the connect_with_retry tool.

Parameters:

exchange - MCP server exchange

arguments - tool arguments

Returns:

reactive MCP tool result

execute

public static McpResponse execute(org.apache.ignite.client.IgniteClient client,
 String query)

Execute SQL query using provided connection pool.

Parameters:

client - shared connection client

query - SQL SELECT query

Returns:

MCP response with results or error