alexey.rassokhin/tet123
1
0
Fork 0
Code Issues Pull Requests 1 Packages Projects Releases Wiki Activity

DBZ-7223 Move sink tests into a separate package

Browse Source
This commit is contained in:
Jiri Pechanec 2024-07-04 06:52:53 +02:00
parent 143e8c3208
commit 1f245b9c87
3 changed files with 9 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/SinkConnectorIT.java → debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/sink/SinkConnectorIT.java
View File

@ -3,9 +3,7 @@
*
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/
package io.debezium.connector.mongodb;
import static io.debezium.testing.testcontainers.testhelper.TestInfrastructureHelper.DATABASE;
package io.debezium.connector.mongodb.sink;
import java.util.ArrayList;
import java.util.Arrays;
@ -23,11 +21,14 @@
import io.debezium.config.CommonConnectorConfig;
import io.debezium.config.Configuration;
import io.debezium.connector.mongodb.sink.MongoDbSinkConnectorConfig;
import io.debezium.connector.mongodb.Module;
import io.debezium.connector.mongodb.MongoDbSinkConnector;
import io.debezium.connector.mongodb.TestHelper;
import io.debezium.testing.testcontainers.Connector;
import io.debezium.testing.testcontainers.ConnectorConfiguration;
import io.debezium.testing.testcontainers.MongoDbDeployment;
import io.debezium.testing.testcontainers.testhelper.TestInfrastructureHelper;
import io.debezium.testing.testcontainers.testhelper.TestInfrastructureHelper.DATABASE;
public interface SinkConnectorIT {

3
debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/SinkConnectorReplicaSetIT.java → debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/sink/SinkConnectorReplicaSetIT.java
View File

@ -3,7 +3,7 @@
*
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/
package io.debezium.connector.mongodb;
package io.debezium.connector.mongodb.sink;
import static io.debezium.connector.mongodb.TestHelper.cleanDatabase;
import static org.hamcrest.CoreMatchers.is;
@ -15,6 +15,7 @@
import org.junit.BeforeClass;
import org.junit.Test;
import io.debezium.connector.mongodb.AbstractMongoConnectorIT;
import io.debezium.connector.mongodb.junit.MongoDbDatabaseProvider;
import io.debezium.testing.testcontainers.MongoDbDeployment;
import io.debezium.testing.testcontainers.testhelper.TestInfrastructureHelper;

3
debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/SinkConnectorShardedClusterIT.java → debezium-connector-mongodb/src/test/java/io/debezium/connector/mongodb/sink/SinkConnectorShardedClusterIT.java
View File

@ -3,7 +3,7 @@
*
* Licensed under the Apache Software License version 2.0, available at http://www.apache.org/licenses/LICENSE-2.0
*/
package io.debezium.connector.mongodb;
package io.debezium.connector.mongodb.sink;
import static io.debezium.connector.mongodb.TestHelper.cleanDatabase;
import static org.hamcrest.CoreMatchers.is;
@ -15,6 +15,7 @@
import org.junit.BeforeClass;
import org.junit.Test;
import io.debezium.connector.mongodb.AbstractShardedMongoConnectorIT;
import io.debezium.connector.mongodb.junit.MongoDbDatabaseProvider;
import io.debezium.connector.mongodb.junit.MongoDbDatabaseVersionResolver;
import io.debezium.connector.mongodb.junit.MongoDbPlatform;