pg分区表一

2021-07-10 17:36:21 阅读：202 来源： 互联网

标签：fenqu addtime varying character 分区表 pg table integer

PostgreSQL的分区表创建较Oracle分区表复杂些，需要借助创建继承表和触发器的模式实现, 具体创建方法可以参照以下实验, 供参考。

创建父表

CREATE TABLE fenqu_table (  
 id integer NOT NULL,  
 mcc character varying(5),  
 lac character varying(8),  
 mnc character(2),  
 cellid character varying(8),  
 signal integer,  
 antennaheight integer,  
 cellpower integer,  
 addtime timestamp(0) without time zone DEFAULT now(),  
 cellidfrom character varying(200),  
 address character varying(200),  
 mark integer DEFAULT 100,  
 fail_times integer DEFAULT 0,  
 success_times integer DEFAULT 0,  
 skyid integer DEFAULT 0,  
 mapaddress character varying(200)  
);

创建子表

CREATE TABLE fenqu_table_p200905 (  
 id integer,  
 mcc character varying(5),  
 lac character varying(8),  
 mnc character(2),  
 cellid character varying(8),  
 signal integer,  
 antennaheight integer,  
 cellpower integer,  
 addtime timestamp(0) without time zone,  
 cellidfrom character varying(200),  
 address character varying(200),  
 mark integer,  
 fail_times integer,  
 success_times integer,  
 skyid integer,  
 mapaddress character varying(200),  
 CONSTRAINT fenqu_table_p200905_addtime_check CHECK (((addtime >= '2009-05-01 00:00:00'::timestamp without time zone) AND (addtime < '2009-06-01 00:00:00'::timestamp without time zone)))  
)  
INHERITS (fenqu_table);

CREATE TABLE fenqu_table_p200906 (  
 id integer,  
 mcc character varying(5),  
 lac character varying(8),  
 mnc character(2),  
 cellid character varying(8),  
 signal integer,  
 antennaheight integer,  
 cellpower integer,  
 addtime timestamp(0) without time zone,  
 cellidfrom character varying(200),  
 address character varying(200),  
 mark integer,  
 fail_times integer,  
 success_times integer,  
 skyid integer,  
 mapaddress character varying(200),  
 CONSTRAINT fenqu_table_p200906_addtime_check CHECK (((addtime >= '2009-06-01 00:00:00'::timestamp without time zone) AND (addtime < '2009-07-01 00:00:00'::timestamp without time zone)))  
)  
INHERITS (fenqu_table);

CREATE TABLE fenqu_table_p200907 (  
 id integer,  
 mcc character varying(5),  
 lac character varying(8),  
 mnc character(2),  
 cellid character varying(8),  
 signal integer,  
 antennaheight integer,  
 cellpower integer,  
 addtime timestamp(0) without time zone,  
 cellidfrom character varying(200),  
 address character varying(200),  
 mark integer,  
 fail_times integer,  
 success_times integer,  
 skyid integer,  
 mapaddress character varying(200),  
 CONSTRAINT fenqu_table_p200907_addtime_check CHECK (((addtime >= '2009-07-01 00:00:00'::timestamp without time zone) AND (addtime < '2009-08-01 00:00:00'::timestamp without time zone)))  
)  
INHERITS (fenqu_table);

创建数据删除触发器函数

CREATE OR REPLACE FUNCTION public.fenqu_table_delete_trigger()  
RETURNS trigger  
LANGUAGE plpgsql  
AS $function$  
BEGIN  
 IF ( OLD.addtime>='2009-05-01' and OLD.addtime<'2009-06-01' ) THEN  
 DELETE FROM fenqu_table_p200905 where cretime=OLD.cretime;  
 ELSIF ( OLD.addtime>='2009-06-01' and OLD.addtime<'2009-07-01' ) THEN  
 DELETE FROM fenqu_table_p200906 where cretime=OLD.cretime;  
 ELSIF ( OLD.addtime>='2009-07-01' and OLD.addtime<'2009-08-01' ) THEN  
 DELETE FROM fenqu_table_p200907 where cretime=OLD.cretime;  
 ELSE  
 RAISE EXCEPTION 'addtime out of range. Fix the fenqu_table_delete_trigger() function!';  
 END IF;  
 RETURN NULL;  
END;  
$function$

创建数据插入触发器函数

CREATE OR REPLACE FUNCTION public.fenqu_table_insert_trigger()  
RETURNS trigger  
LANGUAGE plpgsql  
AS $function$  
BEGIN  
 IF ( NEW.addtime>='2009-05-01' and NEW.addtime<'2009-06-01' ) THEN  
 INSERT INTO fenqu_table_p200905 VALUES (NEW.*);  
 ELSIF ( NEW.addtime>='2009-06-01' and NEW.addtime<'2009-07-01' ) THEN  
 INSERT INTO fenqu_table_p200906 VALUES (NEW.*);  
 ELSIF ( NEW.addtime>='2009-07-01' and NEW.addtime<'2009-08-01' ) THEN  
 INSERT INTO fenqu_table_p200907 VALUES (NEW.*);  
 ELSE  
 RAISE EXCEPTION 'addtime out of range. Fix the fenqu_table_insert_trigger() function!';  
 END IF;  
 RETURN NULL;  
END;  
$function$

创建数据插入、删除触发器

1
2

create trigger delete_fenqu_table_trigger BEFORE DELETE ON fenqu_table FOR EACH ROW EXECUTE PROCEDURE fenqu_table_delete_trigger();  
create trigger insert_fenqu_table_trigger BEFORE INSERT ON fenqu_table FOR EACH ROW EXECUTE PROCEDURE fenqu_table_insert_trigger();

create sequence

create sequence fenqu_table_id_seq  
INCREMENT by 1  
MINVALUE 1  
start with 1;

分区表测试

mydb=> insert into fenqu_table (id,addtime) values (nextval('fenqu_table_id_seq'),'2009-05-01 00:00:00');  
INSERT 0 0

mydb=> select count(*) from fenqu_table;  
count  
-------  
 1  
(1 row)

mydb=> select count(*) from only fenqu_table;  
count  
-------  
 0  
(1 row)

mydb=> select count(*) from fenqu_table_p200905;  
count  
-------  
 1  
(1 row)

标签：fenqu,addtime,varying,character,分区表,pg,table,integer
来源： https://www.cnblogs.com/lovezhr/p/14994272.html

本站声明： 1. iCode9 技术分享网（下文简称本站）提供的所有内容，仅供技术学习、探讨和分享；
2. 关于本站的所有留言、评论、转载及引用，纯属内容发起人的个人观点，与本站观点和立场无关；
3. 关于本站的所有言论和文字，纯属内容发起人的个人观点，与本站观点和立场无关；
4. 本站文章均是网友提供，不完全保证技术分享内容的完整性、准确性、时效性、风险性和版权归属；如您发现该文章侵犯了您的权益，可联系我们第一时间进行删除；
5. 本站为非盈利性的个人网站，所有内容不会用来进行牟利，也不会利用任何形式的广告来间接获益，纯粹是为了广大技术爱好者提供技术内容和技术思想的分享性交流网站。