public class EtlFactory
extends Object
Scenario
Modifier and Type | Field and Description |
---|---|
static String |
ACTION_ATTR
The ACTION_ATTR.
|
static String |
ACTUAL_CONNECTION_NAME_NODE
The ACTUAL_CONNECTION_NAME_NODE.
|
static String |
AFTER_TASKS_NODE
The AFTER LOAD_NODE TASKS_NODE.
|
static String |
AFTER_TASKS_OWNER_NAME_VALUE
The AFTER_TASKS_OWNER_NAME_VALUE.
|
static String |
BEFORE_SQL_NODE
The BEFORE_SQL_NODE.
|
static String |
BEFORE_TASKS_NODE
The BEFORE EXTRACT_NODE TASKS_NODE.
|
static String |
BEFORE_TASKS_OWNER_NAME_VALUE
The BEFORE_TASKS_OWNER_NAME_VALUE.
|
static String |
BLOCK_OWNER_NODE
The BLOCK OWNER.
|
static String |
CLASS_NAME_ATTR
The CLASS_NAME_ATTR.
|
static String |
CODE_NODE
The CODE_NODE.
|
static String |
CONDITION_CODE_ATTR
The CONDITION_CODE_ATTR.
|
static String |
CONDITION_CONNECTION_ATTR
The CONDITION_CONNECTION_ATTR.
|
static String |
CONDITION_LANG_ATTR
The CONDITION_LANG_ATTR.
|
static String |
CONNECTION_PARALLEL_ATTR
The CONNECTION_PARALLEL_ATTR.
|
static String |
DEST_AFTER_NODE
The DEST_AFTER_NODE.
|
static String |
DEST_AS_A_SOURCE_ATTR
The DEST_AS_A_SOURCE_ATTR.
|
static String |
DEST_CACHE_CLASS_NAME_NODE
The DEST_CACHE_CLASS_NAME_NODE.
|
static String |
DEST_CONDITION_NODE
The DEST_CONDITION_NODE.
|
static String |
DEST_CONNECTION_NAME_NODE
The DEST_CONNECTION_NAME_NODE.
|
static String |
DEST_CREATE_TABLE_TEMPLATE_ATTR
The DEST_CREATE_TABLE_TEMPLATE_ATTR.
|
static String |
DEST_CURSOR_NAME_ATTR
The DEST_CURSOR_TABLE_NAME_ATTR.
|
static String |
DEST_CURSOR_NODE
The DEST_CURSOR_NODE.
|
static String |
DEST_CURSOR_SQL_ATTR
The DEST_CURSOR_SQL_ATTR.
|
static String |
DEST_CURSOR_TABLE_NAME_ATTR
The DEST_CURSOR_TABLE_NAME_ATTR.
|
static String |
DEST_CURSOR_TABLE_ON_FINISH_ATTR
The DEST_CURSOR_TABLE_ON_FINISH_ATTR.
|
static String |
DEST_CURSOR_TABLE_TYPE_ATTR
The DEST_CURSOR_TABLE_TYPE_ATTR.
|
static String |
DEST_ELSE_NODE
The DEST_ELSE_NODE.
|
static String |
DEST_ENABLED_ATTR
The DEST_ENABLED_ATTR.
|
static String |
DEST_ENCODE_ATTR
The DEST_ENCODE_ATTR.
|
static String |
DEST_EXT_BLOB_ATTR
The DEST_EXT_BLOB_ATTR.
|
static String |
DEST_GROUP_THREADS_ATTR
The DEST_GROUP_THREADS_ATTR.
|
static String |
DEST_IS_EMPTY_ATTR
The DEST_IS_EMPTY_ATTR.
|
static String |
DEST_METRICS_ENABLED_ATTR
The DEST_METRICS_ENABLED_ATTR.
|
static String |
DEST_NEW_CONNECTION_ATTR
The DEST_NEW_CONNECTION_ATTR.
|
static String |
DEST_PARALLEL_ATTR
The DEST_PARALLEL_ATTR.
|
static String |
DEST_READER_NODE
The DEST_READER_NODE.
|
static String |
DEST_SCOPE_ATTR
The DEST_SCOPE_ATTR.
|
static String |
DEST_SOURCE_NAME_NODE
The DEST_SOURCE_NAME_NODE.
|
static String |
DEST_SOURCE_TABLE_NODE
The DEST_SOURCE_TABLE_NODE.
|
static String |
DEST_TEMP_TABLE_ATTR
The DEST_TEMP_TABLE_ATTR.
|
static String |
DEST_THEN_NODE
The DEST_THEN_NODE.
|
static String |
DEST_TOLERATE_ATTR
The DEST_TOLERATE_ATTR.
|
static String |
DEST_TYPE_ATTR
The DEST_TYPE_ATTR.
|
static String |
DEST_WRITER_NODE
The DEST_WRITER_NODE.
|
static String |
DESTINATION_NAME_NODE
The DESTINATION_NAME_NODE.
|
static String |
DESTINATION_NODE
The DESTINATION_NODE.
|
static String |
DESTINATIONS_NODE
The DESTINATIONS_NODE.
|
static String |
DRIVER_ALWAYS_QUOTE_ATTR
The DRIVER_ALWAYS_QUOTE_ATTR.
|
static String |
DRIVER_AUTO_VALUE
Auto discover driver.
|
static String |
DRIVER_CASE_SENSITIVE_ATTR
The DRIVER_CASE_SENSITIVE_ATTR.
|
static String |
DRIVER_CHAR_SIZE_ATTR
The DRIVER_CHAR_SIZE_ATTR.
|
static String |
DRIVER_CLASS_NAME_NODE
The DRIVER_CLASS_NAME_NODE.
|
static String |
DRIVER_INIT_SQL_ATTR
The DRIVER_INIT_SQL_ATTR.
|
static String |
DRIVER_LINES_LIMIT_ATTR
The DRIVER_LINES_LIMIT_ATTR.
|
static String |
DRIVER_NAME_ATTR
The DRIVER_NAME_ATTR.
|
static String |
DRIVER_PARENT_ATTR
The DRIVER_PARENT_ATTR.
|
static String |
DRIVER_PRECISION_ATTR
The DRIVER_PRECISION_ATTR.
|
static String |
DRIVER_SCALE_ATTR
The DRIVER_SCALE_ATTR.
|
static String |
DRIVER_STRING_LITERAL_SIZE_ATTR
The DRIVER_STRING_LITERAL_SIZE_ATTR.
|
static String |
DRIVER_VARCHAR_SIZE_ATTR
The DRIVER_VARCHAR_SIZE_ATTR.
|
static String |
EXCEPTION_KEY_FIELD_ATTR
The EXCEPTION_KEY_FIELD_ATTR.
|
static String |
EXCEPTION_MASK_ATTR
The EXCEPTION_MASK_ATTR.
|
static String |
EXCEPTION_MESSAGE_ATTR
The EXCEPTION_MESSAGE_ATTR.
|
static String |
EXCEPTION_SAVEPOINT_ATTR
The EXCEPTION_SAVEPOINT_ATTR.
|
static String |
EXCLUDE_NODE
The EXCLUDE_NODE.
|
static String |
EXECUTE_NODE
The EXECUTE_NODE.
|
static String |
EXTRACT_NODE
The EXTRACT_NODE.
|
static String |
HIGH_WATERMARK_EXCEPTION_TO_IGNORE_ATTR
The Constant HIGH_WATERMARK_EXCEPTION_TO_IGNORE_ATTR.
|
static String |
INCLUDE_NODE
The INCLUDE_NODE.
|
static String |
INNER_SCENARIO_NODE
The INNER_SCENARIO_NODE.
|
static String |
INNER_SCENARIO_ON_EXCEPTION_ATTR
The SCENARIO_ON_EXCEPTION_ATTR.
|
static String |
INNER_SCENARIO_PARELLEL_ATTR
The INNER_SCENARIO_PARELLEL_ATTR.
|
static String |
LINKED_SOURCE_NAME_NODE
The LINKED_SOURCE_NAME_NODE.
|
static String |
LOAD_ACTION_ATTR
The LOAD_ACTION_ATTR.
|
static String |
LOAD_ACTION_COND_ATTR
The LOAD_ACTION_CONDITIONS.
|
static String |
LOAD_ACTION_LANG_ATTR
The LOAD_ACTION_LANG.
|
static String |
LOAD_AUTOSELECT_KEY_ATTR |
static String |
LOAD_BATCH_WINDOW_ATTR
The LOAD_BATCH_WINDOW_ATTR.
|
static String |
LOAD_FORCE_BIND_ATTR
The LOAD_FORCE_BIND_ATTR.
|
static String |
LOAD_HIGH_WATERMARK_ATTR
The LOAD_HIGH_WATERMARK_ATTR.
|
static String |
LOAD_HIGH_WATERMARK_CODE_ATTR
The LOAD_HIGH_WATERMARK_CODE_ATTR.
|
static String |
LOAD_HIGH_WATERMARK_VALUE_ATTR
The LOAD_HIGH_WATERMARK_VALUE_ATTR.
|
static String |
LOAD_HIGH_WATERMARK_VALUE_ON_START_ATTR
The LOAD_HIGH_WATERMARK_VALUE_ATTR.
|
static String |
LOAD_IS_STREAM_ATTR
The LOAD_IS_STREAM_ATTR.
|
static String |
LOAD_KEY_ATTR
The LOAD_KEY_ATTR.
|
static String |
LOAD_NODE
The LOAD_NODE.
|
static String |
LOAD_REPLICATION_ATTR
The LOAD_REPLICATION_ATTR.
|
static String |
LOAD_SKIP_DELETE_WITH_MERGE |
static String |
LOAD_USE_BIND_VARS_ATTR
The LOAD_USE_BIND_VARS_ATTR.
|
static String |
LOAD_WRITER_ATTR
The WRITER_ATTR.
|
static String |
MATCH_NODE
The MATCH_NODE.
|
static String |
MERGE_METRICS_ATTR
The MERGE_METRICS_ATTR.
|
static String |
METADATA_EXTRACTOR_ALTER_ATTR
The Constant METADATA_EXTRACTOR_ALTER_ATTR.
|
static String |
METADATA_EXTRACTOR_CREATE_ATTR
The Constant METADATA_EXTRACTOR_CREATE_ATTR.
|
static String |
METADATA_EXTRACTOR_DEST_ATTR
The Constant METADATA_EXTRACTOR_DEST_ATTR.
|
static String |
METADATA_EXTRACTOR_INDEX_SUFFIX_ATTR
The METADATA_EXTRACTOR_INDEX_SUFFIX_ATTR.
|
static String |
METADATA_EXTRACTOR_INDEXES_ATTR
The METADATA_EXTRACTOR_INDEX.
|
static String |
METADATA_EXTRACTOR_NODE
The METADATA_EXTRACTOR_NODE.
|
static String |
METADATA_EXTRACTOR_ORDER_ATTR
The Constant METADATA_EXTRACTOR_ORDER_ATTR.
|
static String |
METADATA_EXTRACTOR_SOURCE_ATTR
The Constant METADATA_EXTRACTOR_SOURCE_ATTR.
|
static String |
METADATA_EXTRACTOR_TYPES_ATTR
The METADATA_EXTRACTOR_TYPES_ATTR.
|
static String |
METRICS_FOLDER_ATTR
The METRICS_FOLDER_ATTR.
|
static String |
NO_CONNECTION_ATTR
The NO_CONNECTION_ATTR.
|
static String |
OBJECT_NAME_NODE
The OBJECT_NAME_NODE.
|
static String |
ON_EXCEPTION_NODE
The ON_EXCEPTION_NODE.
|
static String |
ON_EXECUTE_COMMIT_VALUE
The ON_EXECUTE_COMMIT_VALUE.
|
static int |
PARSE_ALL_PARAM
The PARSE_ALL_PARAM.
|
static int |
PARSE_RECURSVIVELY_PARAM
The PARSE_RECURSVIVELY_PARAM.
|
static int |
PARSE_STRUCTURE_ONLY_PARAM
The PARSE_STRUCTURE_ONLY_PARAM.
|
static String |
SCENARIO_ACTION_ATTR
The SCENARIO_ACTION_ATTR.
|
static String |
SCENARIO_ALLOWED_ACTIONS_NODE
The SCENARIO_ALLOWED_ACTIONS_NODE.
|
static String |
SCENARIO_CODEGEN_CLASS_NAME_NODE
The SCENARIO_CODEGEN_CLASS_NAME_NODE.
|
static String |
SCENARIO_CONNECTION_NAME_NODE
The SCENARIO_CONNECTION_NAME_NODE.
|
static String |
SCENARIO_DEF_FUNCTION_CLASS_NAME_NODE
The SCENARIO_DEF_FUNCTION_CLASS_NAME_NODE.
|
static String |
SCENARIO_DESCRIPTION_NODE
The SCENARIO_DESCRIPTION_NODE.
|
static String |
SCENARIO_LOOP_CODE_ATTR
The SCENARIO_LOOP_CODE_ATTR.
|
static String |
SCENARIO_LOOP_CONNECTION_ATTR
The SCENARIO_LOOP_CONNECTION_ATTR.
|
static String |
SCENARIO_LOOP_COUNT_ATTR
The SCENARIO_LOOP_COUNT_ATTR.
|
static String |
SCENARIO_LOOP_FIELD_ATTR
The SCENARIO_LOOP_FIELD_ATTR.
|
static String |
SCENARIO_LOOP_LANG_ATTR
The SCENARIO_LOOP_LANG_ATTR.
|
static String |
SCENARIO_LOOP_THREADS_ATTR
The SCENARIO_LOOP_THREADS_ATTR.
|
static String |
SCENARIO_LOOP_VAR_ATTR
The SCENARIO_LOOP_VAR_ATTR.
|
static String |
SCENARIO_LOOP_VAR_PATTERN_ATTR
The SCENARIO_LOOP_VAR_PATTERN_ATTR.
|
static String |
SCENARIO_MAX_LOOP_ITERATIONS_ATTR
The SCENARIO_MAX_LOOP_ITERATIONS_ATTR.
|
static String |
SCENARIO_NAME_NODE
The SCENARIO_NAME_NODE.
|
static String |
SCENARIO_NO_TEMP_ATTR
The Constant SCENARIO_NO_TEMP_ATTR.
|
static String |
SCENARIO_NODE
The SCENARIO_NODE.
|
static String |
SCENARIO_ON_EXECUTE_NODE
The SCENARIO_ON_EXECUTE_NODE.
|
static String |
SCENARIO_ON_PERSIST_NODE
The SCENARIO_ON_PERSIST_NODE.
|
static String |
SCENARIO_ON_POPULATE_NODE
The SCENARIO_ON_POPULATE_NODE.
|
static String |
SCENARIO_ON_SAVE_NODE
The SCENARIO_ON_SAVE_NODE.
|
static String |
SCENARIO_REQUIRE_DEST_ATTR
The Constant SCENARIO_REQUIRE_DEST_ATTR.
|
static String |
SCENARIO_REQUIRE_SOURCE_ATTR
The Constant SCENARIO_REQUIRE_SOURCE_ATTR.
|
static String |
SCENARIO_SCRIPT_NAME_NODE
The SCENARIO_SCRIPT_NAME_NODE.
|
static String |
SOURCE_CONNECTION_NAME_NODE
The SOURCE_CONNECTION_NAME_NODE.
|
static String |
SOURCE_DRIVER_CLASS_NAME_NODE
The SOURCE_DRIVER_CLASS_NAME_NODE.
|
static String |
SOURCE_EMPTY_ATTR
The SOURCE_EMPTY_ATTR.
|
static String |
SOURCE_ENABLED_ATTR
The SOURCE_ENABLED_ATTR.
|
static String |
SOURCE_ENCODE_ATTR
The SOURCE_ENCODE_ATTR.
|
static String |
SOURCE_FETCH_SIZE_ATTR
The SOURCE_FETCH_SIZE_ATTR.
|
static String |
SOURCE_FILE_TRACKING_ENABLED_ATTR
The SOURCE_FILE_TRACKING_ENABLED_ATTR.
|
static String |
SOURCE_IGNORE_EMPTY_ATTR
The SOURCE_IGNORE_EMPTY_ATTR.
|
static String |
SOURCE_IGNORE_NO_RECORDS_ATTR
The SOURCE_IGNORE_NO_RECORDS_ATTR.
|
static String |
SOURCE_INDEPENDENT_ATTR
The SOURCE_INDEPENDENT_ATTR.
|
static String |
SOURCE_KEY_FIELDS_ATTR
The SOURCE_KEY_FIELDS_ATTR.
|
static String |
SOURCE_KEY_NAME_ATTR
The SOURCE_KEY_NAME_ATTR.
|
static String |
SOURCE_LIMIT_ATTR
The SOURCE_LIMIT_ATTR.
|
static String |
SOURCE_MANDATORY_ATTR
The SOURCE_MANDATORY_ATTR.
|
static String |
SOURCE_MAX_FILES_ATTR |
static String |
SOURCE_METRICS_ENABLED_ATTR
The SOURCE_METRICS_ENABLED_ATTR.
|
static String |
SOURCE_NAME_NODE
The SOURCE_NAME_NODE.
|
static String |
SOURCE_NEW_CONNECTION_ATTR |
static String |
SOURCE_NEW_CONNECTION_SOURCE_QUERY_ATTR |
static String |
SOURCE_NODE
The SOURCE_NODE.
|
static String |
SOURCE_PARALLEL_ATTR
The SOURCE_PARALLEL_ATTR.
|
static String |
SOURCE_READER_NODE
The SOURCE_READER_NODE.
|
static String |
SOURCE_SQL_STATEMENT_PARAM_INDEX_NODE
The SOURCE SQL STATEMENT OUTPUT PARAMETER INDEX NODE.
|
static String |
SOURCE_SQL_STATEMENT_TYPE_NODE
The SOURCE SQL STATEMENT TYPE NODE.
|
static String |
SOURCE_UPDATE_KEY_ATTR
The SOURCE_UPDATE_KEY_ATTR.
|
static String |
SOURCE_WILCARD_ENABLED_ATTR |
static String |
SOURCE_WILDCARD_PARALLEL_ATTR
The SOURCE_WILDCARD_PARALLEL_ATTR.
|
static String |
SOURCE_WRITER_NODE
The SOURCE_WRITER_NODE.
|
static String |
SOURCES_NODE
The SOURCES_NODE.
|
static String |
SQL_NODE
The SQL_NODE.
|
static String |
TABLE_NAME_NODE
The TABLE_NAME_NODE.
|
static String |
TARGET_DRIVER_NODE
The TARGET_DRIVER_NODE.
|
static String |
TARGET_NODE
The TARGET_NODE.
|
static String |
TASK_ASYNCHRONOUS_ATTR
The TASK_ASYNCHRONOUS_ATTR.
|
static String |
TASK_CLASS_NAME_NODE
The TASK_CLASS_NAME_NODE.
|
static String |
TASK_CMD_NODE
The TASK_CMD_NODE.
|
static String |
TASK_CODE_NODE
The TASK_CODE_NODE.
|
static String |
TASK_COMMAND_NODE
The TASK_COMMAND_NODE.
|
static String |
TASK_COMMIT_ATTR
The TASK_COMMIT_ATTR.
|
static String |
TASK_CONNECTION_NAME_NODE
The TASK_CONNECTION_NAME_NODE.
|
static String |
TASK_ENABLED_ATTR
The TASK_ENABLED_ATTR.
|
static String |
TASK_IS_FINAL_ATTR |
static String |
TASK_MESSAGE_NODE
The TASK_MESSAGE_NODE.
|
static String |
TASK_METRICS_ENABLED_ATTR
The TASK_METRICS_ENABLED_ATTR.
|
static String |
TASK_NAME_NODE
The TASK_NAME_NODE.
|
static String |
TASK_NODE
The TASK_NODE.
|
static String |
TASK_SCOPE_ATTR
The TASK_SCOPE_ATTR.
|
static String |
TASK_SQL_NODE
The TASK_SQL_NODE.
|
static String |
TASK_TABLE_NAME_NODE
The TASK_TABLE_NAME_NODE.
|
static String |
TASK_USING_NODE
The TASK_USING_NODE.
|
static String |
TASKS_NODE
The TASKS_NODE.
|
static String |
TRACK_METRICS_ATTR
The TRACK_METRICS_ATTR.
|
static String |
USE_METADATA_ATTR
The USE_METADATA_ATTR.
|
static String |
USING_NODE
The USING_NODE.
|
static String |
VAR_ADD_ATTR
The VAR_ADD_ATTR.
|
static String |
VAR_CLASS_NAME_ATTR
The VAR_CLASS_NAME_ATTR.
|
static String |
VAR_CODE_ATTR
The VAR_CODE_ATTR.
|
static String |
VAR_DECLARE_ATTR
The VAR_DECLARE_ATTR.
|
static String |
VAR_EXCLUDE_ATTR
The VAR_EXCLUDE_ATTR.
|
static String |
VAR_FIELD_NAME_ATTR
The VAR_FIELD_NAME_ATTR.
|
static String |
VAR_FUNC_NAME_ATTR
The VAR_FUNC_NAME_ATTR.
|
static String |
VAR_GLOBAL_ATTR
The VAR_GLOBAL_ATTR.
|
static String |
VAR_INCLUDE_ATTR
The VAR_INCLUDE_ATTR.
|
static String |
VAR_ITEM_ATTR
The VAR_ITEM_ATTR.
|
static String |
VAR_LABEL_ATTR
The VAR_LABEL_ATTR.
|
static String |
VAR_LANG_ATTR
The VAR_LANG_ATTR.
|
static String |
VAR_LINKED_DEST_NAME_ATTR
The VAR_LINKED_DEST_NAME_ATTR.
|
static String |
VAR_LINKED_NAME_ATTR
The VAR_LINKED_NAME_ATTR.
|
static String |
VAR_NAME_ATTR
The VAR_NAME_ATTR.
|
static String |
VAR_PARAM_ATTR
The VAR_PARAM_ATTR.
|
static String |
VAR_SCOPE_ATTR
The VAR_SCOPE_ATTR.
|
static String |
VAR_SQL_ATTR
The VAR_SQL_ATTR.
|
static String |
VAR_TABLE_NAME_ATTR
The VAR_TABLE_NAME_ATTR.
|
static String |
VAR_TOLERATE_ATTR
The VAR_TOLERATE_ATTR.
|
static String |
VAR_TYPE_ATTR
The VAR_TYPE_ATTR.
|
static String |
VAR_VALUE_ATTR
The VAR_VALUE_ATTR.
|
static String |
VARIABLES_NODE
The VARIABLES_NODE.
|
static String |
WRITE_METRICS_ATTR
The WRITE_METRICS_ATTR.
|
Constructor and Description |
---|
EtlFactory() |
Modifier and Type | Method and Description |
---|---|
void |
checkSyntaxt(String code)
Checks etl scenario syntax.
|
Driver |
getDriver(String value,
DriverDiscovery driverDiscovery,
String jdbcClassName)
Gets the driver using given string.
|
String |
getDriverCase(String value)
Gets the driver case.
|
String |
getDriverClassName(String value)
Gets the driver class name from the given string.
|
String |
getParentDriverClassName(String value)
Gets the parent driver class name from the given string.
|
Scenario |
getScenario(EtlConfig config,
String fileName)
Gets the scenario using PARSE_ALL_PARAM scope.
|
Scenario |
getScenario(EtlConfig config,
String fileName,
int parseScope)
Gets the scenario.
|
void |
parseAfterTasks(EtlConfig config,
XmlUtils xml,
org.w3c.dom.Node treesNode,
Scenario scenario)
Parses "after" tasks.
|
void |
parseBeforeTasks(EtlConfig config,
XmlUtils xml,
org.w3c.dom.Node treesNode,
Scenario scenario,
String rootNodeName)
Parses "before" tasks.
|
void |
parseDestinations(EtlConfig config,
XmlUtils xml,
org.w3c.dom.Node treesNode,
Scenario scenario)
Parses the destinations.
|
Scenario |
parseScenario(EtlConfig config,
String code)
Parses the scenario using PARSE_ALL_PARAM scope.
|
Scenario |
parseScenario(EtlConfig config,
String code,
int parseScope)
Parses the scenario.
|
Scenario |
parseScenario(EtlConfig config,
XmlUtils xml,
int parseScope)
Parses the scenario.
|
Scenario |
parseScenario(EtlConfig config,
XmlUtils xml,
int parseScope,
org.w3c.dom.Node rootNode)
Parses the scenario.
|
void |
parseScenarioVariables(XmlUtils xml,
Scenario scenario,
org.w3c.dom.Node rootNode,
EtlConfig config)
Parses the scenario variables.
|
void |
parseSources(EtlConfig config,
XmlUtils xml,
org.w3c.dom.Node treesNode,
Scenario scenario)
Parses the sources.
|
void |
parseTasks(EtlConfig config,
XmlUtils xml,
org.w3c.dom.Node rootNode,
Scenario scenario,
Block block,
String rootNodeName)
Parses tasks for the etl block.
|
void |
parseVariableAttrs(XmlUtils xml,
org.w3c.dom.Node variableNode,
Variable var)
Parses variable attributes.
|
void |
parseVariableObject(XmlUtils xml,
org.w3c.dom.Node variableNode,
Variable var)
Parses the variable object.
|
public static final String SCENARIO_NODE
public static final String SCENARIO_REQUIRE_SOURCE_ATTR
public static final String SCENARIO_REQUIRE_DEST_ATTR
public static final String SCENARIO_NO_TEMP_ATTR
public static final String SCENARIO_ON_SAVE_NODE
public static final String SCENARIO_ON_PERSIST_NODE
public static final String SCENARIO_ON_POPULATE_NODE
public static final String SCENARIO_ON_EXECUTE_NODE
public static final String DEST_AS_A_SOURCE_ATTR
public static final String DEST_SCOPE_ATTR
public static final String LOAD_IS_STREAM_ATTR
public static final String LOAD_HIGH_WATERMARK_ATTR
public static final String HIGH_WATERMARK_EXCEPTION_TO_IGNORE_ATTR
public static final String LOAD_HIGH_WATERMARK_VALUE_ATTR
public static final String LOAD_HIGH_WATERMARK_CODE_ATTR
public static final String LOAD_HIGH_WATERMARK_VALUE_ON_START_ATTR
public static final String LOAD_REPLICATION_ATTR
public static final String LOAD_WRITER_ATTR
public static final String SCENARIO_ALLOWED_ACTIONS_NODE
public static final String ACTION_ATTR
public static final String CLASS_NAME_ATTR
public static final String SCENARIO_NAME_NODE
public static final String CODE_NODE
public static final String SCENARIO_DESCRIPTION_NODE
public static final String SCENARIO_DEF_FUNCTION_CLASS_NAME_NODE
public static final String METADATA_EXTRACTOR_NODE
public static final String USE_METADATA_ATTR
public static final String METADATA_EXTRACTOR_TYPES_ATTR
public static final String METADATA_EXTRACTOR_INDEXES_ATTR
public static final String METADATA_EXTRACTOR_INDEX_SUFFIX_ATTR
public static final String METADATA_EXTRACTOR_SOURCE_ATTR
public static final String METADATA_EXTRACTOR_DEST_ATTR
public static final String METADATA_EXTRACTOR_CREATE_ATTR
public static final String METADATA_EXTRACTOR_ALTER_ATTR
public static final String METADATA_EXTRACTOR_ORDER_ATTR
public static final String SCENARIO_CODEGEN_CLASS_NAME_NODE
public static final String SCENARIO_CONNECTION_NAME_NODE
public static final String SCENARIO_LOOP_CODE_ATTR
public static final String SCENARIO_LOOP_COUNT_ATTR
public static final String SCENARIO_MAX_LOOP_ITERATIONS_ATTR
public static final String SCENARIO_LOOP_VAR_ATTR
public static final String SCENARIO_LOOP_VAR_PATTERN_ATTR
public static final String SCENARIO_LOOP_FIELD_ATTR
public static final String SCENARIO_LOOP_LANG_ATTR
public static final String CONDITION_CODE_ATTR
public static final String CONDITION_LANG_ATTR
public static final String SCENARIO_LOOP_CONNECTION_ATTR
public static final String SCENARIO_LOOP_THREADS_ATTR
public static final String CONDITION_CONNECTION_ATTR
public static final String CONNECTION_PARALLEL_ATTR
public static final String TRACK_METRICS_ATTR
public static final String WRITE_METRICS_ATTR
public static final String METRICS_FOLDER_ATTR
public static final String MERGE_METRICS_ATTR
public static final String SCENARIO_SCRIPT_NAME_NODE
public static final String DRIVER_CLASS_NAME_NODE
public static final String SOURCE_DRIVER_CLASS_NAME_NODE
public static final String DRIVER_NAME_ATTR
public static final String DRIVER_PARENT_ATTR
public static final String DRIVER_STRING_LITERAL_SIZE_ATTR
public static final String DRIVER_VARCHAR_SIZE_ATTR
public static final String DRIVER_CHAR_SIZE_ATTR
public static final String DRIVER_PRECISION_ATTR
public static final String DRIVER_SCALE_ATTR
public static final String DRIVER_LINES_LIMIT_ATTR
public static final String DRIVER_CASE_SENSITIVE_ATTR
public static final String DRIVER_INIT_SQL_ATTR
public static final String DRIVER_ALWAYS_QUOTE_ATTR
public static final String DRIVER_AUTO_VALUE
public static final String BLOCK_OWNER_NODE
public static final String SOURCE_INDEPENDENT_ATTR
public static final String SOURCE_EMPTY_ATTR
public static final String SOURCE_IGNORE_EMPTY_ATTR
public static final String SOURCE_IGNORE_NO_RECORDS_ATTR
public static final String SOURCE_MANDATORY_ATTR
public static final String SOURCE_NODE
public static final String SOURCES_NODE
public static final String SOURCE_NAME_NODE
public static final String LINKED_SOURCE_NAME_NODE
public static final String SOURCE_ENCODE_ATTR
public static final String SOURCE_ENABLED_ATTR
public static final String SOURCE_METRICS_ENABLED_ATTR
public static final String SOURCE_FILE_TRACKING_ENABLED_ATTR
public static final String SOURCE_WILCARD_ENABLED_ATTR
public static final String SOURCE_MAX_FILES_ATTR
public static final String SOURCE_NEW_CONNECTION_ATTR
public static final String SOURCE_NEW_CONNECTION_SOURCE_QUERY_ATTR
public static final String SOURCE_PARALLEL_ATTR
public static final String SOURCE_WILDCARD_PARALLEL_ATTR
public static final String SOURCE_CONNECTION_NAME_NODE
public static final String SOURCE_READER_NODE
public static final String SOURCE_WRITER_NODE
public static final String EXTRACT_NODE
public static final String BEFORE_SQL_NODE
public static final String SQL_NODE
public static final String EXCLUDE_NODE
public static final String INCLUDE_NODE
public static final String MATCH_NODE
public static final String USING_NODE
public static final String SOURCE_KEY_NAME_ATTR
public static final String SOURCE_LIMIT_ATTR
public static final String SOURCE_FETCH_SIZE_ATTR
public static final String SOURCE_KEY_FIELDS_ATTR
public static final String SOURCE_SQL_STATEMENT_TYPE_NODE
public static final String SOURCE_SQL_STATEMENT_PARAM_INDEX_NODE
public static final String SOURCE_UPDATE_KEY_ATTR
public static final String VARIABLES_NODE
public static final String DESTINATIONS_NODE
public static final String DESTINATION_NODE
public static final String DESTINATION_NAME_NODE
public static final String DEST_SOURCE_NAME_NODE
public static final String DEST_TYPE_ATTR
public static final String DEST_EXT_BLOB_ATTR
public static final String DEST_ENABLED_ATTR
public static final String DEST_METRICS_ENABLED_ATTR
public static final String DEST_PARALLEL_ATTR
public static final String DEST_GROUP_THREADS_ATTR
public static final String DEST_NEW_CONNECTION_ATTR
public static final String DEST_TEMP_TABLE_ATTR
public static final String DEST_CREATE_TABLE_TEMPLATE_ATTR
public static final String LOAD_USE_BIND_VARS_ATTR
public static final String LOAD_BATCH_WINDOW_ATTR
public static final String TABLE_NAME_NODE
public static final String OBJECT_NAME_NODE
public static final String DEST_CONDITION_NODE
public static final String LOAD_ACTION_ATTR
public static final String LOAD_KEY_ATTR
public static final String LOAD_AUTOSELECT_KEY_ATTR
public static final String LOAD_SKIP_DELETE_WITH_MERGE
public static final String LOAD_ACTION_LANG_ATTR
public static final String LOAD_ACTION_COND_ATTR
public static final String DEST_THEN_NODE
public static final String DEST_ELSE_NODE
public static final String DEST_AFTER_NODE
public static final String DEST_ENCODE_ATTR
public static final String DEST_TOLERATE_ATTR
public static final String DEST_IS_EMPTY_ATTR
public static final String LOAD_FORCE_BIND_ATTR
public static final String DEST_READER_NODE
public static final String DEST_WRITER_NODE
public static final String DEST_CACHE_CLASS_NAME_NODE
public static final String DEST_CONNECTION_NAME_NODE
public static final String ACTUAL_CONNECTION_NAME_NODE
public static final String TARGET_NODE
public static final String TARGET_DRIVER_NODE
public static final String DEST_CURSOR_NODE
public static final String DEST_SOURCE_TABLE_NODE
public static final String DEST_CURSOR_TABLE_NAME_ATTR
public static final String DEST_CURSOR_NAME_ATTR
public static final String DEST_CURSOR_SQL_ATTR
public static final String DEST_CURSOR_TABLE_TYPE_ATTR
public static final String DEST_CURSOR_TABLE_ON_FINISH_ATTR
public static final String NO_CONNECTION_ATTR
public static final String ON_EXCEPTION_NODE
public static final String EXCEPTION_MASK_ATTR
public static final String EXCEPTION_MESSAGE_ATTR
public static final String EXCEPTION_KEY_FIELD_ATTR
public static final String EXCEPTION_SAVEPOINT_ATTR
public static final String LOAD_NODE
public static final String VAR_NAME_ATTR
public static final String VAR_FUNC_NAME_ATTR
public static final String VAR_CLASS_NAME_ATTR
public static final String VAR_FIELD_NAME_ATTR
public static final String VAR_SQL_ATTR
public static final String VAR_CODE_ATTR
public static final String VAR_LANG_ATTR
public static final String VAR_TYPE_ATTR
public static final String VAR_LINKED_NAME_ATTR
public static final String VAR_LINKED_DEST_NAME_ATTR
public static final String VAR_VALUE_ATTR
public static final String VAR_LABEL_ATTR
public static final String VAR_INCLUDE_ATTR
public static final String VAR_EXCLUDE_ATTR
public static final String VAR_ADD_ATTR
public static final String VAR_TOLERATE_ATTR
public static final String VAR_TABLE_NAME_ATTR
public static final String VAR_ITEM_ATTR
public static final String VAR_GLOBAL_ATTR
public static final String VAR_DECLARE_ATTR
public static final String VAR_PARAM_ATTR
public static final String VAR_SCOPE_ATTR
public static final String TASKS_NODE
public static final String TASK_NODE
public static final String BEFORE_TASKS_NODE
public static final String AFTER_TASKS_NODE
public static final String TASK_NAME_NODE
public static final String TASK_CLASS_NAME_NODE
public static final String TASK_CONNECTION_NAME_NODE
public static final String TASK_TABLE_NAME_NODE
public static final String TASK_SQL_NODE
public static final String TASK_CODE_NODE
public static final String TASK_COMMAND_NODE
public static final String TASK_MESSAGE_NODE
public static final String TASK_CMD_NODE
public static final String TASK_USING_NODE
public static final String TASK_ENABLED_ATTR
public static final String TASK_ASYNCHRONOUS_ATTR
public static final String TASK_SCOPE_ATTR
public static final String TASK_COMMIT_ATTR
public static final String TASK_METRICS_ENABLED_ATTR
public static final String TASK_IS_FINAL_ATTR
public static final String EXECUTE_NODE
public static final String INNER_SCENARIO_NODE
public static final String SCENARIO_ACTION_ATTR
public static final String INNER_SCENARIO_PARELLEL_ATTR
public static final String INNER_SCENARIO_ON_EXCEPTION_ATTR
public static final int PARSE_ALL_PARAM
public static final int PARSE_STRUCTURE_ONLY_PARAM
public static final int PARSE_RECURSVIVELY_PARAM
public static final String BEFORE_TASKS_OWNER_NAME_VALUE
public static final String AFTER_TASKS_OWNER_NAME_VALUE
public static final String ON_EXECUTE_COMMIT_VALUE
public void checkSyntaxt(String code) throws Exception
code
- the codeException
- the exception if syntax is not correctpublic Driver getDriver(String value, DriverDiscovery driverDiscovery, String jdbcClassName) throws Exception
value
- the initialization stringdriverDiscovery
- the instance of the driver discovery interface. Can be nulljdbcClassName
- the jdbc class name. Can be nullException
- in case of any errorpublic String getDriverCase(String value)
value
- the initialization stringpublic String getDriverClassName(String value)
value
- the initialization stringpublic String getParentDriverClassName(String value)
value
- the initialization stringpublic Scenario getScenario(EtlConfig config, String fileName) throws Exception
config
- the etl configfileName
- the scenario file nameException
- in case of any errorpublic Scenario getScenario(EtlConfig config, String fileName, int parseScope) throws Exception
config
- the configfileName
- the scenario file nameparseScope
- the parse scope. Possible values (bitwise operators allowed):
PARSE_ALL_PARAM, PARSE_STRUCTURE_ONLY_PARAM,
PARSE_RECURSVIVELY_PARAMException
- in case of any errorpublic void parseAfterTasks(EtlConfig config, XmlUtils xml, org.w3c.dom.Node treesNode, Scenario scenario) throws Exception
config
- the configxml
- the xmltreesNode
- the root nodescenario
- the scenarioException
- the exceptionpublic void parseBeforeTasks(EtlConfig config, XmlUtils xml, org.w3c.dom.Node treesNode, Scenario scenario, String rootNodeName) throws Exception
config
- the configxml
- the xmltreesNode
- the root nodescenario
- the scenariorootNodeName
- the root node nameException
- the exceptionpublic void parseDestinations(EtlConfig config, XmlUtils xml, org.w3c.dom.Node treesNode, Scenario scenario) throws Exception
config
- the etl configxml
- the xml domtreesNode
- the trees nodescenario
- the scenarioException
- in case of any errorpublic Scenario parseScenario(EtlConfig config, String code) throws Exception
config
- the etl configcode
- the xml as a stringException
- in case of any errorpublic Scenario parseScenario(EtlConfig config, String code, int parseScope) throws Exception
config
- the etl configcode
- the xml as a stringparseScope
- the parse scope. Possible values (bitwise operators allowed):
PARSE_ALL_PARAM, PARSE_STRUCTURE_ONLY_PARAM,
PARSE_RECURSVIVELY_PARAMException
- in case of any errorpublic Scenario parseScenario(EtlConfig config, XmlUtils xml, int parseScope) throws Exception
config
- the etl configxml
- the xml domparseScope
- the parse scope. Possible values (bitwise operators allowed):
PARSE_ALL_PARAM, PARSE_STRUCTURE_ONLY_PARAM,
PARSE_RECURSVIVELY_PARAMException
- in case of any errorpublic Scenario parseScenario(EtlConfig config, XmlUtils xml, int parseScope, org.w3c.dom.Node rootNode) throws Exception
config
- the etl configxml
- the xml domparseScope
- the parse scope. Possible values (bitwise operators allowed):
PARSE_ALL_PARAM, PARSE_STRUCTURE_ONLY_PARAM,
PARSE_RECURSVIVELY_PARAMrootNode
- the root node. If null start from
node
Exception
- in case of any errorpublic void parseScenarioVariables(XmlUtils xml, Scenario scenario, org.w3c.dom.Node rootNode, EtlConfig config)
xml
- the xml domscenario
- the scenariorootNode
- the root nodeconfig
- the configpublic void parseSources(EtlConfig config, XmlUtils xml, org.w3c.dom.Node treesNode, Scenario scenario) throws Exception
config
- the configxml
- the xml domtreesNode
- the trees nodescenario
- the scenarioException
- in case of any errorpublic void parseTasks(EtlConfig config, XmlUtils xml, org.w3c.dom.Node rootNode, Scenario scenario, Block block, String rootNodeName) throws Exception
config
- the configxml
- the xml domrootNode
- the root nodescenario
- the scenarioblock
- the blockrootNodeName
- the root node nameException
- in case of any errorpublic void parseVariableAttrs(XmlUtils xml, org.w3c.dom.Node variableNode, Variable var)
xml
- the xml domvariableNode
- the variable nodevar
- the variableCopyright © 2010-2020 Toolsverse. All Rights Reserved.