Struct SqliteHandler 

pub struct SqliteHandler { /* private fields */ }

SQLite file-based database handler.

Composes one [SqliteConnection] (which owns the pool and the pool initialization logic) with the per-backend MCP tool router.

Implementations

impl SqliteHandler

pub fn new(config: &DatabaseConfig) -> Self

Creates a new SQLite handler.

Constructs the [SqliteConnection] (which builds the lazy pool) and the MCP tool router. No file I/O happens here.

impl SqliteHandler

pub async fn drop_table( &self, __arg1: DropTableRequest, ) -> Result<MessageResponse, SqlError>

Drops a table from the database.

Errors

Returns SqlError::ReadOnlyViolation in read-only mode, SqlError::InvalidIdentifier for invalid names, or SqlError::Query if the backend reports an error.

impl SqliteHandler

pub async fn explain_query( &self, __arg1: ExplainQueryRequest, ) -> Result<QueryResponse, SqlError>

Returns the execution plan for a query.

Always uses EXPLAIN QUERY PLAN — SQLite does not support EXPLAIN ANALYZE.

Errors

Returns SqlError::Query if the backend reports an error.

impl SqliteHandler

pub async fn get_table_schema( &self, __arg1: GetTableSchemaRequest, ) -> Result<TableSchemaResponse, SqlError>

Returns column definitions with foreign key relationships.

Errors

Returns SqlError if validation fails or the query errors.

impl SqliteHandler

pub async fn list_tables( &self, __arg1: ListTablesRequest, ) -> Result<ListTablesResponse, ErrorData>

Lists one page of tables in the connected database.

Errors

Returns ErrorData with code -32602 if cursor is malformed, or an internal-error ErrorData if the underlying query fails.

impl SqliteHandler

pub async fn read_query( &self, __arg1: ReadQueryRequest, ) -> Result<ReadQueryResponse, SqlError>

Executes a read-only SQL query, paginating SELECT result rows.

Validates that the query is read-only, then dispatches on the classified StatementKind: Select is wrapped in a subquery with a server-controlled LIMIT/OFFSET; NonSelect (EXPLAIN under the SQLite dialect) is executed as-is and returned in a single page. A malformed cursor is rejected by the serde deserializer before this method is called, producing JSON-RPC -32602.

Errors

Returns SqlError::ReadOnlyViolation if the query is not read-only, or SqlError::Query if the backend reports an error.

impl SqliteHandler

pub async fn write_query( &self, __arg1: QueryRequest, ) -> Result<QueryResponse, SqlError>

Executes a write SQL query.

Errors

Returns SqlError if the query fails.

Trait Implementations

impl Clone for SqliteHandler

fn clone(&self) -> SqliteHandler

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for SqliteHandler

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<SqliteHandler> for Server

fn from(handler: SqliteHandler) -> Self

Wraps a SqliteHandler in the type-erased MCP server.

impl ServerHandler for SqliteHandler

fn get_info(&self) -> ServerInfo

async fn call_tool( &self, request: CallToolRequestParams, context: RequestContext<RoleServer>, ) -> Result<CallToolResult, ErrorData>

async fn list_tools( &self, _request: Option<PaginatedRequestParams>, _context: RequestContext<RoleServer>, ) -> Result<ListToolsResult, ErrorData>

fn get_tool(&self, name: &str) -> Option<Tool>

Get a tool definition by name.

fn enqueue_task( &self, _request: CallToolRequestParams, _context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CreateTaskResult, ErrorData>> + MaybeSendFuture

fn ping( &self, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn initialize( &self, request: InitializeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<InitializeResult, ErrorData>> + MaybeSendFuture

fn complete( &self, request: CompleteRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CompleteResult, ErrorData>> + MaybeSendFuture

fn set_level( &self, request: SetLevelRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn get_prompt( &self, request: GetPromptRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetPromptResult, ErrorData>> + MaybeSendFuture

fn list_prompts( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListPromptsResult, ErrorData>> + MaybeSendFuture

fn list_resources( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourcesResult, ErrorData>> + MaybeSendFuture

fn list_resource_templates( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListResourceTemplatesResult, ErrorData>> + MaybeSendFuture

fn read_resource( &self, request: ReadResourceRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ReadResourceResult, ErrorData>> + MaybeSendFuture

fn subscribe( &self, request: SubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn unsubscribe( &self, request: UnsubscribeRequestParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<(), ErrorData>> + MaybeSendFuture

fn on_custom_request( &self, request: CustomRequest, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CustomResult, ErrorData>> + MaybeSendFuture

fn on_cancelled( &self, notification: CancelledNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_progress( &self, notification: ProgressNotificationParam, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_initialized( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_roots_list_changed( &self, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn on_custom_notification( &self, notification: CustomNotification, context: NotificationContext<RoleServer>, ) -> impl Future<Output = ()> + MaybeSendFuture

fn list_tasks( &self, request: Option<PaginatedRequestParams>, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<ListTasksResult, ErrorData>> + MaybeSendFuture

fn get_task_info( &self, request: GetTaskInfoParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetTaskResult, ErrorData>> + MaybeSendFuture

fn get_task_result( &self, request: GetTaskResultParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<GetTaskPayloadResult, ErrorData>> + MaybeSendFuture

fn cancel_task( &self, request: CancelTaskParams, context: RequestContext<RoleServer>, ) -> impl Future<Output = Result<CancelTaskResult, ErrorData>> + MaybeSendFuture