mdp_outbox_and_stg_external.sql 1.1 KB

1234567891011121314151617181920212223242526272829303132
  1. -- MDP 出站 Outbox + 通用贴源表(双模式对接执行任务书 P-B/P-E)
  2. -- 幂等可重复执行
  3. CREATE TABLE IF NOT EXISTS mdp_outbox (
  4. id BIGINT PRIMARY KEY AUTO_INCREMENT,
  5. tenant_id BIGINT NOT NULL,
  6. target_source_code VARCHAR(100) NOT NULL,
  7. action_code VARCHAR(100) NOT NULL,
  8. idem_key VARCHAR(200) NOT NULL,
  9. payload_json TEXT,
  10. status TINYINT NOT NULL DEFAULT 0,
  11. retry_count INT NOT NULL DEFAULT 0,
  12. response_json TEXT,
  13. error_msg VARCHAR(1000),
  14. create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
  15. update_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP ON UPDATE CURRENT_TIMESTAMP,
  16. UNIQUE KEY uk_idem (tenant_id, target_source_code, action_code, idem_key),
  17. KEY idx_status (status, tenant_id)
  18. );
  19. CREATE TABLE IF NOT EXISTS mdp_stg_external_row (
  20. id BIGINT PRIMARY KEY AUTO_INCREMENT,
  21. tenant_id BIGINT NOT NULL,
  22. source_table VARCHAR(200),
  23. source_row_id VARCHAR(200),
  24. raw_data JSON,
  25. sync_batch_id VARCHAR(100),
  26. create_time DATETIME NOT NULL DEFAULT CURRENT_TIMESTAMP,
  27. KEY idx_batch (sync_batch_id),
  28. KEY idx_src (source_table, source_row_id),
  29. KEY idx_tenant (tenant_id)
  30. );