This is an automated email from the ASF dual-hosted git repository. zhoubo pushed a commit to branch master in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
commit 24c083eccf9232b7ca7f18e0d0f236af2e68ba7f Merge: 386adcc 6708ada Author: odbozhou <[email protected]> AuthorDate: Wed Mar 2 11:19:42 2022 +0800 Add 'connector/rocketmq-connect-jdbc/' from commit '6708ada617d9f6cfef5ca42a3c2f97af44603a89' git-subtree-dir: connector/rocketmq-connect-jdbc git-subtree-mainline: 386adcc43bf32d201d8ea21ba9abfc653ef4ad17 git-subtree-split: 6708ada617d9f6cfef5ca42a3c2f97af44603a89 connector/rocketmq-connect-jdbc/README.md | 85 +++++ connector/rocketmq-connect-jdbc/pom.xml | 271 ++++++++++++++++ .../rocketmq/connect/jdbc/common/CloneUtils.java | 28 ++ .../rocketmq/connect/jdbc/common/ConstDefine.java | 23 ++ .../rocketmq/connect/jdbc/common/DBUtils.java | 212 ++++++++++++ .../apache/rocketmq/connect/jdbc/common/Utils.java | 74 +++++ .../rocketmq/connect/jdbc/config/Config.java | 357 +++++++++++++++++++++ .../rocketmq/connect/jdbc/config/ConfigUtil.java | 52 +++ .../rocketmq/connect/jdbc/config/DataType.java | 26 ++ .../connect/jdbc/config/DbConnectorConfig.java | 84 +++++ .../connect/jdbc/config/SinkDbConnectorConfig.java | 98 ++++++ .../jdbc/config/SourceDbConnectorConfig.java | 73 +++++ .../connect/jdbc/config/TaskDivideConfig.java | 112 +++++++ .../connect/jdbc/config/TaskTopicInfo.java | 37 +++ .../connect/jdbc/connector/JdbcSinkConnector.java | 221 +++++++++++++ .../connect/jdbc/connector/JdbcSinkTask.java | 134 ++++++++ .../jdbc/connector/JdbcSourceConnector.java | 105 ++++++ .../connect/jdbc/connector/JdbcSourceTask.java | 183 +++++++++++ .../rocketmq/connect/jdbc/schema/Database.java | 109 +++++++ .../rocketmq/connect/jdbc/schema/Schema.java | 123 +++++++ .../apache/rocketmq/connect/jdbc/schema/Table.java | 101 ++++++ .../jdbc/schema/column/BigIntColumnParser.java | 50 +++ .../connect/jdbc/schema/column/ColumnParser.java | 104 ++++++ .../jdbc/schema/column/DateTimeColumnParser.java | 53 +++ .../jdbc/schema/column/DefaultColumnParser.java | 37 +++ .../jdbc/schema/column/EnumColumnParser.java | 46 +++ .../jdbc/schema/column/IntColumnParser.java | 66 ++++ .../jdbc/schema/column/SetColumnParser.java | 54 ++++ .../jdbc/schema/column/StringColumnParser.java | 57 ++++ .../jdbc/schema/column/TimeColumnParser.java | 39 +++ .../jdbc/schema/column/YearColumnParser.java | 40 +++ .../apache/rocketmq/connect/jdbc/sink/Updater.java | 258 +++++++++++++++ .../rocketmq/connect/jdbc/source/Querier.java | 173 ++++++++++ .../jdbc/source/TimestampIncrementingQuerier.java | 311 ++++++++++++++++++ .../connect/jdbc/strategy/DivideStrategyEnum.java | 23 ++ .../connect/jdbc/strategy/DivideTaskByQueue.java | 72 +++++ .../connect/jdbc/strategy/DivideTaskByTopic.java | 113 +++++++ .../connect/jdbc/strategy/TaskDivideStrategy.java | 32 ++ .../jdbc/connector/JdbcSourceConnectorTest.java | 79 +++++ 39 files changed, 4115 insertions(+) diff --cc connector/rocketmq-connect-jdbc/README.md index 0000000,54c04ea..54c04ea mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/README.md +++ b/connector/rocketmq-connect-jdbc/README.md diff --cc connector/rocketmq-connect-jdbc/pom.xml index 0000000,2feaa22..2feaa22 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/pom.xml +++ b/connector/rocketmq-connect-jdbc/pom.xml diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/CloneUtils.java index 0000000,f0ff98e..f0ff98e mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/CloneUtils.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/CloneUtils.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/ConstDefine.java index 0000000,e6d2f7a..e6d2f7a mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/ConstDefine.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/ConstDefine.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DBUtils.java index 0000000,963fbf6..963fbf6 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DBUtils.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DBUtils.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/Utils.java index 0000000,5708e34..5708e34 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/Utils.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/Utils.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java index 0000000,1a9bbc9..1a9bbc9 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/Config.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/ConfigUtil.java index 0000000,53563f2..53563f2 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/ConfigUtil.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/ConfigUtil.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DataType.java index 0000000,ef7408a..ef7408a mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DataType.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DataType.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DbConnectorConfig.java index 0000000,43bd165..43bd165 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DbConnectorConfig.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/DbConnectorConfig.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SinkDbConnectorConfig.java index 0000000,26b1541..26b1541 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SinkDbConnectorConfig.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SinkDbConnectorConfig.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SourceDbConnectorConfig.java index 0000000,4972739..4972739 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SourceDbConnectorConfig.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/SourceDbConnectorConfig.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskDivideConfig.java index 0000000,8b15a2f..8b15a2f mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskDivideConfig.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskDivideConfig.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskTopicInfo.java index 0000000,5c2a21e..5c2a21e mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskTopicInfo.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/config/TaskTopicInfo.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkConnector.java index 0000000,53379ec..53379ec mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkConnector.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkConnector.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkTask.java index 0000000,31f43e3..31f43e3 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkTask.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkTask.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java index 0000000,ee62133..ee62133 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java index 0000000,f36623f..f36623f mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Database.java index 0000000,33a9a22..33a9a22 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Database.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Database.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java index 0000000,1cfaf2c..1cfaf2c mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Schema.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Table.java index 0000000,891fb9a..891fb9a mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Table.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/Table.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/BigIntColumnParser.java index 0000000,610f07d..610f07d mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/BigIntColumnParser.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/BigIntColumnParser.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnParser.java index 0000000,341064e..341064e mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnParser.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnParser.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DateTimeColumnParser.java index 0000000,c9b39e3..c9b39e3 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DateTimeColumnParser.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DateTimeColumnParser.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DefaultColumnParser.java index 0000000,ee3075a..ee3075a mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DefaultColumnParser.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/DefaultColumnParser.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/EnumColumnParser.java index 0000000,0fd14ba..0fd14ba mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/EnumColumnParser.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/EnumColumnParser.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/IntColumnParser.java index 0000000,36c6078..36c6078 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/IntColumnParser.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/IntColumnParser.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/SetColumnParser.java index 0000000,d1e6bbc..d1e6bbc mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/SetColumnParser.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/SetColumnParser.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/StringColumnParser.java index 0000000,cd4f04f..cd4f04f mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/StringColumnParser.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/StringColumnParser.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/TimeColumnParser.java index 0000000,9926d81..9926d81 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/TimeColumnParser.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/TimeColumnParser.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/YearColumnParser.java index 0000000,14cc798..14cc798 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/YearColumnParser.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/YearColumnParser.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/Updater.java index 0000000,9feffe6..9feffe6 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/Updater.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/Updater.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java index 0000000,03447a8..03447a8 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/Querier.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java index 0000000,0ab72df..0ab72df mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingQuerier.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideStrategyEnum.java index 0000000,0afa470..0afa470 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideStrategyEnum.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideStrategyEnum.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByQueue.java index 0000000,9d23fd2..9d23fd2 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByQueue.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByQueue.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByTopic.java index 0000000,5762795..5762795 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByTopic.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/DivideTaskByTopic.java diff --cc connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/TaskDivideStrategy.java index 0000000,736fcac..736fcac mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/TaskDivideStrategy.java +++ b/connector/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/strategy/TaskDivideStrategy.java diff --cc connector/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnectorTest.java index 0000000,5d25f98..5d25f98 mode 000000,100644..100644 --- a/connector/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnectorTest.java +++ b/connector/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnectorTest.java
