Enhancement: Add e2e integration and integration tests for oceanbase-cdc connector

Author: yuanoOo

flink-cdc-connect/flink-cdc-source-connectors/flink-connector-oceanbase-cdc/src/test/java/org/apache/flink/cdc/connectors/oceanbase/OceanBaseFailoverITCase.java

@@ -62,7 +62,7 @@ public class OceanBaseFailoverITCase extends OceanBaseSourceTestBase {
 
     private static final String DEFAULT_SCAN_STARTUP_MODE = "initial";
     private static final String DDL_FILE = "oceanbase_ddl_test";
-    private static final String DEFAULT_TEST_DATABASE = "customer_" + getRandomSuffix();
+    private static String DEFAULT_TEST_DATABASE = "customer_" + getRandomSuffix();
     protected static final int DEFAULT_PARALLELISM = 4;
 
     private final List<String> firstPartBinlogEvents =
@@ -102,6 +102,7 @@ public static Stream<Arguments> parameters() {
 
     @BeforeEach
     public void setup() throws InterruptedException {
+        DEFAULT_TEST_DATABASE = "customer_" + getRandomSuffix();
         initializeOceanBaseTables(
                 DDL_FILE,
                 DEFAULT_TEST_DATABASE,