基于Flink同步数据到南大通用数据库的方法、系统、设备及存储介质

    公开(公告)号:CN119669353A

    公开(公告)日:2025-03-21

    申请号:CN202411683736.3

    申请日:2024-11-22

    Abstract: 本发明公开了一种基于Flink同步数据到南大通用数据库的方法、系统、设备及存储介质,属于同步数据到数据库技术领域,解决目前Flink不支持将数据写入南大通用国产数据库的技术问题。方法为:新建项目并添加南大通用数据库JDBC驱动依赖包、Flink所需要jar、flink‑connector‑mysql‑cdc包;获取所需要修改的flink‑connector‑jdbc项目的源码;并对flink‑connector‑jdbc.jar作适配南大通用数据库改造;在项目额外添加经适配南大通用数据库修改后的flink‑connector‑jdbc‑gbase.jar依赖包;在项目使用flinksql的语法编写将读取Mysql中user表实时同步到南大通用数据库的user表定义信息;将项目打包成jar并运行到flink的环境中;从而能够通过FlinkStream和SQL方式高效地批量写入数据到南大通用数据库。

Patent Agency Ranking