RisingWave
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
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 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
Related Databases MCP servers
View all
Memwrightbolnet/agent-memoryEmbedded memory for AI agents with SQLite, pgvector, and Neo4j graph search.0stars
Zotero Bridgecombjellyshen/zoterobridgeMCP Server for Zotero SQLite Database - collection, tagging, PDF reading and more.10stars
oraclemcpmuhdur/oraclemcpEngine-free, governed Oracle Database MCP server with a fail-closed SQL guard (unofficial).4stars
DB Connect MCPyugui923/db-connect-mcpMulti-database MCP server for PostgreSQL, MySQL, and ClickHouse4stars