[update][lib][rdbms] Refactor writer.parameter.connection to use a …

…map instead of a list
wgzhao · Oct 10, 2024 · e681280 · e681280
1 parent e26003e
commit e681280
Show file tree

Hide file tree

Showing 28 changed files with 1,044 additions and 1,116 deletions.
diff --git a/core/src/main/java/com/wgzhao/addax/core/util/ConfigParser.java b/core/src/main/java/com/wgzhao/addax/core/util/ConfigParser.java
@@ -131,6 +131,17 @@ private static void upgradeJobConfig(Configuration configuration)
             }
             configuration.set(JOB_CONTENT_READER_PARAMETER, reader);
         }
+        // switch `write.connection` from list to map
+        Configuration writer = configuration.getConfiguration(JOB_CONTENT_WRITER_PARAMETER);
+        if (writer != null) {
+            if (writer.getString(CONNECTION, "").startsWith("[")) {
+                List<Map> connectionList = configuration.getList(JOB_CONTENT_WRITER_PARAMETER + ".connection", Map.class);
+                if (connectionList != null && !connectionList.isEmpty()) {
+                    writer.set(CONNECTION, connectionList.get(0));
+                }
+            }
+            configuration.set(JOB_CONTENT_WRITER_PARAMETER, writer);
+        }
     }
 
     private static Configuration parseCoreConfig()