From 38b468fb64e12225420bc41b01067695c1b9ad05 Mon Sep 17 00:00:00 2001 From: Eric Long Date: Wed, 26 Feb 2020 15:18:48 -0500 Subject: [PATCH] 0004290: Oracle bulk loader uses wrong user and password for load-only --- .../symmetric/ext/OracleBulkDataLoaderFactory.java | 10 +++++++--- 1 file changed, 7 insertions(+), 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 index 0867d302d8..852d2b27ed 100644 --- 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 conflictSettings, List 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())); }