|
1 | | -# gaussdb-flink-connector-jdbc |
2 | | -Flink connector jdbc implementation for GaussDB |
| 1 | +<p align="center"> |
| 2 | + <h1 align="center">Flink connector jdbc implementation for GaussDB</h1> |
| 3 | + |
| 4 | + |
| 5 | +## 目录 |
| 6 | + |
| 7 | +- [项目介绍](#项目介绍) |
| 8 | +- [前置条件](#前置条件) |
| 9 | +- [使用说明](#使用说明) |
| 10 | +- [获取帮助](#获取帮助) |
| 11 | +- [如何贡献](#如何贡献) |
| 12 | + |
| 13 | +## 项目介绍 |
| 14 | +[Flink-connector-jdbc-gaussdb](https://github.com/HuaweiCloudDeveloper/gaussdb-flink-connector-jdbc) 是一个开源的GaussDB连接器,专为Flink写入数据(sink)到GaussDB场景下使用。 |
| 15 | + |
| 16 | +**核心特性:** |
| 17 | +1. 新增数据:对应insert功能, 新增增量数据。 |
| 18 | +2. 更新数据:对应update功能, 更新存量数据。 |
| 19 | +3. 删除数据:对应delete功能, 删除存量数据。 |
| 20 | +4. 合并数据:对应upsert功能, 根据主键判断目标数据库(GaussDB)是否已存在增量数据,不存在则新增(insert),存在则更新(update)。 |
| 21 | + |
| 22 | +## 前置条件 |
| 23 | +本项目提供的连接器使用前需预先安装 Flink集群及其相关运行环境,并下载对应jar包放置Flink集群各节点的Flink 安装目录 ~/lib 下!!!。 |
| 24 | +需要下载的jar包 <strong>GaussDB驱动</strong> + <strong>flink-connector-jdbc-gaussdb</strong> + <strong>flink-connector-jdbc-core</strong> |
| 25 | +相关依赖jar包下载地址(以3.3.0-1.20版本举例): |
| 26 | +[**GaussDB驱动**](https://repo1.maven.org/maven2/com/huaweicloud/gaussdb/gaussdbjdbc/506.0.0.b058-jdk7/gaussdbjdbc-506.0.0.b058-jdk7.jar) |
| 27 | +[**flink-connector-jdbc-gaussdb**](https://repo.maven.apache.org/maven2/com/huaweicloud/gaussdb/flink/flink-connector-jdbc-gaussdb/3.3.0-1.20/) |
| 28 | +[**flink-connector-jdbc-core**](https://repo1.maven.org/maven2/org/apache/flink/flink-connector-jdbc-core/3.3.0-1.20/) |
| 29 | + |
| 30 | + |
| 31 | +> **系统要求如下:** |
| 32 | +> - CPU: 2GHz 或更高 |
| 33 | +> - RAM: 4GB 或更大 |
| 34 | +> - Disk: 至少 40GB |
| 35 | +
|
| 36 | +## 使用说明 |
| 37 | + |
| 38 | +| jar包版本 | Flink集群系统版本(推荐) | 备注 | |
| 39 | +|--------------------------------------------------------------------------------------------------------------------------------------------------------|------------------------------------------------|----------------------| |
| 40 | +| [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及以下集群环境适用 | |
| 41 | +| [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及以下集群环境适用 | |
| 42 | +| [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集群环境适用 | |
| 43 | +| [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集群环境适用 | |
| 44 | +| [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 | |
| 45 | +| [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及以上使用 | |
| 46 | + |
| 47 | +**注意事项:** |
| 48 | +1. GaussDB驱动的选择: 依照Flink集群环境的JDK版本选择对应的驱动版本,否则可能出现低版本的JDK无法识别高版本的情况,导致任务提交失败。 |
| 49 | +2. 建议直接下载jar包后放置Flink安装目录 ~/lib 下使用,如要使用源码在本地重新打包后使用,注意对应连接器和JDK版本。 |
| 50 | +3. 连接器的选择: flink-connector-jdbc-gaussdb和flink-connector-jdbc-core需要与Flink的版本对应匹配 不支持混合版本使用。 |
| 51 | +4. 源码仓库地址: [**flink-connector-jdbc-gaussdb**](https://github.com/HuaweiCloudDeveloper/gaussdb-flink-connector-jdbc) , [**flink-connector-jdbc-core**](https://github.com/apache/flink-connector-jdbc) |
| 52 | + |
| 53 | +## 获取帮助 |
| 54 | +- 更多问题可通过 [issue](https://github.com/HuaweiCloudDeveloper/gaussdb-flink-connector-jdbc/issues) 与我们取得联系 |
| 55 | + |
| 56 | + |
| 57 | +## 如何贡献 |
| 58 | +- Fork 此存储库并提交合并请求 |
| 59 | +- 基于您的开源源码信息同步更新 README.md |
0 commit comments