oracle char type

Author: todd5167

oracle/oracle-sink/src/main/java/com/dtstack/flink/sql/sink/oracle/OracleDialect.java

@@ -19,6 +19,7 @@
 package com.dtstack.flink.sql.sink.oracle;
 
 import com.dtstack.flink.sql.sink.rdb.dialect.JDBCDialect;
+import com.dtstack.flink.sql.table.TableInfo;
 import com.dtstack.flink.sql.util.DtStringUtil;
 import org.apache.commons.lang3.StringUtils;
 

oracle/oracle-sink/src/main/java/com/dtstack/flink/sql/sink/oracle/OracleSink.java

@@ -31,10 +31,6 @@
  */
 public class OracleSink extends RdbSink implements IStreamSinkGener<RdbSink> {
 
-    private final String SQL_DEFAULT_PLACEHOLDER = " ? ";
-    private final String DEAL_CHAR_KEY = "char";
-    private String RPAD_FORMAT = " rpad(?, %d, ' ') ";
-
     public OracleSink() {
         super(new OracleDialect());
     }

rdb/rdb-sink/src/main/java/com/dtstack/flink/sql/sink/rdb/RdbSink.java

@@ -106,6 +106,7 @@ public RdbSink genStreamSink(TargetTableInfo targetTableInfo) {
         this.sqlTypes = JDBCTypeConvertUtils.buildSqlTypes(fieldTypeArray);
         this.allReplace = rdbTableInfo.isAllReplace();
         this.updateMode = rdbTableInfo.getUpdateMode();
+        rdbTableInfo.getFieldList();
         return this;
     }