add module dbsyncer-connector-base

dbsyncer-biz/src/main/java/org/dbsyncer/biz/enums/MetricEnum.java

@@ -2,7 +2,6 @@ package org.dbsyncer.biz.enums;
 
 import org.dbsyncer.biz.BizException;
 import org.dbsyncer.common.util.StringUtil;
-import org.dbsyncer.connector.ConnectorException;
 
 /**
  * 系统指标
@@ -58,7 +57,7 @@ public enum MetricEnum {
         this.metricName = metricName;
     }
 
-    public static MetricEnum getMetric(String code) throws ConnectorException {
+    public static MetricEnum getMetric(String code) throws BizException {
         for (MetricEnum e : MetricEnum.values()) {
             if (StringUtil.equals(code, e.getCode())) {
                 return e;

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

@@ -0,0 +1,71 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <parent>
+        <artifactId>dbsyncer-connector</artifactId>
+        <groupId>org.ghi</groupId>
+        <version>2.0.0</version>
+    </parent>
+    <modelVersion>4.0.0</modelVersion>
+
+    <artifactId>dbsyncer-connector-base</artifactId>
+
+    <dependencies>
+        <!-- sdk -->
+        <dependency>
+            <groupId>org.ghi</groupId>
+            <artifactId>dbsyncer-sdk</artifactId>
+            <version>${project.parent.version}</version>
+        </dependency>
+
+        <!-- dbsyncer-connector-elasticsearch -->
+        <dependency>
+            <groupId>org.ghi</groupId>
+            <artifactId>dbsyncer-connector-elasticsearch</artifactId>
+            <version>${project.parent.version}</version>
+        </dependency>
+
+        <!-- dbsyncer-connector-file -->
+        <dependency>
+            <groupId>org.ghi</groupId>
+            <artifactId>dbsyncer-connector-file</artifactId>
+            <version>${project.parent.version}</version>
+        </dependency>
+
+        <!-- dbsyncer-connector-kafka -->
+        <dependency>
+            <groupId>org.ghi</groupId>
+            <artifactId>dbsyncer-connector-kafka</artifactId>
+            <version>${project.parent.version}</version>
+        </dependency>
+
+        <!-- dbsyncer-connector-mysql -->
+        <dependency>
+            <groupId>org.ghi</groupId>
+            <artifactId>dbsyncer-connector-mysql</artifactId>
+            <version>${project.parent.version}</version>
+        </dependency>
+
+        <!-- dbsyncer-connector-oracle -->
+        <dependency>
+            <groupId>org.ghi</groupId>
+            <artifactId>dbsyncer-connector-oracle</artifactId>
+            <version>${project.parent.version}</version>
+        </dependency>
+
+        <!-- dbsyncer-connector-sqlserver -->
+        <dependency>
+            <groupId>org.ghi</groupId>
+            <artifactId>dbsyncer-connector-sqlserver</artifactId>
+            <version>${project.parent.version}</version>
+        </dependency>
+
+        <!-- dbsyncer-connector-postgresql -->
+        <dependency>
+            <groupId>org.ghi</groupId>
+            <artifactId>dbsyncer-connector-postgresql</artifactId>
+            <version>${project.parent.version}</version>
+        </dependency>
+    </dependencies>
+</project>

dbsyncer-connector/dbsyncer-connector-elasticsearch/pom.xml

@@ -26,6 +26,13 @@
             <artifactId>elasticsearch-rest-high-level-client</artifactId>
         </dependency>
 
+        <!-- postgresql -->
+        <dependency>
+            <groupId>org.postgresql</groupId>
+            <artifactId>postgresql</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-log4j2</artifactId>

dbsyncer-connector/dbsyncer-connector-mysql/pom.xml

@@ -32,6 +32,12 @@
             <artifactId>mysql-binlog-connector-java</artifactId>
         </dependency>
 
+        <dependency>
+            <groupId>com.github.jsqlparser</groupId>
+            <artifactId>jsqlparser</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-log4j2</artifactId>

dbsyncer-connector/dbsyncer-connector-oracle/pom.xml

@@ -26,6 +26,13 @@
             <artifactId>ojdbc6</artifactId>
         </dependency>
 
+        <!-- sqlserver-driver -->
+        <dependency>
+            <groupId>com.microsoft.sqlserver</groupId>
+            <artifactId>mssql-jdbc</artifactId>
+            <scope>provided</scope>
+        </dependency>
+
         <dependency>
             <groupId>org.springframework.boot</groupId>
             <artifactId>spring-boot-starter-log4j2</artifactId>

dbsyncer-connector/pom.xml

@@ -11,6 +11,7 @@
     <artifactId>dbsyncer-connector</artifactId>
     <packaging>pom</packaging>
     <modules>
+        <module>dbsyncer-connector-base</module>
         <module>dbsyncer-connector-elasticsearch</module>
         <module>dbsyncer-connector-file</module>
         <module>dbsyncer-connector-kafka</module>
@@ -19,64 +20,4 @@
         <module>dbsyncer-connector-sqlserver</module>
         <module>dbsyncer-connector-postgresql</module>
     </modules>
-
-    <dependencies>
-        <!-- sdk -->
-        <dependency>
-            <groupId>org.ghi</groupId>
-            <artifactId>dbsyncer-sdk</artifactId>
-            <version>${project.parent.version}</version>
-        </dependency>
-
-        <!-- dbsyncer-connector-elasticsearch
-        <dependency>
-            <groupId>org.ghi</groupId>
-            <artifactId>dbsyncer-connector-elasticsearch</artifactId>
-            <version>${project.parent.version}</version>
-        </dependency> -->
-
-        <!-- dbsyncer-connector-file
-        <dependency>
-            <groupId>org.ghi</groupId>
-            <artifactId>dbsyncer-connector-file</artifactId>
-            <version>${project.parent.version}</version>
-        </dependency> -->
-
-        <!-- dbsyncer-connector-kafka
-        <dependency>
-            <groupId>org.ghi</groupId>
-            <artifactId>dbsyncer-connector-kafka</artifactId>
-            <version>${project.parent.version}</version>
-        </dependency> -->
-
-        <!-- dbsyncer-connector-mysql
-        <dependency>
-            <groupId>org.ghi</groupId>
-            <artifactId>dbsyncer-connector-mysql</artifactId>
-            <version>${project.parent.version}</version>
-        </dependency> -->
-
-        <!-- dbsyncer-connector-oracle
-        <dependency>
-            <groupId>org.ghi</groupId>
-            <artifactId>dbsyncer-connector-oracle</artifactId>
-            <version>${project.parent.version}</version>
-        </dependency> -->
-
-        <!-- dbsyncer-connector-sqlserver
-        <dependency>
-            <groupId>org.ghi</groupId>
-            <artifactId>dbsyncer-connector-sqlserver</artifactId>
-            <version>${project.parent.version}</version>
-        </dependency> -->
-
-        <!-- dbsyncer-connector-postgresql -->
-        <dependency>
-            <groupId>org.ghi</groupId>
-            <artifactId>dbsyncer-connector-postgresql</artifactId>
-            <version>${project.parent.version}</version>
-        </dependency>
-
-    </dependencies>
-
 </project>

dbsyncer-storage/pom.xml

@@ -14,7 +14,7 @@
         <!-- Connector 连接器 -->
         <dependency>
             <groupId>org.ghi</groupId>
-            <artifactId>dbsyncer-connector</artifactId>
+            <artifactId>dbsyncer-connector-base</artifactId>
             <version>${project.parent.version}</version>
         </dependency>