This is an automated email from the ASF dual-hosted git repository.
zhoubo pushed a change to branch master
in repository https://gitbox.apache.org/repos/asf/rocketmq-connect.git
from 6b6a6be5 [ISSUE #399]Debezium sopport heartbeat record (#401)
add 7f9a2203 [ISSUE #389]Optimize connector jdbc (#402)
No new revisions were added by this update.
Summary of changes:
connectors/rocketmq-connect-doris/README.txt | 4 +-
connectors/rocketmq-connect-jdbc/README.md | 2 +-
connectors/rocketmq-connect-jdbc/pom.xml | 256 ++++++--------
.../rocketmq-connect-jdbc-core}/pom.xml | 72 ++--
.../connect/jdbc/common/DebeziumTimeTypes.java | 14 -
.../rocketmq/connect/jdbc/common/HeaderField.java | 8 +-
.../jdbc/common/JdbcSourceConfigConstants.java | 0
.../connect/jdbc/config/AbstractConfig.java | 0
.../rocketmq/connect/jdbc/config/ConfigDef.java | 2 +
.../connect/jdbc/dialect/DatabaseDialect.java | 29 +-
.../rocketmq/connect/jdbc/dialect/DropOptions.java | 0
.../jdbc/dialect}/GenericDatabaseDialect.java | 302 +++++++++--------
.../jdbc/dialect/PreparedStatementBinder.java | 58 +++-
.../dialect/provider/CachedConnectionProvider.java | 2 -
.../jdbc/dialect/provider/ConnectionProvider.java | 0
.../connect/jdbc/exception/ConfigException.java | 0
.../exception/TableAlterOrCreateException.java | 0
.../jdbc/schema/column/ColumnDefAdjuster.java | 0
.../jdbc/schema/column/ColumnDefinition.java | 0
.../connect/jdbc/schema/column/ColumnId.java | 2 +-
.../connect/jdbc/schema/db/DbStructure.java | 10 +-
.../connect/jdbc/schema/table/TableDefinition.java | 0
.../jdbc/schema/table/TableDefinitions.java | 0
.../connect/jdbc/schema/table/TableId.java | 0
.../connect/jdbc/sink/BaseSinkConnector.java} | 14 +-
.../rocketmq/connect/jdbc/sink/BaseSinkTask.java} | 60 ++--
.../connect/jdbc/sink/BufferedRecords.java | 219 ++++++++++++
.../connect/jdbc/sink}/JdbcSinkConfig.java | 14 +-
.../rocketmq/connect/jdbc/sink/JdbcWriter.java} | 11 +-
.../connect/jdbc}/sink/RecordValidator.java | 41 ++-
.../connect/jdbc/sink/metadata/FieldsMetadata.java | 9 +-
.../connect/jdbc/sink/metadata/SchemaPair.java | 0
.../jdbc/sink/metadata/SinkRecordField.java | 3 +-
.../connect/jdbc/source/BaseSourceConnector.java} | 20 +-
.../connect/jdbc/source/BaseSourceTask.java} | 19 +-
.../connect/jdbc/source}/JdbcSourceConfig.java | 2 +-
.../connect/jdbc/source}/JdbcSourceTaskConfig.java | 2 +-
.../jdbc/source/TimestampIncrementingCriteria.java | 17 -
.../jdbc/source/metadata/ColumnMapping.java | 0
.../jdbc/source/metadata/SchemaMapping.java | 0
.../jdbc/source/offset/SourceOffsetCompute.java | 7 +-
.../source/offset/TimestampIncrementingOffset.java | 0
.../connect/jdbc/source/querier/BulkQuerier.java | 0
.../connect/jdbc/source/querier/Querier.java | 0
.../querier/TimestampIncrementingQuerier.java | 0
.../rocketmq/connect/jdbc/util/BytesUtil.java | 1 +
.../connect/jdbc/util/ConnectorGroupUtils.java | 0
.../rocketmq/connect/jdbc/util/DateTimeUtils.java | 0
.../connect/jdbc/util/ExpressionBuilder.java | 0
.../connect/jdbc/util/IdentifierRules.java | 0
.../rocketmq/connect/jdbc/util/JdbcDriverInfo.java | 0
.../rocketmq/connect/jdbc/util/NumericMapping.java | 2 +-
.../rocketmq/connect/jdbc/util/QuoteMethod.java | 0
.../rocketmq/connect/jdbc/util/TableType.java | 0
...t.jdbc.dialect.provider.DatabaseDialectProvider | 2 +-
.../connect/jdbc/connector/sink/JdbcSinkTest.java | 0
.../jdbc/connector/sink/OpenMLDBJdbcSinkTest.java | 119 +++++++
.../connector/source/JdbcSourceConnectorTest.java | 0
.../jdbc/connector/source/JdbcSourceTaskTest.java | 4 +-
.../rocketmq-connect-jdbc-mysql}/pom.xml | 30 +-
.../jdbc/mysql/dialect}/MySqlDatabaseDialect.java | 20 +-
.../jdbc/mysql/sink/MysqlJdbcSinkConnector.java} | 22 +-
.../jdbc/mysql/sink/MysqlJdbcSinkTask.java} | 18 +-
.../mysql/source/MysqlJdbcSourceConnector.java} | 16 +-
.../jdbc/mysql/source/MysqlJdbcSourceTask.java} | 24 +-
.../src/main/resources/mysql-jdbc-sink.conf | 18 +
.../src/main/resources/mysql-jdbc-source.conf | 15 +
.../rocketmq-connect-jdbc-openmldb}/pom.xml | 51 ++-
.../openmldb/dialect}/OpenMLDBDatabaseDialect.java | 20 +-
.../openmldb/sink/OpenMLDBJdbcSinkConnector.java} | 16 +-
.../jdbc/openmldb/sink/OpenMLDBJdbcSinkTask.java} | 24 +-
.../src/main/resources/openmldb-jdbc-sink.conf} | 0
.../rocketmq/connect/jdbc/common/Dialect.java | 45 ---
.../rocketmq/connect/jdbc/common/DialectType.java | 25 --
.../rocketmq/connect/jdbc/common/OperatorType.java | 26 --
.../jdbc/dialect/DatabaseDialectFactory.java | 194 -----------
.../dialect/provider/DatabaseDialectProvider.java | 60 ----
.../connect/jdbc/dialect/provider/JdbcUrlInfo.java | 42 ---
.../schema/column/parser/DateColumnParser.java | 61 ----
.../schema/column/parser/TimeColumnParser.java | 63 ----
.../column/parser/TimestampColumnParser.java | 54 ---
.../connect/jdbc/sink/BufferedRecords.java | 377 ---------------------
.../connect/jdbc/sink/RecordValidator.java | 100 ------
.../dialect/DatabaseDialectFactoryTest.java | 16 -
.../jdbc/connector/sink/OpenMLDBJdbcSinkTest.java | 144 --------
.../src/main/resources/avro-sink.template | 2 +-
.../src/main/resources/avro-source.template | 2 +-
.../src/main/resources/json-sink.template | 2 +-
.../src/main/resources/json-source.template | 2 +-
89 files changed, 950 insertions(+), 1866 deletions(-)
copy {rocketmq-connect-sample =>
connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-core}/pom.xml (59%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/common/DebeziumTimeTypes.java
(79%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/common/HeaderField.java
(84%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/common/JdbcSourceConfigConstants.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/config/AbstractConfig.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/config/ConfigDef.java
(99%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialect.java
(93%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DropOptions.java
(100%)
rename
connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/dialect/impl
=>
rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/dialect}/GenericDatabaseDialect.java
(91%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/PreparedStatementBinder.java
(72%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/provider/CachedConnectionProvider.java
(99%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/provider/ConnectionProvider.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/exception/ConfigException.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/exception/TableAlterOrCreateException.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefAdjuster.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnDefinition.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/ColumnId.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/db/DbStructure.java
(97%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinition.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableDefinitions.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/schema/table/TableId.java
(100%)
rename
connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkConnector.java
=>
rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BaseSinkConnector.java}
(81%)
rename
connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSinkTask.java
=>
rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BaseSinkTask.java}
(77%)
create mode 100644
connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java
rename
connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector
=>
rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/sink}/JdbcSinkConfig.java
(97%)
rename
connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/sink/Updater.java
=>
rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/sink/JdbcWriter.java}
(92%)
copy
connectors/{rocketmq-connect-doris/src/main/java/org/apache/rocketmq/connect/doris
=>
rocketmq-connect-jdbc/rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc}/sink/RecordValidator.java
(91%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/FieldsMetadata.java
(97%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SchemaPair.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/sink/metadata/SinkRecordField.java
(97%)
rename
connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceConnector.java
=>
rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/source/BaseSourceConnector.java}
(89%)
rename
connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector/JdbcSourceTask.java
=>
rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/source/BaseSourceTask.java}
(94%)
rename
connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector
=>
rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/source}/JdbcSourceConfig.java
(99%)
rename
connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/connector
=>
rocketmq-connect-jdbc-core/src/main/java/org/apache/rocketmq/connect/jdbc/source}/JdbcSourceTaskConfig.java
(96%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/TimestampIncrementingCriteria.java
(92%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/metadata/ColumnMapping.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/metadata/SchemaMapping.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/SourceOffsetCompute.java
(98%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/offset/TimestampIncrementingOffset.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/BulkQuerier.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/Querier.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/source/querier/TimestampIncrementingQuerier.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/BytesUtil.java
(99%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/ConnectorGroupUtils.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/DateTimeUtils.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/ExpressionBuilder.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/IdentifierRules.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/JdbcDriverInfo.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/NumericMapping.java
(96%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/QuoteMethod.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/java/org/apache/rocketmq/connect/jdbc/util/TableType.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/main/resources/META-INF/services/org.apache.rocketmq.connect.jdbc.dialect.provider.DatabaseDialectProvider
(60%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/test/java/org/apache/rocketmq/connect/jdbc/connector/sink/JdbcSinkTest.java
(100%)
create mode 100644
connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-core/src/test/java/org/apache/rocketmq/connect/jdbc/connector/sink/OpenMLDBJdbcSinkTest.java
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/test/java/org/apache/rocketmq/connect/jdbc/connector/source/JdbcSourceConnectorTest.java
(100%)
rename connectors/rocketmq-connect-jdbc/{ =>
rocketmq-connect-jdbc-core}/src/test/java/org/apache/rocketmq/connect/jdbc/connector/source/JdbcSourceTaskTest.java
(74%)
copy {reporter-api =>
connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql}/pom.xml (87%)
rename
connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/dialect/impl
=>
rocketmq-connect-jdbc-mysql/src/main/java/org/apache/rocketmq/connect/jdbc/mysql/dialect}/MySqlDatabaseDialect.java
(87%)
copy
connectors/{rocketmq-connect-cassandra/src/main/java/org/apache/rocketmq/connect/cassandra/schema/column/BooleanColumnParser.java
=>
rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/java/org/apache/rocketmq/connect/jdbc/mysql/sink/MysqlJdbcSinkConnector.java}
(69%)
copy
connectors/{rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/FlushAllParser.java
=>
rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/java/org/apache/rocketmq/connect/jdbc/mysql/sink/MysqlJdbcSinkTask.java}
(62%)
copy
connectors/{rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java
=>
rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/java/org/apache/rocketmq/connect/jdbc/mysql/source/MysqlJdbcSourceConnector.java}
(69%)
copy
connectors/{rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java
=>
rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/java/org/apache/rocketmq/connect/jdbc/mysql/source/MysqlJdbcSourceTask.java}
(61%)
create mode 100644
connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/resources/mysql-jdbc-sink.conf
create mode 100644
connectors/rocketmq-connect-jdbc/rocketmq-connect-jdbc-mysql/src/main/resources/mysql-jdbc-source.conf
copy connectors/{rocketmq-connect-debezium/rocketmq-connect-debezium-mongodb
=> rocketmq-connect-jdbc/rocketmq-connect-jdbc-openmldb}/pom.xml (85%)
rename
connectors/rocketmq-connect-jdbc/{src/main/java/org/apache/rocketmq/connect/jdbc/dialect/impl
=>
rocketmq-connect-jdbc-openmldb/src/main/java/org/apache/rocketmq/connect/jdbc/openmldb/dialect}/OpenMLDBDatabaseDialect.java
(88%)
copy
connectors/{rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/ScriptParser.java
=>
rocketmq-connect-jdbc/rocketmq-connect-jdbc-openmldb/src/main/java/org/apache/rocketmq/connect/jdbc/openmldb/sink/OpenMLDBJdbcSinkConnector.java}
(69%)
copy
connectors/{rocketmq-connect-redis/src/main/java/org/apache/rocketmq/connect/redis/parser/AppendParser.java
=>
rocketmq-connect-jdbc/rocketmq-connect-jdbc-openmldb/src/main/java/org/apache/rocketmq/connect/jdbc/openmldb/sink/OpenMLDBJdbcSinkTask.java}
(60%)
copy connectors/{rocketmq-connect-debezium/README.md =>
rocketmq-connect-jdbc/rocketmq-connect-jdbc-openmldb/src/main/resources/openmldb-jdbc-sink.conf}
(100%)
delete mode 100644
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/Dialect.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/DialectType.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/common/OperatorType.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/DatabaseDialectFactory.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/provider/DatabaseDialectProvider.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/dialect/provider/JdbcUrlInfo.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/parser/DateColumnParser.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/parser/TimeColumnParser.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/schema/column/parser/TimestampColumnParser.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/BufferedRecords.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/main/java/org/apache/rocketmq/connect/jdbc/sink/RecordValidator.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/dialect/DatabaseDialectFactoryTest.java
delete mode 100644
connectors/rocketmq-connect-jdbc/src/test/java/org/apache/rocketmq/connect/jdbc/connector/sink/OpenMLDBJdbcSinkTest.java
