0004290: Oracle bulk loader uses wrong user and password for load-only

JumpMind · Feb 26, 2020 · 38b468f · 38b468f
1 parent d1546f1
commit 38b468f
Showing 1 changed file with 7 additions and 3 deletions.
diff --git a/symmetric-client/src/main/java/org/jumpmind/symmetric/ext/OracleBulkDataLoaderFactory.java b/symmetric-client/src/main/java/org/jumpmind/symmetric/ext/OracleBulkDataLoaderFactory.java
@@ -58,13 +58,17 @@ public IDataWriter getDataWriter(String sourceNodeId, ISymmetricDialect symmetri
             List<? extends Conflict> conflictSettings, List<ResolvedData> resolvedData) {
 
         IParameterService parmService = engine.getParameterService();
-        String dbUrl = parmService.getString(BasicDataSourcePropertyConstants.DB_POOL_URL);
-        String dbUser = parmService.getString(BasicDataSourcePropertyConstants.DB_POOL_USER);
+        String prefix = "";
+        if (parmService.is(ParameterConstants.NODE_LOAD_ONLY)) {
+            prefix = ParameterConstants.LOAD_ONLY_PROPERTY_PREFIX;
+        }
+        String dbUrl = parmService.getString(prefix + BasicDataSourcePropertyConstants.DB_POOL_URL);
+        String dbUser = parmService.getString(prefix + BasicDataSourcePropertyConstants.DB_POOL_USER);
         if (dbUser != null && dbUser.startsWith(SecurityConstants.PREFIX_ENC)) {
             dbUser = engine.getSecurityService().decrypt(dbUser.substring(SecurityConstants.PREFIX_ENC.length()));
         }
 
-        String dbPassword = parmService.getString(BasicDataSourcePropertyConstants.DB_POOL_PASSWORD);
+        String dbPassword = parmService.getString(prefix + BasicDataSourcePropertyConstants.DB_POOL_PASSWORD);
         if (dbPassword != null && dbPassword.startsWith(SecurityConstants.PREFIX_ENC)) {
             dbPassword = engine.getSecurityService().decrypt(dbPassword.substring(SecurityConstants.PREFIX_ENC.length()));
         }