diff --git a/README.en.md b/README.en.md new file mode 100644 index 0000000000000000000000000000000000000000..0c43a4a5061410b3863e2897582ceff0543f2dfd --- /dev/null +++ b/README.en.md @@ -0,0 +1,56 @@ +# flink-cdc-demo1 + +This is a simple demonstration project based on Flink CDC, showcasing how to use Apache Flink to capture database changes in real time. The project contains two main classes, each demonstrating the CDC functionality of Microsoft SQL Server (MSSQL) and SQL Server. + +## Project Structure + +- **MSSQLMain.java** - Demonstrates CDC integration with Microsoft SQL Server. +- **SQLSERVERMain.java** - Demonstrates CDC integration with SQL Server. + +## Features + +- Real-time monitoring of database changes. +- Stream processing using Apache Flink. +- Support for multiple databases (MSSQL and SQL Server). + +## Installation and Running + +### Prerequisites + +- Java 8 or higher +- Apache Flink environment +- Maven + +### Build the Project + +```bash +mvn clean package +``` + +### Run the Project + +#### Run the MSSQL Example + +```bash +mvn exec:java -Dexec.mainClass="indi.zhifa.study2025.flinkcdc.MSSQLMain" +``` + +#### Run the SQL Server Example + +```bash +mvn exec:java -Dexec.mainClass="indi.zhifa.study2025.flinkcdc.SQLSERVERMain" +``` + +## Contribution Guide + +Contributions of code and improvements are welcome! Please follow these steps: + +1. Fork the project. +2. Create a new branch (`git checkout -b feature/your-feature-name`). +3. Commit your changes (`git commit -am 'Add some feature'`). +4. Push the branch (`git push origin feature/your-feature-name`). +5. Submit a Pull Request. + +## License + +This project is licensed under the MIT License. See the [LICENSE](LICENSE) file for details. \ No newline at end of file diff --git a/README.md b/README.md new file mode 100644 index 0000000000000000000000000000000000000000..ae3fecbefb41b48a3a8120b9db6278108a68e33a --- /dev/null +++ b/README.md @@ -0,0 +1,56 @@ +# flink-cdc-demo1 + +这是一个基于 Flink CDC 的简单演示项目,展示了如何使用 Apache Flink 实时捕获数据库更改。该项目包含了两个主要类,分别用于演示 Microsoft SQL Server (MSSQL) 和 SQL Server 的 CDC 功能。 + +## 项目结构 + +- **MSSQLMain.java** - 用于演示与 Microsoft SQL Server 的 CDC 集成。 +- **SQLSERVERMain.java** - 用于演示与 SQL Server 的 CDC 集成。 + +## 功能特点 + +- 实时监控数据库变更。 +- 使用 Apache Flink 进行流处理。 +- 支持多种数据库(MSSQL 和 SQL Server)。 + +## 安装与运行 + +### 前提条件 + +- Java 8 或更高版本 +- Apache Flink 环境 +- Maven + +### 构建项目 + +```bash +mvn clean package +``` + +### 运行项目 + +#### 运行 MSSQL 示例 + +```bash +mvn exec:java -Dexec.mainClass="indi.zhifa.study2025.flinkcdc.MSSQLMain" +``` + +#### 运行 SQL Server 示例 + +```bash +mvn exec:java -Dexec.mainClass="indi.zhifa.study2025.flinkcdc.SQLSERVERMain" +``` + +## 贡献指南 + +欢迎贡献代码和改进!请遵循以下步骤: + +1. Fork 项目。 +2. 创建新分支 (`git checkout -b feature/your-feature-name`). +3. 提交更改 (`git commit -am 'Add some feature'`). +4. 推送分支 (`git push origin feature/your-feature-name`). +5. 提交 Pull Request. + +## 许可证 + +本项目遵循 MIT 许可证。详情请查看 [LICENSE](LICENSE) 文件。 \ No newline at end of file