This is an automated email from the ASF dual-hosted git repository.
duanzhengqiang pushed a commit to branch master
in repository https://gitbox.apache.org/repos/asf/shardingsphere.git
The following commit(s) were added to refs/heads/master by this push:
new 1e3bdd95cd7 Refactor pipeline's it fixture (#29449)
1e3bdd95cd7 is described below
commit 1e3bdd95cd7966ca2b3f9553fbb290f2f902b6d3
Author: Liang Zhang <[email protected]>
AuthorDate: Tue Dec 19 19:03:21 2023 +0800
Refactor pipeline's it fixture (#29449)
* Remove FixtureIncrementalDumperCreator
* Rename H2ColumnValueReader
* Refactor pipeline's it fixture
* Refactor pipeline's it fixture
---
.../core/dump/ColumnValueReaderEngineTest.java | 2 +-
.../core/fixture/FixtureIncrementalDumper.java | 32 ---------------
.../fixture/FixtureIncrementalDumperCreator.java | 42 -------------------
.../FixturePipelineDataSourceConfiguration.java | 48 ----------------------
...ixtureSingleTableInventoryCalculatedResult.java | 38 -----------------
.../FixtureTableDataConsistencyChecker.java | 2 +-
.../FixtureTableInventoryChecker.java | 2 +-
.../FixtureTransmissionJobItemContext.java | 2 +-
.../checker/H2DataSourceChecker.java} | 7 +++-
.../datasource/H2JdbcQueryPropertiesExtension.java | 2 +-
.../dumper/H2ColumnValueReader.java} | 7 +++-
.../h2/dumper/H2IncrementalDumperCreator.java | 2 +-
.../ingest/position}/H2PositionInitializer.java | 5 ++-
.../h2/query/H2JDBCStreamQueryBuilder.java | 2 +-
.../{ => h2/sql}/H2CreateTableSQLGenerator.java | 2 +-
.../h2/sqlbuilder/H2PipelineSQLBuilder.java | 2 +-
.../core/importer/PipelineDataSourceSinkTest.java | 2 +-
....pipeline.core.checker.DialectDataSourceChecker | 2 +-
...sistencycheck.table.TableDataConsistencyChecker | 2 +-
...peline.core.query.DialectJDBCStreamQueryBuilder | 2 +-
...core.spi.ingest.dumper.DialectColumnValueReader | 2 +-
...core.spi.ingest.dumper.IncrementalDumperCreator | 3 +-
...ne.core.spi.ingest.position.PositionInitializer | 2 +-
...a.pipeline.core.spi.sql.CreateTableSQLGenerator | 2 +-
...pipeline.core.spi.sql.DialectPipelineSQLBuilder | 2 +-
....data.pipeline.spi.JdbcQueryPropertiesExtension | 2 +-
26 files changed, 33 insertions(+), 185 deletions(-)
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/dump/ColumnValueReaderEngineTest.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/dump/ColumnValueReaderEngineTest.java
index 67953b4d690..fe6f28a903f 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/dump/ColumnValueReaderEngineTest.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/dump/ColumnValueReaderEngineTest.java
@@ -36,7 +36,7 @@ class ColumnValueReaderEngineTest {
@Test
void assertReadValue() throws SQLException {
- ColumnValueReaderEngine columnValueReaderEngine = new
ColumnValueReaderEngine(TypedSPILoader.getService(DatabaseType.class,
"FIXTURE"));
+ ColumnValueReaderEngine columnValueReaderEngine = new
ColumnValueReaderEngine(TypedSPILoader.getService(DatabaseType.class, "H2"));
try (
HikariDataSource dataSource =
createDataSource(RandomStringUtils.randomAlphanumeric(6));
Connection connection = dataSource.getConnection()) {
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureIncrementalDumper.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureIncrementalDumper.java
deleted file mode 100644
index f24eb1bf541..00000000000
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureIncrementalDumper.java
+++ /dev/null
@@ -1,32 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.test.it.data.pipeline.core.fixture;
-
-import
org.apache.shardingsphere.data.pipeline.core.execute.AbstractPipelineLifecycleRunnable;
-import
org.apache.shardingsphere.data.pipeline.core.ingest.dumper.IncrementalDumper;
-
-public final class FixtureIncrementalDumper extends
AbstractPipelineLifecycleRunnable implements IncrementalDumper {
-
- @Override
- protected void runBlocking() {
- }
-
- @Override
- protected void doStop() {
- }
-}
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureIncrementalDumperCreator.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureIncrementalDumperCreator.java
deleted file mode 100644
index db1a8327ac8..00000000000
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureIncrementalDumperCreator.java
+++ /dev/null
@@ -1,42 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.test.it.data.pipeline.core.fixture;
-
-import
org.apache.shardingsphere.data.pipeline.core.ingest.dumper.context.IncrementalDumperContext;
-import
org.apache.shardingsphere.data.pipeline.core.ingest.channel.PipelineChannel;
-import
org.apache.shardingsphere.data.pipeline.core.ingest.dumper.IncrementalDumper;
-import
org.apache.shardingsphere.data.pipeline.core.ingest.position.IngestPosition;
-import
org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTableMetaDataLoader;
-import
org.apache.shardingsphere.data.pipeline.core.spi.ingest.dumper.IncrementalDumperCreator;
-
-/**
- * Fixture incremental dumper creator.
- */
-public final class FixtureIncrementalDumperCreator implements
IncrementalDumperCreator {
-
- @Override
- public IncrementalDumper createIncrementalDumper(final
IncrementalDumperContext context, final IngestPosition position,
- final PipelineChannel
channel, final PipelineTableMetaDataLoader metaDataLoader) {
- return new FixtureIncrementalDumper();
- }
-
- @Override
- public String getDatabaseType() {
- return "Fixture";
- }
-}
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixturePipelineDataSourceConfiguration.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixturePipelineDataSourceConfiguration.java
deleted file mode 100644
index 44ba69aa4fb..00000000000
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixturePipelineDataSourceConfiguration.java
+++ /dev/null
@@ -1,48 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.test.it.data.pipeline.core.fixture;
-
-import lombok.RequiredArgsConstructor;
-import
org.apache.shardingsphere.data.pipeline.api.PipelineDataSourceConfiguration;
-import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
-
-@RequiredArgsConstructor
-public final class FixturePipelineDataSourceConfiguration implements
PipelineDataSourceConfiguration {
-
- private final DatabaseType databaseType;
-
- @Override
- public String getParameter() {
- return null;
- }
-
- @Override
- public Object getDataSourceConfiguration() {
- return null;
- }
-
- @Override
- public DatabaseType getDatabaseType() {
- return databaseType;
- }
-
- @Override
- public String getType() {
- return "FIXTURE";
- }
-}
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureSingleTableInventoryCalculatedResult.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureSingleTableInventoryCalculatedResult.java
deleted file mode 100644
index ef1f39b791d..00000000000
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureSingleTableInventoryCalculatedResult.java
+++ /dev/null
@@ -1,38 +0,0 @@
-/*
- * Licensed to the Apache Software Foundation (ASF) under one or more
- * contributor license agreements. See the NOTICE file distributed with
- * this work for additional information regarding copyright ownership.
- * The ASF licenses this file to You under the Apache License, Version 2.0
- * (the "License"); you may not use this file except in compliance with
- * the License. You may obtain a copy of the License at
- *
- * http://www.apache.org/licenses/LICENSE-2.0
- *
- * Unless required by applicable law or agreed to in writing, software
- * distributed under the License is distributed on an "AS IS" BASIS,
- * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
- * See the License for the specific language governing permissions and
- * limitations under the License.
- */
-
-package org.apache.shardingsphere.test.it.data.pipeline.core.fixture;
-
-import lombok.EqualsAndHashCode;
-import lombok.Getter;
-import lombok.RequiredArgsConstructor;
-import
org.apache.shardingsphere.data.pipeline.core.consistencycheck.result.SingleTableInventoryCalculatedResult;
-
-import java.util.Optional;
-
-@RequiredArgsConstructor
-@EqualsAndHashCode
-@Getter
-public final class FixtureSingleTableInventoryCalculatedResult implements
SingleTableInventoryCalculatedResult {
-
- private final int recordsCount;
-
- @Override
- public Optional<Object> getMaxUniqueKeyValue() {
- return Optional.empty();
- }
-}
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureTableDataConsistencyChecker.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/algorithm/FixtureTableDataConsistencyChecker.java
similarity index 99%
rename from
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureTableDataConsistencyChecker.java
rename to
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/algorithm/FixtureTableDataConsistencyChecker.java
index fdcc39f5120..e3c91fa12b9 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureTableDataConsistencyChecker.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/algorithm/FixtureTableDataConsistencyChecker.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.test.it.data.pipeline.core.fixture;
+package org.apache.shardingsphere.test.it.data.pipeline.core.fixture.algorithm;
import
org.apache.shardingsphere.data.pipeline.core.consistencycheck.table.TableDataConsistencyChecker;
import
org.apache.shardingsphere.data.pipeline.core.consistencycheck.table.TableInventoryCheckParameter;
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureTableInventoryChecker.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/algorithm/FixtureTableInventoryChecker.java
similarity index 98%
rename from
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureTableInventoryChecker.java
rename to
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/algorithm/FixtureTableInventoryChecker.java
index 18ea7820581..7f781020566 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureTableInventoryChecker.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/algorithm/FixtureTableInventoryChecker.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.test.it.data.pipeline.core.fixture;
+package org.apache.shardingsphere.test.it.data.pipeline.core.fixture.algorithm;
import
org.apache.shardingsphere.data.pipeline.core.consistencycheck.result.TableDataConsistencyCheckResult;
import
org.apache.shardingsphere.data.pipeline.core.consistencycheck.table.TableInventoryChecker;
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureTransmissionJobItemContext.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/algorithm/FixtureTransmissionJobItemContext.java
similarity index 99%
rename from
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureTransmissionJobItemContext.java
rename to
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/algorithm/FixtureTransmissionJobItemContext.java
index 4f26c4a0b9b..23ed37f9ec1 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureTransmissionJobItemContext.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/algorithm/FixtureTransmissionJobItemContext.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.test.it.data.pipeline.core.fixture;
+package org.apache.shardingsphere.test.it.data.pipeline.core.fixture.algorithm;
import
org.apache.shardingsphere.data.pipeline.core.metadata.loader.PipelineTableMetaDataLoader;
import
org.apache.shardingsphere.data.pipeline.core.job.config.PipelineJobConfiguration;
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureDataSourceChecker.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/checker/H2DataSourceChecker.java
similarity index 90%
rename from
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureDataSourceChecker.java
rename to
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/checker/H2DataSourceChecker.java
index 23018527cf3..a6b4aab6dbd 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureDataSourceChecker.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/checker/H2DataSourceChecker.java
@@ -15,13 +15,16 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.test.it.data.pipeline.core.fixture;
+package
org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.checker;
import
org.apache.shardingsphere.data.pipeline.core.checker.DialectDataSourceChecker;
import javax.sql.DataSource;
-public final class FixtureDataSourceChecker implements
DialectDataSourceChecker {
+/**
+ * Data source checker for H2.
+ */
+public final class H2DataSourceChecker implements DialectDataSourceChecker {
@Override
public void checkPrivilege(final DataSource dataSource) {
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/datasource/H2JdbcQueryPropertiesExtension.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/datasource/H2JdbcQueryPropertiesExtension.java
similarity index 94%
rename from
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/datasource/H2JdbcQueryPropertiesExtension.java
rename to
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/datasource/H2JdbcQueryPropertiesExtension.java
index 2ea976ed351..7fe66ab9a15 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/datasource/H2JdbcQueryPropertiesExtension.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/datasource/H2JdbcQueryPropertiesExtension.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.test.it.data.pipeline.h2.datasource;
+package
org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.datasource;
import
org.apache.shardingsphere.data.pipeline.spi.JdbcQueryPropertiesExtension;
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureColumnValueReader.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/dumper/H2ColumnValueReader.java
similarity index 90%
rename from
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureColumnValueReader.java
rename to
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/dumper/H2ColumnValueReader.java
index e733cd2be7e..c5a19be4ea5 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/FixtureColumnValueReader.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/dumper/H2ColumnValueReader.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.test.it.data.pipeline.core.fixture;
+package org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.dumper;
import
org.apache.shardingsphere.data.pipeline.core.spi.ingest.dumper.DialectColumnValueReader;
@@ -23,7 +23,10 @@ import java.sql.ResultSet;
import java.sql.ResultSetMetaData;
import java.util.Optional;
-public final class FixtureColumnValueReader implements
DialectColumnValueReader {
+/**
+ * Column value reader for H2.
+ */
+public final class H2ColumnValueReader implements DialectColumnValueReader {
@Override
public Optional<Object> read(final ResultSet resultSet, final
ResultSetMetaData metaData, final int columnIndex) {
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/dumper/H2IncrementalDumperCreator.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/dumper/H2IncrementalDumperCreator.java
similarity index 96%
rename from
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/dumper/H2IncrementalDumperCreator.java
rename to
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/dumper/H2IncrementalDumperCreator.java
index f79975af6df..72f290882f7 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/dumper/H2IncrementalDumperCreator.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/dumper/H2IncrementalDumperCreator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.test.it.data.pipeline.h2.dumper;
+package org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.dumper;
import
org.apache.shardingsphere.data.pipeline.core.ingest.dumper.context.IncrementalDumperContext;
import
org.apache.shardingsphere.data.pipeline.core.ingest.channel.PipelineChannel;
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/H2PositionInitializer.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/ingest/position/H2PositionInitializer.java
similarity index 95%
rename from
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/H2PositionInitializer.java
rename to
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/ingest/position/H2PositionInitializer.java
index 4583f2f1332..0d7ddcfd111 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/H2PositionInitializer.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/ingest/position/H2PositionInitializer.java
@@ -15,13 +15,16 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.test.it.data.pipeline.core.fixture;
+package
org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.ingest.position;
import
org.apache.shardingsphere.data.pipeline.core.ingest.position.PlaceholderPosition;
import
org.apache.shardingsphere.data.pipeline.core.spi.ingest.position.PositionInitializer;
import javax.sql.DataSource;
+/**
+ * Position initializer for H2.
+ */
public final class H2PositionInitializer implements PositionInitializer {
@Override
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/query/H2JDBCStreamQueryBuilder.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/query/H2JDBCStreamQueryBuilder.java
similarity index 95%
rename from
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/query/H2JDBCStreamQueryBuilder.java
rename to
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/query/H2JDBCStreamQueryBuilder.java
index 095cc8af6f9..04f2d6e6228 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/query/H2JDBCStreamQueryBuilder.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/query/H2JDBCStreamQueryBuilder.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.test.it.data.pipeline.h2.query;
+package org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.query;
import
org.apache.shardingsphere.data.pipeline.core.query.DialectJDBCStreamQueryBuilder;
import org.apache.shardingsphere.infra.database.core.type.DatabaseType;
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/H2CreateTableSQLGenerator.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/sql/H2CreateTableSQLGenerator.java
similarity index 99%
rename from
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/H2CreateTableSQLGenerator.java
rename to
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/sql/H2CreateTableSQLGenerator.java
index d1ddacf733e..29a771630d8 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/H2CreateTableSQLGenerator.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/sql/H2CreateTableSQLGenerator.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.test.it.data.pipeline.core.fixture;
+package org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.sql;
import
org.apache.shardingsphere.data.pipeline.core.exception.syntax.CreateTableSQLGenerateException;
import
org.apache.shardingsphere.data.pipeline.core.spi.sql.CreateTableSQLGenerator;
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/sqlbuilder/H2PipelineSQLBuilder.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/sqlbuilder/H2PipelineSQLBuilder.java
similarity index 93%
rename from
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/sqlbuilder/H2PipelineSQLBuilder.java
rename to
test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/sqlbuilder/H2PipelineSQLBuilder.java
index 5780cd6f380..e848883d8cd 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/h2/sqlbuilder/H2PipelineSQLBuilder.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/fixture/h2/sqlbuilder/H2PipelineSQLBuilder.java
@@ -15,7 +15,7 @@
* limitations under the License.
*/
-package org.apache.shardingsphere.test.it.data.pipeline.h2.sqlbuilder;
+package
org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.sqlbuilder;
import
org.apache.shardingsphere.data.pipeline.core.spi.sql.DialectPipelineSQLBuilder;
diff --git
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/importer/PipelineDataSourceSinkTest.java
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/importer/PipelineDataSourceSinkTest.java
index 53a9cecc8db..2044fedd11f 100644
---
a/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/importer/PipelineDataSourceSinkTest.java
+++
b/test/it/pipeline/src/test/java/org/apache/shardingsphere/test/it/data/pipeline/core/importer/PipelineDataSourceSinkTest.java
@@ -35,7 +35,7 @@ import
org.apache.shardingsphere.data.pipeline.core.ingest.record.Column;
import org.apache.shardingsphere.data.pipeline.core.ingest.record.DataRecord;
import
org.apache.shardingsphere.data.pipeline.core.ingest.record.FinishedRecord;
import org.apache.shardingsphere.data.pipeline.core.ingest.record.Record;
-import
org.apache.shardingsphere.test.it.data.pipeline.core.fixture.FixtureTransmissionJobItemContext;
+import
org.apache.shardingsphere.test.it.data.pipeline.core.fixture.algorithm.FixtureTransmissionJobItemContext;
import org.junit.jupiter.api.BeforeEach;
import org.junit.jupiter.api.Test;
import org.junit.jupiter.api.extension.ExtendWith;
diff --git
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.checker.DialectDataSourceChecker
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.checker.DialectDataSourceChecker
index 55507f721c9..373a49fdbf4 100644
---
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.checker.DialectDataSourceChecker
+++
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.checker.DialectDataSourceChecker
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.test.it.data.pipeline.core.fixture.FixtureDataSourceChecker
+org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.checker.H2DataSourceChecker
diff --git
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.consistencycheck.table.TableDataConsistencyChecker
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.consistencycheck.table.TableDataConsistencyChecker
index b771deadee2..7ea0f1c8dd4 100644
---
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.consistencycheck.table.TableDataConsistencyChecker
+++
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.consistencycheck.table.TableDataConsistencyChecker
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.test.it.data.pipeline.core.fixture.FixtureTableDataConsistencyChecker
+org.apache.shardingsphere.test.it.data.pipeline.core.fixture.algorithm.FixtureTableDataConsistencyChecker
diff --git
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.query.DialectJDBCStreamQueryBuilder
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.query.DialectJDBCStreamQueryBuilder
index 5c7e1bda537..44942e01e86 100644
---
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.query.DialectJDBCStreamQueryBuilder
+++
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.query.DialectJDBCStreamQueryBuilder
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.test.it.data.pipeline.h2.query.H2JDBCStreamQueryBuilder
+org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.query.H2JDBCStreamQueryBuilder
diff --git
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.dumper.DialectColumnValueReader
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.dumper.DialectColumnValueReader
index 6d2c2645d60..0349750b070 100644
---
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.dumper.DialectColumnValueReader
+++
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.dumper.DialectColumnValueReader
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.test.it.data.pipeline.core.fixture.FixtureColumnValueReader
+org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.dumper.H2ColumnValueReader
diff --git
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.dumper.IncrementalDumperCreator
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.dumper.IncrementalDumperCreator
index f0a701d1e03..0cbb3fc871a 100644
---
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.dumper.IncrementalDumperCreator
+++
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.dumper.IncrementalDumperCreator
@@ -15,5 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.test.it.data.pipeline.core.fixture.FixtureIncrementalDumperCreator
-org.apache.shardingsphere.test.it.data.pipeline.h2.dumper.H2IncrementalDumperCreator
+org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.dumper.H2IncrementalDumperCreator
diff --git
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.position.PositionInitializer
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.position.PositionInitializer
index 3814bacb8c5..ca7d3d426fc 100644
---
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.position.PositionInitializer
+++
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.ingest.position.PositionInitializer
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.test.it.data.pipeline.core.fixture.H2PositionInitializer
+org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.ingest.position.H2PositionInitializer
diff --git
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.sql.CreateTableSQLGenerator
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.sql.CreateTableSQLGenerator
index ebe233712dc..33ec905f699 100644
---
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.sql.CreateTableSQLGenerator
+++
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.sql.CreateTableSQLGenerator
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.test.it.data.pipeline.core.fixture.H2CreateTableSQLGenerator
+org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.sql.H2CreateTableSQLGenerator
diff --git
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.sql.DialectPipelineSQLBuilder
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.sql.DialectPipelineSQLBuilder
index c4428dae026..b8ff88f0766 100644
---
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.sql.DialectPipelineSQLBuilder
+++
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.core.spi.sql.DialectPipelineSQLBuilder
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.test.it.data.pipeline.h2.sqlbuilder.H2PipelineSQLBuilder
+org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.sqlbuilder.H2PipelineSQLBuilder
diff --git
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.JdbcQueryPropertiesExtension
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.JdbcQueryPropertiesExtension
index 378f8cb196d..8b3c1312975 100644
---
a/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.JdbcQueryPropertiesExtension
+++
b/test/it/pipeline/src/test/resources/META-INF/services/org.apache.shardingsphere.data.pipeline.spi.JdbcQueryPropertiesExtension
@@ -15,4 +15,4 @@
# limitations under the License.
#
-org.apache.shardingsphere.test.it.data.pipeline.h2.datasource.H2JdbcQueryPropertiesExtension
+org.apache.shardingsphere.test.it.data.pipeline.core.fixture.h2.datasource.H2JdbcQueryPropertiesExtension
