Ingest data from MySQL
MySQL is an open-source relational database management system.
Quick Start
Connect in minutes with SQL
Use CREATE SOURCE or CREATE TABLE to ingest data from MySQL into RisingWave. No plugins, no middleware — just PostgreSQL-compatible SQL.
CREATE SOURCE mysql_source WITH (
connector = 'mysql-cdc',
hostname = '127.0.0.1',
port = '8306',
username = 'root',
password = '123456',
database.name = 'mydb',
server.id = 5888
);
CREATE TABLE orders_rw (
order_id INTEGER PRIMARY KEY,
customer_id INTEGER,
order_status VARCHAR,
total_amount DECIMAL,
last_updated TIMESTAMP,
)
FROM source my_source TABLE orders;For comprehensive configuration details, please refer to the MySQL CDC connector documentation
Capabilities
What you can do with RisingWave + MySQL
Real-time Ingestion
Continuously stream data from MySQL into RisingWave with sub-second latency. Process millions of events per second.
SQL Transformations
Join MySQL data with other sources, apply windowing, aggregation, and filtering — all in standard SQL.
Materialized Views
Create incrementally maintained materialized views over MySQL data. Always fresh, always queryable.
Multi-format Support
Supports Avro, JSON, Protobuf, CSV, and more. Compatible with Schema Registry for schema evolution.
Resources
Learn more
Complete configuration reference, authentication options, and advanced features for the MySQL source connector.
RisingWave also supports MySQL as a destination. View the destination connector.
Get RisingWave running locally in 5 minutes and try your first streaming pipeline.
Start streaming in minutes
Connect to MySQL with just a few lines of SQL. No infrastructure to manage, no code to write.
