Struct PostgresServer 

pub struct PostgresServer {
    pub tool_router: ToolRouter<Self>,
    /* private fields */
}

PostgreSQL MCP Server

Provides MCP tools for interacting with a PostgreSQL database.

Fields

tool_router: ToolRouter<Self>

Implementations

impl PostgresServer

pub fn new(db_config: impl Into<String>) -> Self

Create a new PostgreSQL MCP server

Arguments

• db_config - PostgreSQL connection string (e.g., “host=localhost user=postgres dbname=mydb”)

Example

use rmcp_postgres::PostgresServer;

let server = PostgresServer::new("host=localhost user=postgres dbname=mydb");

impl PostgresServer

pub fn query_data_tool_attr() -> Tool

Generated tool metadata function for query_data

pub fn query_data( &self, Parameters: Parameters<QueryParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Execute a SELECT query on the database

pub fn get_schema_tool_attr() -> Tool

Generated tool metadata function for get_schema

pub fn get_schema( &self, Parameters: Parameters<SchemaParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Get schema information for database tables

pub fn insert_data_tool_attr() -> Tool

Generated tool metadata function for insert_data

pub fn insert_data( &self, Parameters: Parameters<InsertParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Insert data into a table

pub fn list_tables_tool_attr() -> Tool

Generated tool metadata function for list_tables

pub fn list_tables( &self, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

List all tables in the database

pub fn describe_table_tool_attr() -> Tool

Generated tool metadata function for describe_table

pub fn describe_table( &self, Parameters: Parameters<TableNameParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Get detailed information about a table

pub fn count_rows_tool_attr() -> Tool

Generated tool metadata function for count_rows

pub fn count_rows( &self, Parameters: Parameters<CountRowsParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Count rows in a table

pub fn table_exists_tool_attr() -> Tool

Generated tool metadata function for table_exists

pub fn table_exists( &self, Parameters: Parameters<TableNameParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Check if a table exists

pub fn column_exists_tool_attr() -> Tool

Generated tool metadata function for column_exists

pub fn column_exists( &self, Parameters: Parameters<ColumnExistsParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Check if a column exists in a table

pub fn get_table_sample_tool_attr() -> Tool

Generated tool metadata function for get_table_sample

pub fn get_table_sample( &self, Parameters: Parameters<TableSampleParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Get a sample of rows from a table

pub fn update_data_tool_attr() -> Tool

Generated tool metadata function for update_data

pub fn update_data( &self, Parameters: Parameters<UpdateDataParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Update rows in a table

pub fn delete_data_tool_attr() -> Tool

Generated tool metadata function for delete_data

pub fn delete_data( &self, Parameters: Parameters<DeleteDataParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Delete rows from a table

pub fn execute_raw_query_tool_attr() -> Tool

Generated tool metadata function for execute_raw_query

pub fn execute_raw_query( &self, Parameters: Parameters<ExecuteRawQueryParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Execute a raw SQL query

pub fn get_relationships_tool_attr() -> Tool

Generated tool metadata function for get_relationships

pub fn get_relationships( &self, Parameters: Parameters<RelationshipsParams>, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Get foreign key relationships for tables

pub fn get_connection_status_tool_attr() -> Tool

Generated tool metadata function for get_connection_status

pub fn get_connection_status( &self, ) -> Pin<Box<dyn Future<Output = Result<CallToolResult, McpError>> + Send + '_>>

Get database connection status

Trait Implementations

impl ServerHandler for PostgresServer

fn get_info(&self) -> ServerInfo

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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

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