Pgsql跨网络数据库增量同步

-- ---------------------------- -- Table structure for t_com_sync_ctrl -- ---------------------------- DROP TABLE IF EXISTS "public"."t_com_sync_ctrl"; CREATE TABLE "public"."t_com_sync_ctrl" ( "id" int4 NOT NULL DEFAULT nextval('t_com_sync_ctrl_id_seq'::regclass), "table_name" varchar(40) COLLATE "pg_catalog"."default" NOT NULL DEFAULT ''::character varying, "ctrl_column" varchar(32) COLLATE "pg_catalog"."default" NOT NULL DEFAULT ''::character varying, "ctrl_value" varchar(100) COLLATE "pg_catalog"."default" NOT NULL DEFAULT ''::character varying, "column_type" varchar(16) COLLATE "pg_catalog"."default" NOT NULL DEFAULT 'int'::character varying, "column_list" varchar(1500) COLLATE "pg_catalog"."default" DEFAULT ''::character varying, "sync_flag" int2 NOT NULL DEFAULT 0 ) ; COMMENT ON COLUMN "public"."t_com_sync_ctrl"."table_name" IS '表名称'; COMMENT ON COLUMN "public"."t_com_sync_ctrl"."ctrl_column" IS '控制增量的字段名称'; COMMENT ON COLUMN "public"."t_com_sync_ctrl"."ctrl_value" IS '时间字段增量值'; COMMENT ON COLUMN "public"."t_com_sync_ctrl"."column_type" IS '取值：timestamp integer varchar; 用于强转'; COMMENT ON COLUMN "public"."t_com_sync_ctrl"."column_list" IS '拼接查询sql，处理特殊数据类型，如时间类型字段'; COMMENT ON COLUMN "public"."t_com_sync_ctrl"."sync_flag" IS '是否开启同步 0否1是'; COMMENT ON TABLE "public"."t_com_sync_ctrl" IS '数据增量同步控制表'; -- ---------------------------- -- Records of t_com_sync_ctrl -- ---------------------------- INSERT INTO "public"."t_com_sync_ctrl" VALUES (4, 't_com_dictionary', 'id', '121', 'integer', 'id , owner_id , dict_code , dict_value , dict_type , parent_id , remark , to_char(create_time, ''yyyy-mm-dd hh:mi:ss'') as create_time , create_user_id , version , del_flag', 1); -- ---------------------------- -- Primary Key structure for table t_com_sync_ctrl -- ---------------------------- ALTER TABLE "public"."t_com_sync_ctrl" ADD CONSTRAINT "pk_t_com_sync_ctrl" PRIMARY KEY ("id");