fix bug

dbsyncer-biz/src/main/java/org/dbsyncer/biz/checker/impl/tablegroup/TableGroupChecker.java

@@ -15,7 +15,6 @@ import org.dbsyncer.parser.model.FieldMapping;
 import org.dbsyncer.parser.model.Mapping;
 import org.dbsyncer.parser.model.TableGroup;
 import org.dbsyncer.parser.util.PickerUtil;
-import org.dbsyncer.sdk.connector.ConfigValidator;
 import org.dbsyncer.sdk.enums.ModelEnum;
 import org.dbsyncer.sdk.model.Field;
 import org.dbsyncer.sdk.model.MetaInfo;
@@ -54,9 +53,6 @@ public class TableGroupChecker extends AbstractChecker {
     @Resource
     private ProfileComponent profileComponent;
 
-    @Resource
-    private Map<String, ConfigValidator> map;
-
     @Override
     public ConfigModel checkAddConfigModel(Map<String, String> params) {
         logger.info("params:{}", params);

dbsyncer-connector/dbsyncer-connector-base/pom.xml

@@ -24,6 +24,7 @@
             <groupId>org.ghi</groupId>
             <artifactId>dbsyncer-connector-elasticsearch</artifactId>
             <version>${project.parent.version}</version>
+            <scope>provided</scope>
         </dependency>
 
         <!-- dbsyncer-connector-file -->
@@ -31,6 +32,7 @@
             <groupId>org.ghi</groupId>
             <artifactId>dbsyncer-connector-file</artifactId>
             <version>${project.parent.version}</version>
+            <scope>provided</scope>
         </dependency>
 
         <!-- dbsyncer-connector-kafka -->
@@ -38,6 +40,7 @@
             <groupId>org.ghi</groupId>
             <artifactId>dbsyncer-connector-kafka</artifactId>
             <version>${project.parent.version}</version>
+            <scope>provided</scope>
         </dependency>
 
         <!-- dbsyncer-connector-mysql -->
@@ -45,6 +48,7 @@
             <groupId>org.ghi</groupId>
             <artifactId>dbsyncer-connector-mysql</artifactId>
             <version>${project.parent.version}</version>
+            <scope>provided</scope>
         </dependency>
 
         <!-- dbsyncer-connector-oracle -->
@@ -52,6 +56,7 @@
             <groupId>org.ghi</groupId>
             <artifactId>dbsyncer-connector-oracle</artifactId>
             <version>${project.parent.version}</version>
+            <scope>provided</scope>
         </dependency>
 
         <!-- dbsyncer-connector-sqlserver -->
@@ -59,6 +64,7 @@
             <groupId>org.ghi</groupId>
             <artifactId>dbsyncer-connector-sqlserver</artifactId>
             <version>${project.parent.version}</version>
+            <scope>provided</scope>
         </dependency>
 
         <!-- dbsyncer-connector-postgresql -->
@@ -66,6 +72,7 @@
             <groupId>org.ghi</groupId>
             <artifactId>dbsyncer-connector-postgresql</artifactId>
             <version>${project.parent.version}</version>
+            <scope>provided</scope>
         </dependency>
 
         <dependency>

dbsyncer-parser/src/main/java/org/dbsyncer/parser/convert/handler/BlobToStringHandler.java

@@ -1,30 +0,0 @@
-package org.dbsyncer.parser.convert.handler;
-
-import org.dbsyncer.parser.ParserException;
-import org.dbsyncer.parser.convert.AbstractHandler;
-
-import java.sql.SQLException;
-
-/**
- * Blob转String
- *
- * @author AE86
- * @version 1.0.0
- * @date 2022/1/20 23:04
- */
-public class BlobToStringHandler extends AbstractHandler {
-
-    @Override
-    public Object convert(String args, Object value) {
-        if (value instanceof oracle.sql.BLOB) {
-            oracle.sql.BLOB blob = (oracle.sql.BLOB) value;
-            try {
-                value = getString(blob.getBinaryStream(), (int) blob.length());
-            } catch (SQLException e) {
-                throw new ParserException(e.getMessage());
-            }
-        }
-        return value;
-    }
-
-}

dbsyncer-parser/src/main/java/org/dbsyncer/parser/convert/handler/ClobToStringHandler.java

@@ -1,30 +0,0 @@
-package org.dbsyncer.parser.convert.handler;
-
-import org.dbsyncer.parser.ParserException;
-import org.dbsyncer.parser.convert.AbstractHandler;
-
-import java.sql.SQLException;
-
-/**
- * Clob转String
- *
- * @author AE86
- * @version 1.0.0
- * @date 2022/1/20 23:04
- */
-public class ClobToStringHandler extends AbstractHandler {
-
-    @Override
-    public Object convert(String args, Object value) {
-        if (value instanceof oracle.sql.CLOB) {
-            oracle.sql.CLOB clob = (oracle.sql.CLOB) value;
-            try {
-                value = getString(clob.getAsciiStream(), (int) clob.length());
-            } catch (SQLException e) {
-                throw new ParserException(e.getMessage());
-            }
-        }
-        return value;
-    }
-
-}

dbsyncer-parser/src/main/java/org/dbsyncer/parser/enums/ConvertEnum.java

@@ -54,14 +54,6 @@ public enum ConvertEnum {
      * Byte[]转String
      */
     BYTES_TO_STRING("BYTES_TO_STRING", "Byte[]转String", 0, new BytesToStringHandler()),
-    /**
-     * Clob转String
-     */
-    CLOB_TO_STRING("CLOB_TO_STRING", "Clob转String", 0, new ClobToStringHandler()),
-    /**
-     * Blob转String
-     */
-    BLOB_TO_STRING("BLOB_TO_STRING", "Blob转String", 0, new BlobToStringHandler()),
     /**
      * 替换
      */

dbsyncer-storage/pom.xml

@@ -24,12 +24,6 @@
             <artifactId>protobuf-java</artifactId>
         </dependency>
 
-        <!-- oracle-driver -->
-        <dependency>
-            <groupId>com.oracle</groupId>
-            <artifactId>ojdbc6</artifactId>
-        </dependency>
-
         <!-- smartcn中文分词器 -->
         <dependency>
             <groupId>org.apache.lucene</groupId>
@@ -47,6 +41,20 @@
             <artifactId>spring-boot-starter-log4j2</artifactId>
         </dependency>
 
+        <!-- oracle-driver -->
+        <dependency>
+            <groupId>com.oracle</groupId>
+            <artifactId>ojdbc6</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
+        <!-- postgresql -->
+        <dependency>
+            <groupId>org.postgresql</groupId>
+            <artifactId>postgresql</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
         <dependency>
             <groupId>junit</groupId>
             <artifactId>junit</artifactId>