| 12345678910111213141516171819202122232425262728293031 |
- -- WIP-T8MDP:T8 6 张基表双模式入站启用(提交时 rename 为正式 1.0.<next>.sql 并注册 csproj Copy)
- -- 背景:1.0.178.sql 已登记 mdp_source=T8_V5_SQLSERVER 与 9 个 T8 实体(当时 target_table_name=NULL、sync_mode=NONE,"一期不贴源")。
- -- 本批把 S5_L1_001/003、S6_L1_001/002、S7_L1_001/002/003 这 7 个 KPI 用到的 6 张基表启用为 FULL 贴源,
- -- 指向 mdp_stg_t8_*(stg/std 建表由 T8BaseInboundMdpSyncService.EnsureTablesAsync 幂等创建)。
- -- 暂留 legacy 直连的 3 个实体(T8_KC_DD_LIST_CLLIST / T8_CJ_BG_HEAD_REP / T8_REP_ZONGZHANG_CUNHUO_V3)不动,仍 sync_mode=NONE。
- -- 幂等:可重复执行。
- -- 增量策略:FULL 全量。源表极小(12~39 行);MdpDbPullExecutor 的 LastCursor 为字符串字典序比较,
- -- 对 bigint Id 增量不安全,且这些表无可靠 lastmodify 列;FULL re-upsert 可带回字段/作废标志更新,且零改通用底座。
- -- source_biz_key:行级 Id(实测 count(*)==count(distinct Id) 唯一,含明细表 kc_tz_list/kc_dd_list/kc_zj_list)。
- UPDATE mdp_entity e
- JOIN mdp_source s ON s.id = e.source_id AND s.source_code = 'T8_V5_SQLSERVER'
- SET
- e.target_table_name = CASE e.entity_code
- WHEN 'T8_KC_TZ_HEAD' THEN 'mdp_stg_t8_kc_tz_head'
- WHEN 'T8_KC_TZ_LIST' THEN 'mdp_stg_t8_kc_tz_list'
- WHEN 'T8_KC_DD_HEAD' THEN 'mdp_stg_t8_kc_dd_head'
- WHEN 'T8_KC_DD_LIST' THEN 'mdp_stg_t8_kc_dd_list'
- WHEN 'T8_KC_ZJ_LIST' THEN 'mdp_stg_t8_kc_zj_list'
- WHEN 'T8_SYS_PELIST' THEN 'mdp_stg_t8_sys_pelist'
- END,
- e.sync_mode = 'FULL',
- e.incr_column = NULL,
- e.batch_size = 1000,
- e.biz_key_expr = 'Id',
- e.status = 1,
- e.remark = CONCAT(IFNULL(e.remark,''), ' | T8MDP: FULL 贴源启用,biz_key=Id 行级'),
- e.update_time = NOW()
- WHERE e.entity_code IN (
- 'T8_KC_TZ_HEAD','T8_KC_TZ_LIST','T8_KC_DD_HEAD','T8_KC_DD_LIST','T8_KC_ZJ_LIST','T8_SYS_PELIST'
- );
|