• DATA
  • LOGIC
  • SCHEMA
  • HUMAN

How to test data ingestion with your AI client

Connect RisingWave to your AI client to push JSON events directly into your streaming tables. You can then watch how your logic reacts to new data in real time.

Ask AI about this page

Short answer

How can I test my streaming logic with new data?

Your AI client pushes JSON event payloads into RisingWave tables to trigger your streaming queries. This lets you validate how your logic handles specific event patterns immediately. You'll see the results of your materialized views as the data flows in.

The outcomes.

Where your data lands.

The AI handles the heavy lifting of data movement so you can focus on the query results.

DATA

Live table updates

The AI pushes JSON events into your target tables. Your materialized views update instantly based on the new data.

LOGIC

Rule validation

You can check if your windowing or aggregation logic works as expected. The AI confirms the data landed and the queries reacted.

SCHEMA

Table verification

The AI checks your existing RisingWave schema to ensure the incoming JSON matches your table definitions. This prevents ingestion errors.

HUMAN

Manual tuning

You decide when to adjust your SQL logic or change the event structure. The AI provides the data, but you own the streaming logic.

The workflow

What your AI does when the data arrives.

The AI acts as the bridge between your raw event payloads and your streaming database.

  1. Inspect the schema

    The AI looks at your current RisingWave setup to find the right destination for your events. It needs to know which tables exist before it can send data.

    list_tables

  2. Send the events

    The AI takes your JSON event payloads and writes them directly into the target tables. This simulates a real-time data stream.

    ingest_events

  3. Verify ingestion

    The AI uses the ingestion tool to confirm the data was accepted by the database. It checks that the stream is moving.

    ingest_events

  4. Confirm table state

    The AI checks the table list again to ensure the environment is ready for the next batch of test events.

    list_tables

Try it

Copy these to start.

Use these prompts to begin testing your data streams.

Starting points

Swap the table names and JSON payloads with your actual RisingWave schema details.

RisingWave Connector

You're all set. Choose your MCP client and follow the setup instructions.

Connector linkhttps://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp

Claude Desktop

Follow the steps below to connect in seconds.

  1. 1In Claude Desktop, open Settings → Connectors.
  2. 2Click “Add custom connector” and paste the connector link above as the remote MCP server URL.
  3. 3Click Add and start a new chat — RisingWave capabilities are ready to use.
Configuration · claude_desktop_config.jsonCopy
{
  "mcpServers": {
    "risingwave-streaming-database-mcp": {
      "url": "https://edge.vinkius.com/vk_preview_POZ197YoiA8LB1iU15GyiwF0QcgyMosQUQ2XSBMS/mcp"
    }
  }
}
Copy into chat04

  • List all my RisingWave tables so I can pick one for testing.

  • Ingest this JSON event into the 'user_activity' table: {"user_id": 123, "action": "click"}.

  • Check my tables to see if the 'sensor_data' table is ready for ingestion.

  • Push a batch of five JSON events into the 'web_logs' table to test my windowing logic.

  • Claude
  • ChatGPT
  • Cursor
  • VS Code
  • Windsurf
  • Claude Code
  • JetBrains
  • Cline

Start here

Connect RisingWave once, then ask.

Just link your account once. Your credentials stay encrypted, and you can immediately start sending data through your AI client.

Connect RisingWave to your AI

FAQ

How this task behaves.

  • 01

    Can the AI delete my existing RisingWave tables?

    No. The AI only has tools to list tables and ingest events. It cannot drop or modify your table structures.

  • 02

    Does the AI handle the SQL query execution?

    No. The AI uses specific tools to move data into tables. You must run your own SQL queries in RisingWave to see the results of the ingestion.

  • 03

    Can I send complex nested JSON objects?

    Yes, as long as the JSON structure matches the schema of the table you are targeting.

  • 04

    Will the AI automatically fix my SQL logic if the ingestion fails?

    No. The AI can push the data, but it cannot rewrite your streaming SQL queries for you.

  • 05

    How does the AI know which tables are available?

    The AI uses the list_tables tool to scan your RisingWave instance and identify valid targets.

  • More questions about RisingWave? The Connector page answers them. See everything the RisingWave Connector can do

Connect RisingWave to Claude, Cursor, ChatGPT & more