瀏覽代碼

删除不必要的,以及string做格式化

life 1 年之前
父節點
當前提交
fce4b991b0

+ 0 - 1
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/cdc/OracleListener.java

@@ -132,7 +132,6 @@ public class OracleListener extends AbstractDatabaseListener {
     private AbstractParser setTable(AbstractParser parser, Table table) {
         parser.setTableName(table == null ? StringUtil.EMPTY : StringUtil.replace(table.getName(), StringUtil.DOUBLE_QUOTATION, StringUtil.EMPTY));
         parser.setFields(tableFiledMap.get(parser.getTableName()));
-        parser.setInstance(getConnectorInstance());
         return parser;
     }
 

+ 0 - 4
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/logminer/parser/AbstractParser.java

@@ -26,7 +26,6 @@ public abstract class AbstractParser implements Parser {
     protected Map<String, String> columnMap = new HashMap<>();
     protected String tableName;
     protected List<Field> fields;
-    protected DatabaseConnectorInstance instance;
 
     public void findColumn(Expression expression) {
         if (expression instanceof IsNullExpression){
@@ -89,7 +88,4 @@ public abstract class AbstractParser implements Parser {
         this.fields = fields;
     }
 
-    public void setInstance(DatabaseConnectorInstance instance) {
-        this.instance = instance;
-    }
 }

+ 1 - 1
dbsyncer-connector/dbsyncer-connector-oracle/src/main/java/org/dbsyncer/connector/oracle/logminer/parser/OracleTypeParser.java

@@ -25,7 +25,7 @@ public class OracleTypeParser {
             case Types.TIMESTAMP:
                 return DateFormatUtil.stringToTimestamp(StringUtil.replace(value,StringUtil.SINGLE_QUOTATION,StringUtil.EMPTY));
             default:
-                return value;
+                return StringUtil.replace(value,StringUtil.SINGLE_QUOTATION,StringUtil.EMPTY);
         }
     }