pg_target.sql 1.0 KB

12345678910111213141516171819202122232425
  1. -- PG 目标表(DataX hdfs-export 冒烟用)
  2. --
  3. -- 链路:Hive test.raw_usr_app_user_cert_info_inc_d → PG test.ads_usr_app_user_cert_info_export
  4. -- 简化策略:全字段 VARCHAR,对齐 Hive raw 全字段 STRING 语义,避免 YYYY-MM 脱敏值解析为 timestamp 失败
  5. -- 幂等策略:DataX ini 用 preSql = TRUNCATE 清空目标表再 insert,每次冒烟都是全量覆盖
  6. CREATE SCHEMA IF NOT EXISTS test;
  7. DROP TABLE IF EXISTS test.ads_usr_app_user_cert_info_export;
  8. CREATE TABLE test.ads_usr_app_user_cert_info_export (
  9. id VARCHAR(64) PRIMARY KEY,
  10. user_id VARCHAR(64),
  11. cert_birthday VARCHAR(32),
  12. cert_sex VARCHAR(32),
  13. cert_province VARCHAR(255),
  14. cert_city VARCHAR(255),
  15. version VARCHAR(32),
  16. status VARCHAR(32),
  17. del_flag VARCHAR(32),
  18. create_time VARCHAR(64),
  19. update_time VARCHAR(64)
  20. );
  21. COMMENT ON TABLE test.ads_usr_app_user_cert_info_export IS '用户证件信息(DataX hdfs-export 冒烟目标表,Hive raw 回写 PG 闭环验证用)';