Skip to content
Permalink
Browse files

0003825: Oracle bulk loader using SQL*Loader sqlldr

  • Loading branch information...
elong
elong committed Dec 13, 2018
1 parent a90a01b commit 151d5a28cff091a895dfc4a9770a53245a563ae4
@@ -28,7 +28,6 @@
import org.jumpmind.security.SecurityConstants;
import org.jumpmind.symmetric.ISymmetricEngine;
import org.jumpmind.symmetric.common.ParameterConstants;
import org.jumpmind.symmetric.common.ServerConstants;
import org.jumpmind.symmetric.db.ISymmetricDialect;
import org.jumpmind.symmetric.io.OracleBulkDatabaseWriter;
import org.jumpmind.symmetric.io.data.IDataWriter;
@@ -73,12 +72,10 @@ public IDataWriter getDataWriter(String sourceNodeId, ISymmetricDialect symmetri
String sqlLoaderCommand = parmService.getString(ParameterConstants.DBDIALECT_ORACLE_BULK_LOAD_SQLLDR_CMD);
String sqlLoaderOptions = parmService.getString(ParameterConstants.DBDIALECT_ORACLE_BULK_LOAD_SQLLDR_OPTIONS);
String ezConnectString = parmService.getString(ParameterConstants.DBDIALECT_ORACLE_BULK_LOAD_EZCONNECT);
boolean isStagingClearText = !parmService.is(ServerConstants.STREAM_TO_FILE_ENCRYPT_ENABLED, false) &&
!parmService.is(ServerConstants.STREAM_TO_FILE_COMPRESSION_ENABLED, false);

return new OracleBulkDatabaseWriter(symmetricDialect.getPlatform(), symmetricDialect.getTargetPlatform(),
engine.getStagingManager(), engine.getTablePrefix(), sqlLoaderCommand, sqlLoaderOptions,
dbUser, dbPassword, dbUrl, ezConnectString, isStagingClearText,
dbUser, dbPassword, dbUrl, ezConnectString,
buildDatabaseWriterSettings(filters, errorHandlers, conflictSettings, resolvedData));
}

Oops, something went wrong.

0 comments on commit 151d5a2

Please sign in to comment.
You can’t perform that action at this time.