flink cdc sql

Flink CDC SQL是Flink SQL的一个扩展，支持从数据源中捕获数据变更并将其转换为流式数据。CDC SQL支持从各种数据源中捕获数据变更，例如MySQL、PostgreSQL和Oracle等关系型数据库，以及Kafka和Debezium等其他数据源。

使用CDC SQL，可以轻松地编写SQL查询来捕获数据库中的数据变更，并将其转换为流式数据。这使得您可以使用Flink的流处理功能来处理实时的数据变更，例如插入、更新和删除操作。此外，CDC SQL还提供了一些内置函数和操作符，以便您能够在SQL查询中方便地进行流处理操作。

例如，以下是一个使用CDC SQL从MySQL数据库中捕获数据变更的示例：

CREATE TABLE orders (
  id INT PRIMARY KEY,
  product_name VARCHAR(100),
  price DECIMAL
) WITH (
  'connector' = 'mysql-cdc',
  'hostname' = 'localhost',
  'port' = '3306',
  'username' = 'user',
  'password' = 'pass',
  'database-name' = 'test',
  'table-name' = 'orders'
);

上面的代码创建了一个名为“orders”的表，并使用MySQL CDC连接器将其与MySQL数据库中的“test.orders”表关联起来。这意味着当“test.orders”表中的数据发生变化时，Flink将自动捕获该变化并将其转换为流式数据。