DataWorks:UpdateDIJob

The scheduling parameters.

The number of CUs to request from the Data Integration resource group for offline synchronization.

The name of the Data Integration resource group used for offline synchronization.

The number of CUs to request from the Data Integration resource group for real-time synchronization.

The name of the Data Integration resource group used for real-time synchronization.

The number of CUs to request from the scheduling resource group for the offline synchronization job.

The name of the scheduling resource group used for the offline synchronization job.

The type of the action. Valid values:

• DefinePrimaryKey: Defines a primary key.

• Rename: Renames an object.

• AddColumn: Adds a column.

• HandleDml: Handles DML operations.

• DefineIncrementalCondition: Defines an incremental condition.

• DefineCycleScheduleSettings: Defines periodic scheduling settings.

• DefinePartitionKey: Defines a partition key.

The rule expression, specified as a JSON string.

1. Rename rule (Rename)

• Example: {"expression":"${srcDatasourceName}_${srcDatabaseName}_0922" }

• expression: The expression for the rename transformation rule. The expression supports the following variables: ${srcDatasourceName} (source data source name), ${srcDatabaseName} (source database name), and ${srcTableName} (source table name).

2. Add column rule (AddColumn)

• Example: {"columns":[{"columnName":"my_add_column","columnValueType":"Constant","columnValue":"123"}]}

• If you do not specify this rule, no columns are added.

• columnName: The name of the column to add.

• columnValueType: The type of the value for the added column. Valid values: Constant and Variable.

• columnValue: The value of the added column. If columnValueType is Constant, the value is a custom string constant. If columnValueType is Variable, the value is a built-in variable. Valid values for the built-in variable: EXECUTE_TIME (execution time, Long), DB_NAME_SRC (source database name, String), DATASOURCE_NAME_SRC (source data source name, String), TABLE_NAME_SRC (source table name, String), DB_NAME_DEST (destination database name, String), DATASOURCE_NAME_DEST (destination data source name, String), TABLE_NAME_DEST (destination table name, String), and DB_NAME_SRC_TRANSFORMED (transformed database name, String).

3. Define primary key rule (DefinePrimaryKey)

• Example: {"columns":["ukcolumn1","ukcolumn2"]}

• If you do not specify this rule, the primary key of the source is used by default.

• If the destination is an existing table, Data Integration does not modify the table structure. If a specified primary key column does not exist in the destination table, the job fails to start.

• If the destination table is automatically created, Data Integration creates the table structure, including the defined primary key columns. If a specified primary key column does not exist in the destination column set, the job fails to start.

4. DML handling rule (HandleDml)

• Example: {"dmlPolicies":[{"dmlType":"Delete","dmlAction":"Filter","filterCondition":"id > 1"}]}

• If you do not specify this rule, the default action for Insert, Update, and Delete operations is Normal.

• dmlType: The DML operation type. Valid values: Insert, Update, and Delete.

• dmlAction: The DML handling policy. Valid values: Normal (processes the operation), Ignore (ignores the operation), Filter (conditionally processes the operation, used when dmlType is Update or Delete), and LogicalDelete (performs a logical delete).

• filterCondition: The DML filter condition, used when dmlAction is Filter.

5. Incremental condition rule (DefineIncrementalCondition)

• Example: {"where":"id > 0"}

• Specifies the incremental filter condition.

6. Periodic scheduling rule (DefineCycleScheduleSettings)

• Example: {"cronExpress":" * * * * * *", "cycleType":"1"}

• Specifies the scheduling parameters for a periodic job.

7. Define partition key rule (DefinePartitionKey)

• Example: {"columns":["id"]}

• Specifies the partition key.

The name of the rule. The name must be unique for a specific combination of RuleActionType and RuleTargetType. The name can be up to 50 characters in length.

The type of object that the rule targets. Valid values:

• Table

• Schema

• Database