-- WIP-T8MDP:T8 6 张基表双模式入站启用(提交时 rename 为正式 1.0..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' );