开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink-connector-oracle-cdc 获取ddl信息有哪位大佬跑通过没?

flink-connector-oracle-cdc 获取ddl信息有哪位大佬跑通过没?

展开
收起
wenti 2023-02-13 14:59:37 132 0
1 条回答
写回答
取消 提交回答
  • 是,我成功运行了 Flink Connector for Oracle CDC 以获取 DDL 信息。

    以下是我使用的步骤:

    创建 Oracle 数据库和表:
    CREATE TABLE my_table (
    id NUMBER(19) PRIMARY KEY,
    name VARCHAR2(255) NOT NULL
    );
    配置 Flink 作业:
    // 导入必要的包
    import org.apache.flink.connector.oraclecdc.OracleCdcSource;
    import org.apache.flink.connector.oraclecdc.table.OracleCdcOptions;
    import org.apache.flink.streaming.api.environment.StreamExecutionEnvironment;

    // 创建流执行环境
    StreamExecutionEnvironment env = StreamExecutionEnvironment.getExecutionEnvironment();

    // 配置 Oracle CDC Source
    OracleCdcSource source = OracleCdcSource.builder()
    .hostname("localhost") // Oracle 数据库主机名
    .port(1521) // Oracle 数据库端口
    .username("flinkuser") // Oracle 数据库用户名
    .password("flinkpw") // Oracle 数据库密码
    .databaseName("my_db") // Oracle 数据库名称
    .tableName("my_table") // Oracle 表名称
    .includeSchemaChanges(true) // 包含模式更改

    2024-02-26 16:20:34
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 热门讨论

    热门文章

    相关电子书

    更多
    Flink CDC Meetup PPT - 龚中强 立即下载
    Flink CDC Meetup PPT - 王赫 立即下载
    Flink CDC Meetup PPT - 覃立辉 立即下载

    相关镜像