# gaussdb-flink-connector-jdbc **Repository Path**: HuaweiCloudDeveloper/gaussdb-flink-connector-jdbc ## Basic Information - **Project Name**: gaussdb-flink-connector-jdbc - **Description**: No description available - **Primary Language**: Unknown - **License**: Apache-2.0 - **Default Branch**: master-dev - **Homepage**: None - **GVP Project**: No ## Statistics - **Stars**: 0 - **Forks**: 0 - **Created**: 2025-05-16 - **Last Updated**: 2025-05-21 ## Categories & Tags **Categories**: Uncategorized **Tags**: None ## README

Flink connector jdbc implementation for GaussDB

## 目录 - [项目介绍](#项目介绍) - [前置条件](#前置条件) - [使用说明](#使用说明) - [获取帮助](#获取帮助) - [如何贡献](#如何贡献) ## 项目介绍 ‌[Flink-connector-jdbc-gaussdb‌](https://github.com/HuaweiCloudDeveloper/gaussdb-flink-connector-jdbc) 是一个开源的GaussDB连接器，专为Flink写入数据(sink)到GaussDB场景下使用。 **核心特性：** 1. 新增数据：对应insert功能, 新增增量数据。 2. 更新数据：对应update功能, 更新存量数据。 3. ‌删除数据：对应delete功能, 删除存量数据。 4. 合并数据：对应upsert功能, 根据主键判断目标数据库(GaussDB)是否已存在增量数据，不存在则新增(insert)，存在则更新(update)。 ## 前置条件 本项目提供的连接器使用前需预先安装 Flink集群及其相关运行环境，并下载对应jar包放置Flink集群各节点的Flink 安装目录 ~/lib 下！！！。 需要下载的jar包 GaussDB驱动 + flink-connector-jdbc-gaussdb + flink-connector-jdbc-core 相关依赖jar包下载地址(以3.3.0-1.20版本举例): [**GaussDB驱动**](https://repo1.maven.org/maven2/com/huaweicloud/gaussdb/gaussdbjdbc/506.0.0.b058-jdk7/gaussdbjdbc-506.0.0.b058-jdk7.jar) [**flink-connector-jdbc-gaussdb**](https://repo.maven.apache.org/maven2/com/huaweicloud/gaussdb/flink/flink-connector-jdbc-gaussdb/3.3.0-1.20/) [**flink-connector-jdbc-core**](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-jdbc-core/3.3.0-1.20/) > **系统要求如下：** > - CPU: 2GHz 或更高 > - RAM: 4GB 或更大 > - Disk: 至少 40GB ## 使用说明 | jar包版本 | Flink集群系统版本(推荐) | 备注 | |--------------------------------------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|----------------------| | [flink-connector-jdbc-gaussdb-3.3.0-1.20](https://repo.maven.apache.org/maven2/com/huaweicloud/gaussdb/flink/flink-connector-jdbc-gaussdb/3.3.0-1.20/) | 基于 鲲鹏服务器 + Huawei Cloud EulerOS 2.0 标准版 64位 安装部署 | Flink1.20及以下集群环境适用 | | [flink-connector-jdbc-core-3.3.0-1.20](https://repo.maven.apache.org/maven2/com/huaweicloud/gaussdb/flink/flink-connector-jdbc-gaussdb/3.3.0-1.20/) | 基于 鲲鹏服务器 + Huawei Cloud EulerOS 2.0 标准版 64位 安装部署 | Flink1.20及以下集群环境适用 | | [flink-connector-jdbc-gaussdb-4.0.0-2.0](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-jdbc-core/4.0.0-2.0/) | 基于 鲲鹏服务器 + Huawei Cloud EulerOS 2.0 标准版 64位 安装部署 | Flink2.0集群环境适用 | | [flink-connector-jdbc-core-4.0.0-2.0](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-jdbc-core/4.0.0-2.0/) | 基于 鲲鹏服务器 + Huawei Cloud EulerOS 2.0 标准版 64位 安装部署 | Flink2.0集群环境适用 | | [GaussDB驱动1](https://repo1.maven.org/maven2/com/huaweicloud/gaussdb/gaussdbjdbc/506.0.0.b058-jdk7/gaussdbjdbc-506.0.0.b058-jdk7.jar) | 基于 鲲鹏服务器 + Huawei Cloud EulerOS 2.0 标准版 64位 安装部署 |Flink集群环境JDK 17以下使用 如 JDK 8、11 | | [GaussDB驱动2](https://repo1.maven.org/maven2/com/huaweicloud/gaussdb/gaussdbjdbc/506.0.0.b058/gaussdbjdbc-506.0.0.b058.jar) | 基于 鲲鹏服务器 + Huawei Cloud EulerOS 2.0 标准版 64位 安装部署 |Flink集群环境JDK 17及以上使用 | **注意事项:** 1. GaussDB驱动的选择: 依照Flink集群环境的JDK版本选择对应的驱动版本，否则可能出现低版本的JDK无法识别高版本的情况,导致任务提交失败。 2. 建议直接下载jar包后放置Flink安装目录 ~/lib 下使用,如要使用源码在本地重新打包后使用，注意对应连接器和JDK版本。 3. 连接器的选择: flink-connector-jdbc-gaussdb和flink-connector-jdbc-core需要与Flink的版本对应匹配 不支持混合版本使用。 4. 源码仓库地址: [**flink-connector-jdbc-gaussdb**](https://github.com/HuaweiCloudDeveloper/gaussdb-flink-connector-jdbc) , [**flink-connector-jdbc-core**](https://github.com/apache/flink-connector-jdbc) ## 获取帮助 - 更多问题可通过 [issue](https://github.com/HuaweiCloudDeveloper/gaussdb-flink-connector-jdbc/issues) 与我们取得联系 ## 如何贡献 - Fork 此存储库并提交合并请求 - 基于您的开源源码信息同步更新 README.md