如何在带有 bigint 列的 postgres 中创建动态分区 table？

Question

我有高手table如

CREATE TABLE public.user_event_firebase
(
    user_id character varying(32) COLLATE pg_catalog."default" NOT NULL,
    event_name character varying(255) COLLATE pg_catalog."default" NOT NULL,
    "timestamp" bigint NOT NULL,
    platform character varying(255) COLLATE pg_catalog."default" NOT NULL,
    created_at timestamp without time zone DEFAULT now()
)
WITH (
    OIDS = FALSE
)
TABLESPACE pg_default;

目标

我想用 year_month table 和“timestamp”列对这个 table 进行分区，例如 user_event_firebase_2018_04，user_event_firebase_2018_05, user_event_firebase_2018_06.这些行将自动重定向以插入到带有时间戳条件的分区 table 中。

我创建了创建分区的函数，例如：

CREATE OR REPLACE FUNCTION partition_uef_table( bigint, bigint )
returns void AS $$
DECLARE
    create_query text;
    index_query text;
BEGIN
    FOR create_query, index_query IN SELECT
            'create table user_event_firebase_'
            || TO_CHAR( d, 'YYYY_MM' )
            || ' ( check( timestamp >= bigint '''
            || TO_CHAR( d, 'YYYY-MM-DD' )
            || ''' and timestamp < bigint '''
            || TO_CHAR( d + INTERVAL '1 month', 'YYYY-MM-DD' )
            || ''' ) ) inherits ( user_event_firebase );',
            'create index user_event_firebase_'
            || TO_CHAR( d, 'YYYY_MM' )
            || '_time on user_event_firebase_' 
            || TO_CHAR( d, 'YYYY_MM' )
            || ' ( timestamp );'
        FROM generate_series( , , '1 month' ) AS d
    LOOP
        EXECUTE create_query;
        EXECUTE index_query;
    END LOOP;
END;
$$
language plpgsql;

CREATE OR REPLACE FUNCTION test_partition_function_uef()
RETURNS TRIGGER AS $$
BEGIN
    EXECUTE 'insert into user_event_firebase_'
        || to_char( NEW.timestamp, 'YYYY_MM' )
        || ' values ( , , ,  )' USING NEW.user_id, NEW.event_name, NEW.timestamp, NEW.platform;
    RETURN NULL;
END;
$$
LANGUAGE plpgsql;

有触发器

CREATE TRIGGER test_partition_trigger_uef
    BEFORE INSERT
    ON user_event_firebase
    FOR each ROW
    EXECUTE PROCEDURE test_partition_function_uef() ;

我试着用例子

SELECT partition_uef_table(1518164237,1520583437) ;

问题：

ERROR:  invalid input syntax for integer: "1 month"
LINE 14:   FROM generate_series( , , '1 month' ) AS d
                                         ^
QUERY:  SELECT
            'create table user_event_firebase_'
            || TO_CHAR( d, 'YYYY_MM' )
            || ' ( check( timestamp >= bigint '''
            || TO_CHAR( d, 'YYYY-MM-DD' )
            || ''' and timestamp < bigint '''
            || TO_CHAR( d + INTERVAL '1 month', 'YYYY-MM-DD' )
            || ''' ) ) inherits ( user_event_firebase );',
            'create index user_event_firebase_'

问题：

如何在“1 个月”中为 generate_series 函数创建范围，设置 step 属性这样的 int 或 bigint 很糟糕，因为月份的天数不同（第 2 天 - 28 天, 第三 - 30 天).

谢谢。

Answer 1

你的第二个问题的答案将基于意见（所以我跳过它），但第一个问题将是这样的：

with args(a1,a2) as (values(1518164237,1520583437))
select d,to_char(d,'YYYY_MM') from args, generate_series(to_timestamp(a1),to_timestamp(a2),'1 month'::interval) d;

给出结果：

           d            | to_char
------------------------+---------
 2018-02-09 08:17:17+00 | 2018_02
 2018-03-09 08:17:17+00 | 2018_03
(2 rows)

Use

generate_series(start, stop, step interval) timestamp or timestamp with time zone

如何在带有 bigint 列的 postgres 中创建动态分区 table？

How to create dynamic partition table in postgres with bigint column?

sql

postgresql

plpgsql

database-partitioning