书接上回，数据同步核心流程1，同步aav库表

sync_aav
Normal
0
/

ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
TRANSNAME
Y
TRANSNAME
STATUS
Y
STATUS
LINES_READ
Y
LINES_READ
LINES_WRITTEN
Y
LINES_WRITTEN
LINES_UPDATED
Y
LINES_UPDATED
LINES_INPUT
Y
LINES_INPUT
LINES_OUTPUT
Y
LINES_OUTPUT
LINES_REJECTED
Y
LINES_REJECTED
ERRORS
Y
ERRORS
STARTDATE
Y
STARTDATE
ENDDATE
Y
ENDDATE
LOGDATE
Y
LOGDATE
DEPDATE
Y
DEPDATE
REPLAYDATE
Y
REPLAYDATE
LOG_FIELD
Y
LOG_FIELD
EXECUTING_SERVER
N
EXECUTING_SERVER
EXECUTING_USER
N
EXECUTING_USER
CLIENT
N
CLIENT

ID_BATCH
Y
ID_BATCH
SEQ_NR
Y
SEQ_NR
LOGDATE
Y
LOGDATE
TRANSNAME
Y
TRANSNAME
STEPNAME
Y
STEPNAME
STEP_COPY
Y
STEP_COPY
LINES_READ
Y
LINES_READ
LINES_WRITTEN
Y
LINES_WRITTEN
LINES_UPDATED
Y
LINES_UPDATED
LINES_INPUT
Y
LINES_INPUT
LINES_OUTPUT
Y
LINES_OUTPUT
LINES_REJECTED
Y
LINES_REJECTED
ERRORS
Y
ERRORS
INPUT_BUFFER_ROWS
Y
INPUT_BUFFER_ROWS
OUTPUT_BUFFER_ROWS
Y
OUTPUT_BUFFER_ROWS

ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
LOG_DATE
Y
LOG_DATE
LOGGING_OBJECT_TYPE
Y
LOGGING_OBJECT_TYPE
OBJECT_NAME
Y
OBJECT_NAME
OBJECT_COPY
Y
OBJECT_COPY
REPOSITORY_DIRECTORY
Y
REPOSITORY_DIRECTORY
FILENAME
Y
FILENAME
OBJECT_ID
Y
OBJECT_ID
OBJECT_REVISION
Y
OBJECT_REVISION
PARENT_CHANNEL_ID
Y
PARENT_CHANNEL_ID
ROOT_CHANNEL_ID
Y
ROOT_CHANNEL_ID

ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
LOG_DATE
Y
LOG_DATE
TRANSNAME
Y
TRANSNAME
STEPNAME
Y
STEPNAME
STEP_COPY
Y
STEP_COPY
LINES_READ
Y
LINES_READ
LINES_WRITTEN
Y
LINES_WRITTEN
LINES_UPDATED
Y
LINES_UPDATED
LINES_INPUT
Y
LINES_INPUT
LINES_OUTPUT
Y
LINES_OUTPUT
LINES_REJECTED
Y
LINES_REJECTED
ERRORS
Y
ERRORS
LOG_FIELD
N
LOG_FIELD

ID_BATCH
Y
ID_BATCH
CHANNEL_ID
Y
CHANNEL_ID
LOG_DATE
Y
LOG_DATE
METRICS_DATE
Y
METRICS_DATE
METRICS_CODE
Y
METRICS_CODE
METRICS_DESCRIPTION
Y
METRICS_DESCRIPTION
METRICS_SUBJECT
Y
METRICS_SUBJECT
METRICS_TYPE
Y
METRICS_TYPE
METRICS_VALUE
Y
METRICS_VALUE

0.0
0.0
10000
50
50
N
Y
50000
Y
N
1000
100
-
2024/06/04 16:42:12.956
-
2024/06/04 16:42:12.956
N
local_aav
${local_ip}
MYSQL
Native
${schemeName_aav}
3306
${local_user}
${password}
FORCE_IDENTIFIERS_TO_LOWERCASE
N
FORCE_IDENTIFIERS_TO_UPPERCASE
N
IS_CLUSTERED
N
PORT_NUMBER
3306
PRESERVE_RESERVED_WORD_CASE
Y
QUOTE_ALL_FIELDS
N
STREAM_RESULTS
Y
SUPPORTS_BOOLEAN_DATA_TYPE
Y
SUPPORTS_TIMESTAMP_DATA_TYPE
Y
USE_POOLING
N
local_aav1
${local_ip}
MYSQL
Native
${schemeName_aav1}
3306
${local_user}
${password}
FORCE_IDENTIFIERS_TO_LOWERCASE
N
FORCE_IDENTIFIERS_TO_UPPERCASE
N
IS_CLUSTERED
N
PORT_NUMBER
3306
PRESERVE_RESERVED_WORD_CASE
Y
QUOTE_ALL_FIELDS
N
STREAM_RESULTS
Y
SUPPORTS_BOOLEAN_DATA_TYPE
Y
SUPPORTS_TIMESTAMP_DATA_TYPE
Y
USE_POOLING
N
删除所有aav表数据
查询sp_cfg
Y
删除所有aav表数据
查询sp_image
Y
删除所有aav表数据
查询sp_vedio
Y
删除所有aav表数据
查询sys_user
Y
查询sp_cfg
插入 / 更新 sp_cfg
Y
查询sp_image
插入 / 更新 sp_image
Y
查询sp_vedio
插入 / 更新sp_vedio
Y
查询sys_user
插入 / 更新 sys_user
Y
删除所有aav表数据
ExecSQL
Y
1
none
local_aav1
Y
N
N
N
DELETE FROM sp_cfg;
DELETE FROM sp_image;
DELETE FROM sp_vedio;
DELETE FROM sys_user;
N
192
256
Y
查询sp_cfg
TableInput
Y
1
none
local_aav
SELECT * FROM sp_cfg;
0
N
N
N
384
128
Y
查询sp_image
TableInput
Y
1
none
local_aav
SELECT * FROM sp_image;
0
N
N
N
384
208
Y
查询sp_vedio
TableInput
Y
1
none
local_aav
SELECT * FROM sp_vedio;
0
N
N
N
384
288
Y
查询sys_user
TableInput
Y
1
none
local_aav
SELECT * FROM sys_user;
0
N
N
N
384
368
Y
插入 / 更新 sp_cfg
InsertUpdate
Y
1
none
local_aav1
100
N
sp_cfg
id
id
=
id
id
Y
cfg_name
cfg_name
Y
cfg_value
cfg_value
Y
remarks
remarks
Y
560
128
Y
插入 / 更新 sp_image
InsertUpdate
Y
1
none
local_aav1
100
N
sp_image
id
id
=
id
id
Y
url
url
Y
type
type
Y
create_time
create_time
Y
create_by
create_by
Y
update_by
update_by
Y
update_time
update_time
Y
description
description
Y
status
status
Y
560
208
Y
插入 / 更新sp_vedio
InsertUpdate
Y
1
none
local_aav1
100
N
sp_vedio
id
id
=
id
id
Y
url
url
Y
type
type
Y
status
status
Y
create_by
create_by
Y
create_time
create_time
Y
update_by
update_by
Y
update_time
update_time
Y
img_path
img_path
Y
title
title
Y
560
288
Y
插入 / 更新 sys_user
InsertUpdate
Y
1
none
local_aav1
100
N
sys_user
id
id
=
id
id
Y
name
name
Y
phone
phone
Y
password
password
Y
560
368
Y
N