upline the dataSourceFactoryGetter pos

qlangtech · Mar 10, 2023 · 36cf41f · 36cf41f
1 parent b2983c6
commit 36cf41f
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/CommonRdbmsWriter.java b/plugin-rdbms-util/src/main/java/com/alibaba/datax/plugin/rdbms/writer/CommonRdbmsWriter.java
@@ -241,7 +241,7 @@ public void init(Configuration writerSliceConfig) {
                 this.jdbcUrl = ss[2];
                 LOG.info("this is ob1_0 jdbc url. user=" + this.username + " :url=" + this.jdbcUrl);
             }
-
+            this.dataSourceFactoryGetter = DBUtil.getWriterDataSourceFactoryGetter(writerSliceConfig, this.containerContext);
             this.table = SelectTable.createInTask(writerSliceConfig, this.dataSourceFactoryGetter.getDBReservedKeys());
 
 
@@ -256,7 +256,7 @@ public void init(Configuration writerSliceConfig) {
             this.writeRecordSql = String.format(INSERT_OR_REPLACE_TEMPLATE, this.table);
             BASIC_MESSAGE = String.format("jdbcUrl:[%s], table:[%s]", this.jdbcUrl, this.table);
 
-            this.dataSourceFactoryGetter = DBUtil.getWriterDataSourceFactoryGetter(writerSliceConfig, this.containerContext);
+
             this.columns = SelectCols.createSelectCols(writerSliceConfig, this.dataSourceFactoryGetter.getDataSourceFactory());
             this.columnNumber = this.columns.size();
         }