This is an automated email from the ASF dual-hosted git repository.
davidzollo pushed a commit to branch dev
in repository https://gitbox.apache.org/repos/asf/seatunnel.git
The following commit(s) were added to refs/heads/dev by this push:
new 73e46e0d62 [Improve][E2E] Use DependencyJar for MySQL error tests
(#11904)
73e46e0d62 is described below
commit 73e46e0d627fdc964de82549022dd611e35b25e7
Author: fly1d <[email protected]>
AuthorDate: Thu Aug 20 21:34:17 2026 +0800
[Improve][E2E] Use DependencyJar for MySQL error tests (#11904)
Co-authored-by: fly1d <[email protected]>
---
.../seatunnel/engine/e2e/SinkErrorToMysqlIT.java | 20 +++++---------------
.../engine/e2e/TransformErrorToMysqlIT.java | 20 +++++---------------
2 files changed, 10 insertions(+), 30 deletions(-)
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SinkErrorToMysqlIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SinkErrorToMysqlIT.java
index 1e5f2ea411..d1074b0fe4 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SinkErrorToMysqlIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/SinkErrorToMysqlIT.java
@@ -24,6 +24,7 @@ import org.apache.seatunnel.e2e.common.container.EngineType;
import org.apache.seatunnel.e2e.common.container.TestContainer;
import org.apache.seatunnel.e2e.common.junit.DisabledOnContainer;
import org.apache.seatunnel.e2e.common.junit.TestContainerExtension;
+import org.apache.seatunnel.e2e.common.util.DependencyJar;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.Assertions;
@@ -36,6 +37,7 @@ import org.testcontainers.containers.MySQLContainer;
import org.testcontainers.lifecycle.Startables;
import org.testcontainers.utility.DockerImageName;
+import com.mysql.cj.jdbc.Driver;
import lombok.extern.slf4j.Slf4j;
import java.sql.Connection;
@@ -57,24 +59,12 @@ public class SinkErrorToMysqlIT extends TestSuiteBase
implements TestResource {
private static final String MYSQL_USERNAME = "root";
private static final String MYSQL_PASSWORD = "Abc!@#135_seatunnel";
private static final int MYSQL_PORT = 3306;
- private static final String DRIVER_JAR =
-
"https://repo1.maven.org/maven2/com/mysql/mysql-connector-j/8.0.32/mysql-connector-j-8.0.32.jar";;
@TestContainerExtension
private final ContainerExtendedFactory extendedFactory =
- container -> {
- Container.ExecResult extraCommands =
- container.execInContainer(
- "bash",
- "-c",
- "mkdir -p /tmp/seatunnel/plugins/Jdbc/lib"
- + " && cd
/tmp/seatunnel/plugins/Jdbc/lib"
- + " && (test -s
mysql-connector-j-8.0.32.jar"
- + " || curl -fsSLO --retry 5
--retry-delay 2 "
- + DRIVER_JAR
- + ")");
- Assertions.assertEquals(0, extraCommands.getExitCode(),
extraCommands.getStderr());
- };
+ container ->
+ DependencyJar.of(Driver.class)
+ .copyTo(container,
"/tmp/seatunnel/plugins/Jdbc/lib");
private MySQLContainer<?> mysqlContainer;
diff --git
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/TransformErrorToMysqlIT.java
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/TransformErrorToMysqlIT.java
index 1f7fdebae7..619d465e41 100644
---
a/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/TransformErrorToMysqlIT.java
+++
b/seatunnel-e2e/seatunnel-engine-e2e/connector-seatunnel-e2e-base/src/test/java/org/apache/seatunnel/engine/e2e/TransformErrorToMysqlIT.java
@@ -24,6 +24,7 @@ import org.apache.seatunnel.e2e.common.container.EngineType;
import org.apache.seatunnel.e2e.common.container.TestContainer;
import org.apache.seatunnel.e2e.common.junit.DisabledOnContainer;
import org.apache.seatunnel.e2e.common.junit.TestContainerExtension;
+import org.apache.seatunnel.e2e.common.util.DependencyJar;
import org.junit.jupiter.api.AfterAll;
import org.junit.jupiter.api.Assertions;
@@ -36,6 +37,7 @@ import org.testcontainers.containers.MySQLContainer;
import org.testcontainers.lifecycle.Startables;
import org.testcontainers.utility.DockerImageName;
+import com.mysql.cj.jdbc.Driver;
import lombok.extern.slf4j.Slf4j;
import java.sql.Connection;
@@ -57,24 +59,12 @@ public class TransformErrorToMysqlIT extends TestSuiteBase
implements TestResour
private static final String MYSQL_USERNAME = "root";
private static final String MYSQL_PASSWORD = "Abc!@#135_seatunnel";
private static final int MYSQL_PORT = 3306;
- private static final String DRIVER_JAR =
-
"https://repo1.maven.org/maven2/com/mysql/mysql-connector-j/8.0.32/mysql-connector-j-8.0.32.jar";;
@TestContainerExtension
private final ContainerExtendedFactory extendedFactory =
- container -> {
- Container.ExecResult extraCommands =
- container.execInContainer(
- "bash",
- "-c",
- "mkdir -p /tmp/seatunnel/plugins/Jdbc/lib"
- + " && cd
/tmp/seatunnel/plugins/Jdbc/lib"
- + " && (test -s
mysql-connector-j-8.0.32.jar"
- + " || curl -fsSLO --retry 5
--retry-delay 2 "
- + DRIVER_JAR
- + ")");
- Assertions.assertEquals(0, extraCommands.getExitCode(),
extraCommands.getStderr());
- };
+ container ->
+ DependencyJar.of(Driver.class)
+ .copyTo(container,
"/tmp/seatunnel/plugins/Jdbc/lib");
private MySQLContainer<?> mysqlContainer;
