postgres 按时间自动分区

postgres 水平分表,自动创建分区,按时间分表（转）

 

https://blog.csdn.net/wsdhla/article/details/84064868

关于触发器函数的解释:

https://blog.csdn.net/shenwansangz/article/details/53538646

重点说明:

1. 触发器函数自带的很多参数,变量,可以直接调用
2. 触发器函数虽然没有形参,但是也可以在触发器中传递参数,参数可以在触发器函数中通过变量:TG_ARGV[0]来获取

CREATE TABLE public.tb_stranger_snap (
    id serial8 NOT NULL,
    human_id varchar(50) NULL,
    thorough_count int4 NULL,
    device_snap_community_code varchar(30) NULL,
    snap_url varchar(200) NULL,
    update_time timestamp NULL DEFAULT now()
);
CREATE INDEX tb_stranger_snap_device_snap_community_code_idx ON public.tb_stranger_snap (device_snap_community_code);


--------触发器----------------
CREATE OR REPLACE FUNCTION auto_insert_into_tb_stranger_snap()
  RETURNS trigger AS
$BODY$
DECLARE
    time_column_name     text ;            -- 父表中用于分区的时间字段的名称[必须首先初始化!!]
    curMM         varchar(6);        -- 'YYYYMM'字串,用做分区子表的后缀
    isExist         boolean;        -- 分区子表,是否已存在
    startTime         text;
    endTime        text;
    strSQL          text;

BEGIN
    -- 调用前,必须首先初始化(时间字段名):time_column_name [直接从调用参数中获取!!]
    time_column_name := TG_ARGV[0];

    -- 判断对应分区表 是否已经存在?
    EXECUTE 'SELECT $1.'||time_column_name INTO strSQL USING NEW;
    curMM := to_char( strSQL::timestamp , 'YYYYMM' );
    select count(*) INTO isExist from pg_class where relname = (TG_RELNAME||'_'||curMM);

    -- 若不存在, 则插入前需 先创建子分区
    IF ( isExist = false ) THEN
        -- 创建子分区表
        startTime := curMM||'01 00:00:00.000';
        endTime := to_char( startTime::timestamp + interval '1 month', 'YYYY-MM-DD HH24:MI:SS.MS');
        strSQL := 'CREATE TABLE IF NOT EXISTS '||TG_RELNAME||'_'||curMM||
                  ' ( CHECK('||time_column_name||'>='''|| startTime ||''' AND '
                             ||time_column_name||'< '''|| endTime ||''' )
                          ) INHERITS ('||TG_RELNAME||') ;'  ;
        EXECUTE strSQL;

        -- 创建索引
        strSQL := 'CREATE INDEX '||TG_RELNAME||'_'||curMM||'_INDEX_'||time_column_name||' ON '
                  ||TG_RELNAME||'_'||curMM||' ('||time_column_name||');' ;
        EXECUTE strSQL;

    END IF;

    -- 插入数据到子分区!
    strSQL := 'INSERT INTO '||TG_RELNAME||'_'||curMM||' SELECT $1.*' ;
    EXECUTE strSQL USING NEW;
    RETURN NULL;
END
$BODY$
  LANGUAGE plpgsql;


 CREATE TRIGGER insert_tb_stranger_snap_trigger
  BEFORE INSERT
  ON tb_stranger_snap
  FOR EACH ROW
  EXECUTE PROCEDURE auto_insert_into_tb_stranger_snap('update_time');