Merge pull request #531 from tapdata/develop

Develop

Author: jarad0628

connectors-common/connector-core/pom.xml

@@ -33,7 +33,7 @@
         <dependency>
             <groupId>io.tapdata</groupId>
             <artifactId>tapdata-pdk-runner</artifactId>
-            <version>1.10-SNAPSHOT</version>
+            <version>2.0-SNAPSHOT</version>
             <scope>test</scope>
         </dependency>
 

connectors-common/connector-core/src/main/java/io/tapdata/kit/StringKit.java

@@ -1,5 +1,7 @@
 package io.tapdata.kit;
 
+import org.apache.commons.lang3.StringUtils;
+
 import java.security.MessageDigest;
 import java.security.NoSuchAlgorithmException;
 import java.util.Arrays;
@@ -31,12 +33,30 @@ public static String copyString(String copied, Integer count, String combiner) {
         return sb.delete(sb.length() - combiner.length(), sb.length()).toString();
     }
 
-    //replace first
-    public static String replaceOnce(String text, String searchString, String replacement) {
+    //replace
+    public static String replace(String text, String searchString, String replacement) {
         if (EmptyKit.isEmpty(text)) {
             return "";
         }
-        return text.replace(searchString, replacement);
+        return StringUtils.replace(text, searchString, replacement);
+    }
+
+    public static String replaceEscape(String input, char[] replacements) {
+        char[] chars = input.toCharArray();
+        StringBuilder sb = new StringBuilder();
+        int i = 0;
+        while (i < chars.length) {
+            char c = chars[i];
+            for (char replacement : replacements) {
+                if (c == replacement) {
+                    sb.append("\\");
+                    break;
+                }
+            }
+            sb.append(c);
+            i++;
+        }
+        return sb.toString();
     }
 
     /**

connectors-common/file-connector-core/pom.xml

@@ -13,8 +13,8 @@
     <packaging>jar</packaging>
 
     <properties>
-        <tapdata.api.version>1.4.4-SNAPSHOT</tapdata.api.version>
-        <tapdata.pdk.api.version>1.4.4-SNAPSHOT</tapdata.pdk.api.version>
+        <tapdata.api.version>2.0.0-SNAPSHOT</tapdata.api.version>
+        <tapdata.pdk.api.version>2.0.0-SNAPSHOT</tapdata.pdk.api.version>
         <java.version>8</java.version>
     </properties>
 

connectors-common/hive-core/pom.xml

@@ -18,7 +18,7 @@
     <properties>
         <java.version>8</java.version>
         <sql.core.version>1.0-SNAPSHOT</sql.core.version>
-        <tapdata.pdk.api.verison>1.4.4-SNAPSHOT</tapdata.pdk.api.verison>
+        <tapdata.pdk.api.verison>2.0.0-SNAPSHOT</tapdata.pdk.api.verison>
 
     </properties>
     <dependencyManagement>

connectors-common/js-connector-core-plus/pom.xml

@@ -14,7 +14,7 @@
 
     <properties>
         <java.version>8</java.version>
-        <tapdata.pdk.api.version>1.4.4-SNAPSHOT</tapdata.pdk.api.version>
+        <tapdata.pdk.api.version>2.0.0-SNAPSHOT</tapdata.pdk.api.version>
     </properties>
 
     <dependencies>

connectors-common/js-connector-core/pom.xml

@@ -14,7 +14,7 @@
 
     <properties>
         <java.version>8</java.version>
-        <tapdata.pdk.api.version>1.4.4-SNAPSHOT</tapdata.pdk.api.version>
+        <tapdata.pdk.api.version>2.0.0-SNAPSHOT</tapdata.pdk.api.version>
     </properties>
 
     <dependencies>
@@ -65,13 +65,14 @@
         <dependency>
             <groupId>org.graalvm.js</groupId>
             <artifactId>js</artifactId>
-            <version>21.3.0</version>
+            <version>24.1.2</version>
+            <type>pom</type>
             <scope>test</scope>
         </dependency>
         <dependency>
             <groupId>org.graalvm.js</groupId>
             <artifactId>js-scriptengine</artifactId>
-            <version>21.3.0</version>
+            <version>24.1.2</version>
             <scope>test</scope>
         </dependency>
         <dependency>

connectors-common/kafka-core/pom.xml

@@ -196,7 +196,7 @@
         <dependency>
             <groupId>io.tapdata</groupId>
             <artifactId>script-engine-module</artifactId>
-            <version>1.0-SNAPSHOT</version>
+            <version>2.0-SNAPSHOT</version>
             <scope>test</scope>
         </dependency>
         <!-- Test Dependencies -->