RisingWave
risingwavelabs/risingwave-mcp
Query, inspect and operate RisingWave, the PostgreSQL-compatible streaming database, from an agent.
- GitHub stars
- 20
- tools
- 80
- auth
- Secret needed
- transport
- STDIO
- env vars
- 2
- last updated
- Nov 9, 2026
Tools
80 toolsPublic tool metadata for what this MCP can expose to an agent.
run_select_queryExecute a SELECT query against RisingWave
Execute a SELECT query against RisingWave
No parameter schema in public metadata yet.
table_row_countGet the row count for a specific table
Get the row count for a specific table
No parameter schema in public metadata yet.
get_table_statsGet comprehensive statistics for a table
Get comprehensive statistics for a table
No parameter schema in public metadata yet.
explain_queryGet query execution plan without running it
Get query execution plan without running it
No parameter schema in public metadata yet.
explain_analyzeExecute EXPLAIN ANALYZE for detailed runtime statistics
Execute EXPLAIN ANALYZE for detailed runtime statistics
No parameter schema in public metadata yet.
explain_distsqlGet distributed execution plan for streaming statements
Get distributed execution plan for streaming statements
No parameter schema in public metadata yet.
show_tablesList all tables in the database
List all tables in the database
No parameter schema in public metadata yet.
list_databasesList all databases in the cluster
List all databases in the cluster
No parameter schema in public metadata yet.
describe_tableDescribe table structure (columns, types)
Describe table structure (columns, types)
No parameter schema in public metadata yet.
describe_materialized_viewDescribe materialized view structure
Describe materialized view structure
No parameter schema in public metadata yet.
show_create_tableShow CREATE TABLE statement
Show CREATE TABLE statement
No parameter schema in public metadata yet.
show_create_materialized_viewShow CREATE MATERIALIZED VIEW statement
Show CREATE MATERIALIZED VIEW statement
No parameter schema in public metadata yet.
check_table_existsCheck if a table or MV exists
Check if a table or MV exists
No parameter schema in public metadata yet.
list_schemasList all schemas in the database
List all schemas in the database
No parameter schema in public metadata yet.
list_materialized_viewsList all materialized views in a schema
List all materialized views in a schema
No parameter schema in public metadata yet.
get_table_columnsGet detailed column information
Get detailed column information
No parameter schema in public metadata yet.
list_subscriptionsList all subscriptions in a schema
List all subscriptions in a schema
No parameter schema in public metadata yet.
list_table_privilegesList privileges for a table
List privileges for a table
No parameter schema in public metadata yet.
list_sinksList all sinks in the database
List all sinks in the database
No parameter schema in public metadata yet.
show_create_sinkShow CREATE SINK statement
Show CREATE SINK statement
No parameter schema in public metadata yet.
get_relation_infoGet info about any relation by name
Get info about any relation by name
No parameter schema in public metadata yet.
show_create_sourceShow CREATE SOURCE statement
Show CREATE SOURCE statement
No parameter schema in public metadata yet.
create_schemaCreate a new schema
Create a new schema
No parameter schema in public metadata yet.
drop_tableDrop a table
Drop a table
No parameter schema in public metadata yet.
add_table_columnAdd a column to a table
Add a column to a table
No parameter schema in public metadata yet.
drop_table_columnRemove a column from a table
Remove a column from a table
No parameter schema in public metadata yet.
rename_tableRename a table
Rename a table
No parameter schema in public metadata yet.
alter_table_parallelismChange table parallelism
Change table parallelism
No parameter schema in public metadata yet.
alter_table_source_rate_limitModify source rate limit for tables
Modify source rate limit for tables
No parameter schema in public metadata yet.
create_materialized_viewCreate a new materialized view
Create a new materialized view
No parameter schema in public metadata yet.
drop_materialized_viewDrop a materialized view
Drop a materialized view
No parameter schema in public metadata yet.
alter_mv_parallelismChange MV parallelism
Change MV parallelism
No parameter schema in public metadata yet.
alter_mv_backfill_rate_limitModify MV backfill rate limit
Modify MV backfill rate limit
No parameter schema in public metadata yet.
rename_materialized_viewRename a materialized view
Rename a materialized view
No parameter schema in public metadata yet.
swap_materialized_viewsAtomically swap two MVs
Atomically swap two MVs
No parameter schema in public metadata yet.
execute_ddl_statementExecute generic DDL statements
Execute generic DDL statements
No parameter schema in public metadata yet.
create_kafka_tableCreate a table with Kafka connector
Create a table with Kafka connector
No parameter schema in public metadata yet.
add_table_commentAdd comment to a table
Add comment to a table
No parameter schema in public metadata yet.
add_column_commentAdd comment to a column
Add comment to a column
No parameter schema in public metadata yet.
insert_single_rowInsert a single row into a table
Insert a single row into a table
No parameter schema in public metadata yet.
insert_multiple_rowsBatch insert multiple rows
Batch insert multiple rows
No parameter schema in public metadata yet.
update_rowsUpdate rows in a table
Update rows in a table
No parameter schema in public metadata yet.
delete_rowsDelete rows from a table
Delete rows from a table
No parameter schema in public metadata yet.
list_sourcesList all sources
List all sources
No parameter schema in public metadata yet.
describe_sourceDescribe source structure
Describe source structure
No parameter schema in public metadata yet.
alter_source_parallelismChange source parallelism
Change source parallelism
No parameter schema in public metadata yet.
alter_source_rate_limitModify source ingestion rate
Modify source ingestion rate
No parameter schema in public metadata yet.
refresh_source_schemaRefresh schema from registry
Refresh schema from registry
No parameter schema in public metadata yet.
rename_sourceRename a source
Rename a source
No parameter schema in public metadata yet.
drop_sourceDrop a source
Drop a source
No parameter schema in public metadata yet.
describe_sinkDescribe sink structure
Describe sink structure
No parameter schema in public metadata yet.
alter_sink_parallelismChange sink parallelism
Change sink parallelism
No parameter schema in public metadata yet.
alter_sink_rate_limitModify sink output rate
Modify sink output rate
No parameter schema in public metadata yet.
rename_sinkRename a sink
Rename a sink
No parameter schema in public metadata yet.
drop_sinkDrop a sink
Drop a sink
No parameter schema in public metadata yet.
list_connectionsList all connections
List all connections
No parameter schema in public metadata yet.
show_create_connectionShow CREATE CONNECTION statement
Show CREATE CONNECTION statement
No parameter schema in public metadata yet.
drop_connectionDrop a connection
Drop a connection
No parameter schema in public metadata yet.
list_secretsList all secrets (values hidden)
List all secrets (values hidden)
No parameter schema in public metadata yet.
drop_secretDrop a secret
Drop a secret
No parameter schema in public metadata yet.
list_indexesList indexes for a table
List indexes for a table
No parameter schema in public metadata yet.
describe_indexDescribe index structure
Describe index structure
No parameter schema in public metadata yet.
show_create_indexShow CREATE INDEX statement
Show CREATE INDEX statement
No parameter schema in public metadata yet.
drop_indexDrop an index
Drop an index
No parameter schema in public metadata yet.
list_functionsList all user-defined functions
List all user-defined functions
No parameter schema in public metadata yet.
show_create_functionShow CREATE FUNCTION statement
Show CREATE FUNCTION statement
No parameter schema in public metadata yet.
drop_functionDrop a function
Drop a function
No parameter schema in public metadata yet.
list_usersList all users
List all users
No parameter schema in public metadata yet.
get_user_privilegesGet privileges for a user
Get privileges for a user
No parameter schema in public metadata yet.
get_schema_privilegesGet schema-level privileges
Get schema-level privileges
No parameter schema in public metadata yet.
get_database_privilegesGet database-level privileges
Get database-level privileges
No parameter schema in public metadata yet.
show_clusterDisplay cluster node details
Display cluster node details
No parameter schema in public metadata yet.
show_jobsList active streaming jobs
List active streaming jobs
No parameter schema in public metadata yet.
cancel_jobsCancel running jobs
Cancel running jobs
No parameter schema in public metadata yet.
recover_clusterTrigger manual recovery
Trigger manual recovery
No parameter schema in public metadata yet.
get_cluster_infoGet comprehensive cluster info
Get comprehensive cluster info
No parameter schema in public metadata yet.
get_database_versionGet RisingWave version info
Get RisingWave version info
No parameter schema in public metadata yet.
show_running_queriesShow currently running queries
Show currently running queries
No parameter schema in public metadata yet.
flush_databaseForce flush pending writes
Force flush pending writes
No parameter schema in public metadata yet.
set_session_variableSet a session variable
Set a session variable
No parameter schema in public metadata yet.
Sponsors
Promote your product hereReach 125k+ visitors monthlyPromote your product hereReach 125k+ visitors monthly
Agent CaffeineSponsoredClose your lid, come back to finished work
SnugSponsoredThe clipboard manager for the AI eraPromote your product hereReach 125k+ visitors monthly
WaxSponsoredBlock anything with supervision, without erasing your iPhonePromote your product hereReach 125k+ visitors monthly
knobsSponsoredSee your site on any phone, any day, in any language
Agent CaffeineSponsoredClose your lid, come back to finished workSnugSponsoredThe clipboard manager for the AI eraPromote your product hereReach 125k+ visitors monthlyWaxSponsoredBlock anything with supervision, without erasing your iPhonePromote your product hereReach 125k+ visitors monthlyknobsSponsoredSee your site on any phone, any day, in any languageConfiguration
RISINGWAVE_CONNECTION_STR*secretPostgreSQL connection string for RisingWave, e.g. postgresql://user:password@host:4566/dev. Use a user with SELECT on the views the agent may read.
MCP_TRANSPORTdefault: stdioTransport the server speaks. The registry package uses stdio; the image defaults to streamable-http.
Readme
RisingWave MCP Server
RisingWave MCP Server is a comprehensive Model Context Protocol (MCP) server that lets you query and manage your RisingWave streaming database using natural language through AI assistants like VS Code Copilot and Claude Desktop.
Features
- Real-time access to RisingWave tables, materialized views, and streaming data
- Complete management of sources, sinks, connections, indexes, and UDFs
- Streaming job monitoring with fragment, actor, and backfill tracking
- Storage analysis with Hummock/compaction insights
- Built on
FastMCPandrisingwave-pywith high-performance STDIO transport - Seamless integration with VS Code Copilot, Claude Desktop, and other MCP-compatible tools
Installation
Option 1: Docker (Recommended)
docker pull risingwavelabs/risingwave-mcp-server:0.1.1
Option 1b: MCP Registry
Details
- Repository
- github.com/risingwavelabs/risingwave-mcp
- Website
- risingwave.com/mcp-streaming-database
- Categories
- Databases, AI & LLM Tools, Media & Entertainment
- Package
docker.io/risingwavelabs/risingwave-mcp-server:0.1.1- Transport
- STDIO
- Auth
- Required
- Registry
- MCP registry, active
