Skip to content

Commit

Permalink
0006395: Moved bulk loader parameters from symmetric-ds to symmetric-pro
Browse files Browse the repository at this point in the history
  • Loading branch information
@evan-miller-jumpmind
evan-miller-jumpmind committed May 6, 2024
1 parent 6c5e035 commit 1c09129
Show file tree
Hide file tree
Showing 2 changed files with 0 additions and 355 deletions.
45 changes: 0 additions & 45 deletions symmetric-core/src/main/java/org/jumpmind/symmetric/common/ParameterConstants.java
View file
Original file line number Diff line number Diff line change
Expand Up @@ -247,23 +247,12 @@ private ParameterConstants() {
public final static String DBDIALECT_ORACLE_USE_SELECT_START_DATA_ID_HINT = "oracle.use.select.data.using.start.data.id.hint";
public final static String DBDIALECT_ORACLE_SEQUENCE_NOORDER = "oracle.sequence.noorder";
public final static String DBDIALECT_ORACLE_SEQUENCE_NOORDER_NEXTVALUE_DB_URLS = "oracle.sequence.noorder.nextvalue.db.urls";
public final static String DBDIALECT_ORACLE_BULK_LOAD_SQLLDR_CMD = "oracle.bulk.load.sqlldr.cmd";
public final static String DBDIALECT_ORACLE_BULK_LOAD_SQLLDR_OPTIONS = "oracle.bulk.load.sqlldr.options";
public final static String DBDIALECT_ORACLE_BULK_LOAD_SQLLDR_INFILE_CHARSET = "oracle.bulk.load.sqlldr.infile.charset";
public final static String DBDIALECT_ORACLE_BULK_LOAD_EZCONNECT = "oracle.bulk.load.ezconnect";
public final static String DBDIALECT_ORACLE_BULK_FIELD_TERMINATOR = "oracle.bulk.load.field.terminator";
public final static String DBDIALECT_ORACLE_BULK_LINE_TERMINATOR = "oracle.bulk.load.line.terminator";
public final static String DBDIALECT_ORACLE_LOAD_QUERY_HINT_PARALLEL_COUNT = "oracle.load.query.hint.parallel.count";
public final static String DBDIALECT_ORACLE_USE_NTYPES_FOR_SYNC = "oracle.use.ntypes.for.sync";
public final static String DBDIALECT_ORACLE_JDBC_LOB_HANDLING = "oracle.jdbc.lob.handling";
public final static String DBDIALECT_TIBERO_USE_TRANSACTION_VIEW = "tibero.use.transaction.view";
public final static String DBDIALECT_TIBERO_TEMPLATE_NUMBER_SPEC = "tibero.template.precision";
public final static String DBDIALECT_TIBERO_USE_HINTS = "tibero.use.hints";
public final static String DBDIALECT_TIBERO_BULK_LOAD_TBLOADER_CMD = "tibero.bulk.load.tbloader.cmd";
public final static String DBDIALECT_TIBERO_BULK_LOAD_TBLOADER_OPTIONS = "tibero.bulk.load.tbloader.options";
public final static String DBDIALECT_TIBERO_BULK_LOAD_DBNAME = "tibero.bulk.load.dbname";
public final static String DBDIALECT_TIBERO_BULK_LINE_TERMINATOR = "tibero.bulk.load.line.terminator";
public final static String DBDIALECT_TIBERO_BULK_FIELD_TERMINATOR = "tibero.bulk.load.field.terminator";
public final static String DBDIALECT_ORACLE_TRANSACTION_VIEW_CLOCK_SYNC_THRESHOLD_MS = "oracle.transaction.view.clock.sync.threshold.ms";
public final static String DATA_ID_INCREMENT_BY = "data.id.increment.by";
public final static String TRANSPORT_HTTP_MANUAL_REDIRECTS_ENABLED = "http.manual.redirects.enabled";
Expand Down Expand Up @@ -379,14 +368,6 @@ private ParameterConstants() {
public final static String MSSQL_INCLUDE_CATALOG_IN_TRIGGERS = "mssql.include.catalog.in.triggers";
public final static String MSSQL_TRIGGER_EXECUTE_AS = "mssql.trigger.execute.as";
public final static String MSSQL_TRIGGER_ORDER_FIRST = "mssql.trigger.order.first";
public final static String MSSQL_BULK_LOAD_MAX_ROWS_BEFORE_FLUSH = "mssql.bulk.load.max.rows.before.flush";
public final static String MSSQL_BULK_LOAD_FIRE_TRIGGERS = "mssql.bulk.load.fire.triggers";
public final static String MSSQL_BULK_LOAD_UNC_PATH = "mssql.bulk.load.unc.path";
public final static String MSSQL_BULK_LOAD_ROW_TERMINATOR = "mssql.bulk.load.row.terminator";
public final static String MSSQL_BULK_LOAD_FIELD_TERMINATOR = "mssql.bulk.load.field.terminator";
public final static String MSSQL_BULK_LOAD_USE_BCP = "mssql.bulk.load.use.bcp";
public final static String MSSQL_BULK_LOAD_BCP_CMD = "mssql.bulk.load.bcp.cmd";
public final static String MSSQL_BULK_LOAD_BCP_KEEP_NULL_VALUES = "mssql.bulk.load.bcp.keep.null.values";
public final static String MSSQL_USE_SNAPSHOT_ISOLATION = "mssql.use.snapshot.isolation";
public final static String DBDIALECT_SYBASE_ASE_CONVERT_UNITYPES_FOR_SYNC = "sybase.ase.convert.unitypes.for.sync";
public final static String SYBASE_ROW_LEVEL_LOCKS_ONLY = "sybase.allow.only.row.level.locks.on.runtime.tables";
Expand Down Expand Up @@ -437,10 +418,6 @@ private ParameterConstants() {
public final static String ALLOW_TRIGGER_CREATE_OR_REPLACE = "trigger.allow.create.or.replace";
public final static String NODE_LOAD_ONLY = "load.only";
public final static String MYSQL_TINYINT_DDL_TO_BOOLEAN = "mysql.tinyint.ddl.to.boolean";
public final static String MYSQL_BULK_LOAD_MAX_ROWS_BEFORE_FLUSH = "mysql.bulk.load.max.rows.before.flush";
public final static String MYSQL_BULK_LOAD_MAX_BYTES_BEFORE_FLUSH = "mysql.bulk.load.max.bytes.before.flush";
public final static String MYSQL_BULK_LOAD_LOCAL = "mysql.bulk.load.local";
public final static String MYSQL_BULK_LOAD_REPLACE = "mysql.bulk.load.replace";
public static final String LOAD_ONLY_PROPERTY_PREFIX = "target.";
public final static String KAFKA_PRODUCER = "kafka.producer";
public final static String KAFKA_FORMAT = "kafka.format";
Expand All @@ -459,33 +436,11 @@ private ParameterConstants() {
KAFKACLIENT_SSL_KEYSTORE_TYPE };
public final static String SNOWFLAKE_STAGING_TYPE = "snowflake.staging.type";
public final static String SNOWFLAKE_INTERNAL_STAGE_NAME = "snowflake.internal.stage.name";
public final static String CLOUD_BULK_LOAD_MAX_ROWS_BEFORE_FLUSH = "cloud.bulk.load.max.rows.before.flush";
public final static String CLOUD_BULK_LOAD_MAX_BYTES_BEFORE_FLUSH = "cloud.bulk.load.max.bytes.before.flush";
public final static String CLOUD_BULK_LOAD_S3_BUCKET = "cloud.bulk.load.s3.bucket";
public final static String CLOUD_BULK_LOAD_S3_ACCESS_KEY = "cloud.bulk.load.s3.access.key";
public final static String CLOUD_BULK_LOAD_S3_SECRET_KEY = "cloud.bulk.load.s3.secret.key";
public final static String CLOUD_BULK_LOAD_S3_ENDPOINT = "cloud.bulk.load.s3.endpoint";
public final static String CLOUD_BULK_LOAD_S3_REGION = "cloud.bulk.load.s3.region";
public final static String CLOUD_BULK_LOAD_AZURE_ACCOUNT_NAME = "cloud.bulk.load.azure.account.name";
public final static String CLOUD_BULK_LOAD_AZURE_ACCOUNT_KEY = "cloud.bulk.load.azure.account.key";
public final static String CLOUD_BULK_LOAD_AZURE_BLOB_CONTAINER = "cloud.bulk.load.azure.blob.container";
public final static String CLOUD_BULK_LOAD_AZURE_SAS_TOKEN = "cloud.bulk.load.azure.sas.token";
public final static String CLOUD_BULK_ROW_TERMINATOR = "cloud.bulk.row.terminator";
public final static String CLOUD_BULK_FIELD_TERMINATOR = "cloud.bulk.field.terminator";
public final static String CLOUD_BULK_FIELD_QUOTE = "cloud.bulk.field.quote";
public final static String CLOUD_BULK_CODEPAGE = "cloud.bulk.codepage";
public final static String SNAPSHOT_FILE_INCLUDE_HOSTNAME = "snapshot.file.include.hostname";
public final static String SNAPSHOT_MAX_FILES = "snapshot.max.files";
public final static String SNAPSHOT_MAX_BATCHES = "snapshot.max.batches";
public final static String SNAPSHOT_MAX_NODE_CHANNELS = "snapshot.max.node.channels";
public final static String SNAPSHOT_OPERATION_TIMEOUT_MS = "snapshot.operation.timeout.ms";
public final static String REDSHIFT_APPEND_TO_COPY_COMMAND = "redshift.append.to.copy.command";
public final static String REDSHIFT_BULK_LOAD_MAX_ROWS_BEFORE_FLUSH = "redshift.bulk.load.max.rows.before.flush";
public final static String REDSHIFT_BULK_LOAD_MAX_BYTES_BEFORE_FLUSH = "redshift.bulk.load.max.bytes.before.flush";
public final static String REDSHIFT_BULK_LOAD_S3_BUCKET = "redshift.bulk.load.s3.bucket";
public final static String REDSHIFT_BULK_LOAD_S3_ACCESS_KEY = "redshift.bulk.load.s3.access.key";
public final static String REDSHIFT_BULK_LOAD_S3_SECRET_KEY = "redshift.bulk.load.s3.secret.key";
public final static String REDSHIFT_BULK_LOAD_S3_ENDPOINT = "redshift.bulk.load.s3.endpoint";
public final static String POSTGRES_SECURITY_DEFINER = "postgres.security.definer";
public final static String[] ALL_JDBC_PARAMS = new String[] { DB_FETCH_SIZE, DB_QUERY_TIMEOUT_SECS, JDBC_EXECUTE_BATCH_SIZE, JDBC_ISOLATION_LEVEL,
JDBC_READ_STRINGS_AS_BYTES, TREAT_BINARY_AS_LOB_ENABLED, LOG_SLOW_SQL_THRESHOLD_MILLIS, LOG_SQL_PARAMETERS_INLINE };
Expand Down

0 comments on commit 1c09129

Please sign in to comment.