test: use 4.2.1 lts docker image & set cluster name

flink-connector-obkv-hbase/src/test/java/com/oceanbase/connector/flink/OBKVHBaseConnectorITCase.java

@@ -56,10 +56,13 @@
 
 public class OBKVHBaseConnectorITCase extends OceanBaseMySQLTestBase {
 
- public static final String CLUSTER_NAME = "obcluster";
  public static final String CONFIG_URL =
  "http:https://127.0.0.1:8080/services?Action=ObRootServiceInfo&ObCluster=" + CLUSTER_NAME;
 
+ static {
+ OB_SERVER.withInitScript("sql/init.sql");
+ }
+
  @Override
  protected String getTestTable() {
  return "htable";
@@ -78,8 +81,8 @@ protected String getUsername() {
  @Override
  protected Map<String, String> getOptions() {
  Map<String, String> options = super.getOptions();
- options.put("sys.username", OB_SERVER.getSysUsername());
- options.put("sys.password", OB_SERVER.getSysPassword());
+ options.put("sys.username", SYS_USERNAME);
+ options.put("sys.password", SYS_PASSWORD);
  return options;
  }
 

flink-connector-oceanbase-base/src/test/java/com/oceanbase/connector/flink/OceanBaseMySQLTestBase.java

@@ -18,12 +18,14 @@
 
 import org.apache.flink.util.TestLogger;
 
-import org.junit.ClassRule;
+import org.junit.AfterClass;
+import org.junit.BeforeClass;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 import org.testcontainers.containers.output.Slf4jLogConsumer;
-import org.testcontainers.utility.MountableFile;
+import org.testcontainers.oceanbase.OceanBaseCEContainer;
 
+import java.util.Arrays;
 import java.util.HashMap;
 import java.util.List;
 import java.util.Map;
@@ -37,20 +39,38 @@ public abstract class OceanBaseMySQLTestBase extends TestLogger {
 
  private static final Logger LOG = LoggerFactory.getLogger(OceanBaseMySQLTestBase.class);
 
- public static final String IMAGE_TAG = "4.2.1_bp2";
-
- @ClassRule
- public static final OceanBaseContainer OB_SERVER =
- new OceanBaseContainer(OceanBaseContainer.DOCKER_IMAGE_NAME + ":" + IMAGE_TAG)
- .withNetworkMode("host")
- .withSysPassword("123456")
- .withCopyFileToContainer(
- MountableFile.forClasspathResource("sql/init.sql"),
- "/root/boot/init.d/init.sql")
+ public static final String CLUSTER_NAME = "flink-connector-oceanbase-ci";
+ public static final String SYS_USERNAME = "root";
+ public static final String SYS_PASSWORD = "123456";
+ public static final int SQL_PORT = 2881;
+ public static final int RPC_PORT = 2882;
+ public static final int CONFIG_SERVER_PORT = 8080;
+
+ public static final OceanBaseCEContainer OB_SERVER =
+ new OceanBaseCEContainer("oceanbase/oceanbase-ce:4.2.1")
+ .withEnv("OB_CLUSTER_NAME", CLUSTER_NAME)
+ .withEnv("OB_ROOT_PASSWORD", SYS_PASSWORD)
+ .withExposedPorts(SQL_PORT, RPC_PORT, CONFIG_SERVER_PORT)
  .withLogConsumer(new Slf4jLogConsumer(LOG));
 
+ @BeforeClass
+ public static void init() {
+ OB_SERVER.setPortBindings(
+ Arrays.asList(binding(SQL_PORT), binding(RPC_PORT), binding(CONFIG_SERVER_PORT)));
+ OB_SERVER.start();
+ }
+
+ private static String binding(int port) {
+ return String.format("%d:%d", port, port);
+ }
+
+ @AfterClass
+ public static void destroy() {
+ OB_SERVER.stop();
+ }
+
  protected String getUrl() {
- return OB_SERVER.getJdbcUrl();
+ return "jdbc:mysql:https://" + OB_SERVER.getHost() + ":" + SQL_PORT + "/" + "test";
  }
 
  protected abstract String getTestTable();

flink-connector-oceanbase/src/test/java/com/oceanbase/connector/flink/OceanBaseMySQLConnectorITCase.java

@@ -65,6 +65,10 @@
 
 public class OceanBaseMySQLConnectorITCase extends OceanBaseMySQLTestBase {
 
+ static {
+ OB_SERVER.withInitScript("sql/init.sql");
+ }
+
  @Override
  protected String getTestTable() {
  return "products";
@@ -399,7 +403,7 @@ public void testDirectLoadSink() throws Exception {
  + OB_SERVER.getHost()
  + "',"
  + " 'direct-load.port'='"
- + OB_SERVER.getActualPort(2882)
+ + RPC_PORT
  + "',"
  + getOptionsString()
  + ");");

pom.xml

@@ -50,7 +50,7 @@ under the License.
  <dependency>
  <groupId>org.testcontainers</groupId>
  <artifactId>testcontainers-bom</artifactId>
- <version>1.15.3</version>
+ <version>1.19.8</version>
  <type>pom</type>
  <scope>import</scope>
  </dependency>
@@ -140,7 +140,7 @@ under the License.
  </dependency>
  <dependency>
  <groupId>org.testcontainers</groupId>
- <artifactId>jdbc</artifactId>
+ <artifactId>oceanbase</artifactId>
  <scope>test</scope>
  </dependency>
  </dependencies>