Skip to content

Commit b377667

Browse files
authored
fix mysql integration tests (#5369)
* fix mysql integration tests * refactor
1 parent 057bad4 commit b377667

File tree

3 files changed

+6
-1
lines changed

3 files changed

+6
-1
lines changed

airbyte-integrations/connectors/source-mysql/src/test-integration/java/io/airbyte/integrations/source/mysql/CdcMySqlSourceAcceptanceTest.java

Lines changed: 2 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
import io.airbyte.commons.resources.MoreResources;
3232
import io.airbyte.db.Database;
3333
import io.airbyte.db.Databases;
34+
import io.airbyte.integrations.source.mysql.MySqlSource.ReplicationMethod;
3435
import io.airbyte.integrations.standardtest.source.SourceAcceptanceTest;
3536
import io.airbyte.integrations.standardtest.source.TestDestinationEnv;
3637
import io.airbyte.protocol.models.CatalogHelpers;
@@ -118,7 +119,7 @@ protected void setupEnvironment(TestDestinationEnv environment) {
118119
.put("database", container.getDatabaseName())
119120
.put("username", container.getUsername())
120121
.put("password", container.getPassword())
121-
.put("replication_method", "CDC")
122+
.put("replication_method", ReplicationMethod.CDC)
122123
.build());
123124

124125
revokeAllPermissions();

airbyte-integrations/connectors/source-mysql/src/test-integration/java/io/airbyte/integrations/source/mysql/MySqlSourceAcceptanceTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -31,6 +31,7 @@
3131
import io.airbyte.commons.resources.MoreResources;
3232
import io.airbyte.db.Database;
3333
import io.airbyte.db.Databases;
34+
import io.airbyte.integrations.source.mysql.MySqlSource.ReplicationMethod;
3435
import io.airbyte.integrations.standardtest.source.SourceAcceptanceTest;
3536
import io.airbyte.integrations.standardtest.source.TestDestinationEnv;
3637
import io.airbyte.protocol.models.CatalogHelpers;
@@ -66,6 +67,7 @@ protected void setupEnvironment(TestDestinationEnv environment) throws Exception
6667
.put("database", container.getDatabaseName())
6768
.put("username", container.getUsername())
6869
.put("password", container.getPassword())
70+
.put("replication_method", ReplicationMethod.STANDARD)
6971
.build());
7072

7173
final Database database = Databases.createDatabase(

airbyte-integrations/connectors/source-mysql/src/test-integration/java/io/airbyte/integrations/source/mysql/MySqlSourceComprehensiveTest.java

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -29,6 +29,7 @@
2929
import io.airbyte.commons.json.Jsons;
3030
import io.airbyte.db.Database;
3131
import io.airbyte.db.Databases;
32+
import io.airbyte.integrations.source.mysql.MySqlSource.ReplicationMethod;
3233
import io.airbyte.integrations.standardtest.source.SourceComprehensiveTest;
3334
import io.airbyte.integrations.standardtest.source.TestDataHolder;
3435
import io.airbyte.integrations.standardtest.source.TestDestinationEnv;
@@ -67,6 +68,7 @@ protected Database setupDatabase() throws Exception {
6768
.put("database", container.getDatabaseName())
6869
.put("username", container.getUsername())
6970
.put("password", container.getPassword())
71+
.put("replication_method", ReplicationMethod.STANDARD)
7072
.build());
7173

7274
final Database database = Databases.createDatabase(

0 commit comments

Comments
 (0)