AE86 hai 1 ano
pai
achega
2057c75402

+ 1 - 3
dbsyncer-connector/dbsyncer-connector-elasticsearch/src/main/java/org/dbsyncer/connector/elasticsearch/ElasticsearchConnector.java

@@ -58,7 +58,6 @@ import org.elasticsearch.search.sort.SortOrder;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import javax.annotation.PostConstruct;
 import java.io.IOException;
 import java.sql.Types;
 import java.util.ArrayList;
@@ -86,8 +85,7 @@ public final class ElasticsearchConnector extends AbstractConnector implements C
 
     private final ESConfigValidator configValidator = new ESConfigValidator();
 
-    @PostConstruct
-    private void init() {
+    public ElasticsearchConnector() {
         VALUE_MAPPERS.put(Types.DATE, new ESDateValueMapper());
         VALUE_MAPPERS.put(Types.OTHER, new ESOtherValueMapper());
 

+ 1 - 3
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/OracleConnector.java

@@ -23,7 +23,6 @@ import org.dbsyncer.sdk.util.PrimaryKeyUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import javax.annotation.PostConstruct;
 import java.sql.Types;
 import java.util.List;
 
@@ -41,8 +40,7 @@ public final class OracleConnector extends AbstractDatabaseConnector {
     private final String TYPE = "Oracle";
     private final OracleConfigValidator configValidator = new OracleConfigValidator();
 
-    @PostConstruct
-    private void init() {
+    public OracleConnector() {
         VALUE_MAPPERS.put(Types.OTHER, new OracleOtherValueMapper());
     }
 

+ 5 - 7
dbsyncer-connector/dbsyncer-connector-postgresql/src/main/java/org/dbsyncer/connector/postgresql/PostgreSQLConnector.java

@@ -24,7 +24,6 @@ import org.dbsyncer.sdk.util.PrimaryKeyUtil;
 import org.slf4j.Logger;
 import org.slf4j.LoggerFactory;
 
-import javax.annotation.PostConstruct;
 import java.sql.Types;
 import java.util.List;
 
@@ -42,6 +41,11 @@ public final class PostgreSQLConnector extends AbstractDatabaseConnector {
     private final String TYPE = "PostgreSQL";
     private final PostgreSQLConfigValidator configValidator = new PostgreSQLConfigValidator();
 
+    public PostgreSQLConnector() {
+        VALUE_MAPPERS.put(Types.BIT, new PostgreSQLBitValueMapper());
+        VALUE_MAPPERS.put(Types.OTHER, new PostgreSQLOtherValueMapper());
+    }
+
     @Override
     public String getConnectorType() {
         return TYPE;
@@ -64,12 +68,6 @@ public final class PostgreSQLConnector extends AbstractDatabaseConnector {
         return null;
     }
 
-    @PostConstruct
-    private void init() {
-        VALUE_MAPPERS.put(Types.BIT, new PostgreSQLBitValueMapper());
-        VALUE_MAPPERS.put(Types.OTHER, new PostgreSQLOtherValueMapper());
-    }
-
     @Override
     public String buildSqlWithQuotation() {
         return "\"";