1.0.273.sql 2.8 KB

1234567891011121314151617181920212223242526272829303132333435
  1. -- 1.0.273:S6 IPQC 明细 bespoke→通用管线 + dopdemorq 双源入站实体登记(本库 status=1 / SQLSERVER status=0)
  2. --
  3. -- 背景:IPQC Head 已迁 pull stg(source_table='qms_gcjyd')双源就绪;本批把 Detail(qms_gcjydzb) 从 bespoke
  4. -- (读独立 mdp_stg_ipqc_inspection_detail + 裸 CAST)迁入通用管线:执行器灌 mdp_stg_ipqc_pull(source_table='qms_gcjydzb',与 Head 共表)
  5. -- → transform 读 pull stg(MdpJsonSql 修 ybl/jysl/bhgsl/NonNumerical*/InspectionTime 类型守卫)→ mdp_std_ipqc_inspection_detail。
  6. -- 登记 2 个明细入站实体(本库 + dopdemorq SQL Server),均落 mdp_stg_ipqc_pull、FULL。Head 实体不动。
  7. -- 状态:正式脚本(1.0.273,已注册 csproj Copy,随 AutoVersionUpdate 执行)。
  8. --
  9. -- 硬约束:
  10. -- 1) 本库实体 S6_IPQC_INSPECTION_DETAIL status=1:RunFullAsync 明细迁 pull 管线后依赖它(否则 s6 IPQC refresh 明细断)。
  11. -- 2) SQLSERVER 实体 status=0:就位不启用,合入后不改变现有运行行为;启用需带外注密码+受控切源。
  12. -- 3) 两实体均 sync_mode='FULL'(qms_gcjydzb 无 UpdateTime,FULL-only)。
  13. -- 4) source_table_name='qms_gcjydzb'(两库同名);transform 按 source_table='qms_gcjydzb' 过滤,与 Head(qms_gcjyd) 共 pull stg。
  14. -- tenant_id 由入站上下文赋值,本库源含该列(raw 保留),SQL Server 源无此列(回落上下文默认 1300000000001)。
  15. -- 幂等:WHERE NOT EXISTS 守卫,可重复执行。
  16. -- 本库明细入站实体(AIDOPDEV_MYSQL, status=1)
  17. INSERT INTO mdp_entity
  18. (tenant_id, source_id, entity_code, entity_name, entity_type, source_table_name, target_table_name,
  19. sync_mode, batch_size, biz_key_expr, status, remark, create_time, update_time)
  20. SELECT 0, (SELECT id FROM mdp_source WHERE source_code='AIDOPDEV_MYSQL'),
  21. 'S6_IPQC_INSPECTION_DETAIL', 'S6过程检验明细入站(本库)', 'TABLE',
  22. 'qms_gcjydzb', 'mdp_stg_ipqc_pull',
  23. 'FULL', 5000, 'id', 1, 'S6 IPQC 明细 B-① 本库入站', NOW(), NOW()
  24. WHERE NOT EXISTS (SELECT 1 FROM mdp_entity WHERE entity_code='S6_IPQC_INSPECTION_DETAIL');
  25. -- dopdemorq SQL Server 明细入站实体(DOPDEMORQ_SQLSERVER, status=0 就位不启用)
  26. INSERT INTO mdp_entity
  27. (tenant_id, source_id, entity_code, entity_name, entity_type, source_table_name, target_table_name,
  28. sync_mode, batch_size, biz_key_expr, status, remark, create_time, update_time)
  29. SELECT 0, (SELECT id FROM mdp_source WHERE source_code='DOPDEMORQ_SQLSERVER'),
  30. 'S6_IPQC_INSPECTION_DETAIL_SQLSERVER', 'S6过程检验明细入站(SQLServer)', 'TABLE',
  31. 'qms_gcjydzb', 'mdp_stg_ipqc_pull',
  32. 'FULL', 5000, 'id', 0, 'S6 IPQC 明细 B-① 双源 disabled', NOW(), NOW()
  33. WHERE NOT EXISTS (SELECT 1 FROM mdp_entity WHERE entity_code='S6_IPQC_INSPECTION_DETAIL_SQLSERVER');