ADD_LOADER¶
add new dbi_loader (Table DBI_LOADER). create a database loader definition, for the source object, the source connection, in which CDC group the loader is started, the type of the loader and some futher configuration parameters (described in the parameter itself)
Parameter Name |
Required |
DefaultValue |
Description |
---|---|---|---|
p_ldr_name |
yes |
. |
(is part of PK) Name of the loader process for a specific data table. |
p_src_schema |
yes |
. |
Schema name on the source system of the object to be loaded |
p_src_table |
yes |
. |
Object name on the source system |
p_cdc_group |
yes |
. |
Name of the change data capture group as defined in DBI_CDCG_GROUP.CDC_GROUP (foreign key) |
p_cdc_type |
yes |
. |
Should the object’s data be loaded incremental or full (all records) at each load process or CT (change tracking load) or INFU (incremental load, but FULL PSA-load) ? Possible values: INCR, FULL, CT, INFU |
p_src_split_expr |
no |
. |
Degree of parallelism of the table’s load process. Valid values: positive integer. |
p_tsa_retention |
yes |
10 |
Number of days until data will be removed from TSA tables |
p_src_incr_expr |
no |
. |
Column name that is used for incremental loads (column CDC_TYPE=’INCR’) to detect changed records. The column named here has to be of data type integer, date or timestamp. For incremental loads this column need to be set. |
p_use_ultimo_shift |
yes |
FALSE |
Should ultimo shift be used? Ultimo shift: if calendar ultimo <> business ultimo –> BDATE will be shifted to calendar ultimo. Possible values: true or false. |
p_src_incr_datatype |
no |
. |
Data type of value that is returned by SRC_INCR_EXPR (‘I’ for integer, ‘T’ for timestamp, ‘D’ for date) - mandatory for CDC_TYPE = ‘INCR’ |
p_autofill_missing_days |
yes |
FALSE |
Automatically create TSA_CONTROL entries for days that are missing and cannot be delivered anymore |
p_incr_offset |
no |
. |
Offset for incremental load - unit: days for SRC_INCR_DATATYPE = D/T, integer for SRC_INCR_DATATYPE = I |
Example
EXECUTE SCRIPT api_dbiadm.add_loader
( p_ldr_name
, p_src_schema
, p_src_table
, p_cdc_group
, p_cdc_type
, p_src_split_expr
, p_tsa_retention
, p_src_incr_expr
, p_use_ultimo_shift
, p_src_incr_datatype
, p_autofill_missing_days
, p_incr_offset
);