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