postgresql 使用整理:分表与触发器
2012-10-07 21:29
295 查看
测试海量数据库,正好使用存储过程测试,顺便整理一下。
先创建主表,使用字段id为主键,
ptime创建索引。
CREATETABLE test
(
idbigint NOT NULL,
codecharacter varying(64) NOT NULL,
ptimetimestamp without time zone,
CONSTRAINTtest_pkey PRIMARY KEY (id )
);
CREATE INDEX IX_test_ptime
ONtest(ptime) ;
创建子表
createtable test_2012_02_01(
check(ptime>=date '2012-01-01' and ptime<date '2012-00-02'))
inherits(test);
ALTERTABLE test_2012_02_01 ADD
CONSTRAINTtest_2012_02_01_pkey PRIMARY KEY (id )
CREATE INDEX IX_test_2012_02_01
_ptime
ONtest(ptime) ;
分表其实是新数据库表,字段声明从主表继承。使用主表查询postgresql会关联查询分表,删除分表的记录也可以通过主表操作,但是插入数据必须指明使用那张表。另需要注意分表的主键与索引不会从主表继承,需要在分表上单独创建。
主表在实际使用中一般不用存储数据,数据存储在分表,如果是按时间的分别,数据按照时间老化,这时可以使用删除(drop)老分表来删除数据
给test设定添加触发器
CREATETRIGGER tri_test_insert_id
BEFOREINSERT
ONtest
FOREACH ROW
EXECUTEPROCEDURE tri_test_insert();
创建触发函数实现,根据时间选择表插入数据,如果表不未定义异常未创建则创建表。
ps:一般使用pgsql存储过程使用RAISENOTICE
做过程打印跟踪代码走向。
CREATEOR REPLACE FUNCTION tri_test_insert()
RETURNSTRIGGER AS
$BODY$
declare
sqlvarchar;
tmp_datedate;
tablename varchar;
begin
tmp_date= DATE(NEW.Ptime);
tablename= 'test_' || to_char(tmp_date, 'YYYY_MM_DD');
sql= 'INSERT INTO '||tablename||'(id,code,ptime) VALUES('''||NEW.id||''','''|| NEW.code||''','''|| NEW.ptime || ''' )';
RAISENOTICE 'sql: %', sql;
EXECUTEsql;
returnnull;
exception
whenundefined_table then
sql= 'create table '||tablename||' (check (ptime>= ''' || tmp_date || ''' and ptime< ''' || tmp_date+1 || ''')) inherits(test)';
RAISENOTICE 'sql: %', sql;
EXECUTEsql;
sql='ALTERTABLE ' || tablename || ' ADD CONSTRAINT ' || tablename || '_pkey PRIMARY KEY (id)';
RAISENOTICE 'sql: %', sql;
EXECUTEsql;
sql='CREATE INDEX IX_'||tablename|| '_PTIME ON '||tablename|| '(ptime)';
RAISENOTICE 'sql: %', sql;
EXECUTEsql;
sql= 'INSERT INTO '||tablename||' VALUES('''||NEW.id||''','''||NEW.code||''','''|| NEW.ptime || ''' )';
RAISENOTICE 'sql: %', sql;
EXECUTEsql;
returnnull;
end;
$BODY$
LANGUAGEplpgsql VOLATILE;
分表
分表是postgresql储存海量数据的基础,分表比较合适存储记录型的数据,一般按时间进行分表。先创建主表,使用字段id为主键,
ptime创建索引。
CREATETABLE test
(
idbigint NOT NULL,
codecharacter varying(64) NOT NULL,
ptimetimestamp without time zone,
CONSTRAINTtest_pkey PRIMARY KEY (id )
);
CREATE INDEX IX_test_ptime
ONtest(ptime) ;
创建子表
createtable test_2012_02_01(
check(ptime>=date '2012-01-01' and ptime<date '2012-00-02'))
inherits(test);
ALTERTABLE test_2012_02_01 ADD
CONSTRAINTtest_2012_02_01_pkey PRIMARY KEY (id )
CREATE INDEX IX_test_2012_02_01
_ptime
ONtest(ptime) ;
分表其实是新数据库表,字段声明从主表继承。使用主表查询postgresql会关联查询分表,删除分表的记录也可以通过主表操作,但是插入数据必须指明使用那张表。另需要注意分表的主键与索引不会从主表继承,需要在分表上单独创建。
主表在实际使用中一般不用存储数据,数据存储在分表,如果是按时间的分别,数据按照时间老化,这时可以使用删除(drop)老分表来删除数据
触发器
上述分表策略有两个问题,插入数据需要需要指定表,需要提前创建分表。如按时间分表的情况下,一般要求做到统一向主表插入,按照时间计算出插入的分表,如分表不存在这自动创建分表。这样分表就对于业务进行屏蔽。给test设定添加触发器
CREATETRIGGER tri_test_insert_id
BEFOREINSERT
ONtest
FOREACH ROW
EXECUTEPROCEDURE tri_test_insert();
创建触发函数实现,根据时间选择表插入数据,如果表不未定义异常未创建则创建表。
ps:一般使用pgsql存储过程使用RAISENOTICE
做过程打印跟踪代码走向。
CREATEOR REPLACE FUNCTION tri_test_insert()
RETURNSTRIGGER AS
$BODY$
declare
sqlvarchar;
tmp_datedate;
tablename varchar;
begin
tmp_date= DATE(NEW.Ptime);
tablename= 'test_' || to_char(tmp_date, 'YYYY_MM_DD');
sql= 'INSERT INTO '||tablename||'(id,code,ptime) VALUES('''||NEW.id||''','''|| NEW.code||''','''|| NEW.ptime || ''' )';
RAISENOTICE 'sql: %', sql;
EXECUTEsql;
returnnull;
exception
whenundefined_table then
sql= 'create table '||tablename||' (check (ptime>= ''' || tmp_date || ''' and ptime< ''' || tmp_date+1 || ''')) inherits(test)';
RAISENOTICE 'sql: %', sql;
EXECUTEsql;
sql='ALTERTABLE ' || tablename || ' ADD CONSTRAINT ' || tablename || '_pkey PRIMARY KEY (id)';
RAISENOTICE 'sql: %', sql;
EXECUTEsql;
sql='CREATE INDEX IX_'||tablename|| '_PTIME ON '||tablename|| '(ptime)';
RAISENOTICE 'sql: %', sql;
EXECUTEsql;
sql= 'INSERT INTO '||tablename||' VALUES('''||NEW.id||''','''||NEW.code||''','''|| NEW.ptime || ''' )';
RAISENOTICE 'sql: %', sql;
EXECUTEsql;
returnnull;
end;
$BODY$
LANGUAGEplpgsql VOLATILE;
相关文章推荐
- [整理]postgresql基本使用命令
- 过滤关键字,在表TABLE_A 插入前,建立触发器,使用游标过滤关键字。postgresql
- PostgreSQL的时间函数使用整理
- postgresql 触发器的使用
- postgresql触发器使用实例
- PostgreSQL安装和简单使用
- 触发器的使用
- Oracle(25)pl/sql编程 触发器及管理触发器及case...end case使用
- [转] PostgreSQL的时间/日期函数使用
- Unity3D碰撞检测 及 Trigger触发器的使用及注意事项
- ORACLE 中触发器的使用(基于系统事件与用户处事件的触发器)
- anaconda使用整理
- cocos2d-x CocoStudio中场景触发器(Trigger)的使用和扩展
- 尽量不要使用触发器
- 商城项目回顾整理(二)easyUi数据表格使用
- 转:这里有些sscanf()的一些使用说明,都是从论坛,Blog里整理出来的。供大家使用。
- sqlalchemy的基础使用,sqlalchemy调用外部创建的触发器
- PostgreSQL 优势,MySQL 数据库自身的特性并不十分丰富,触发器和存储过程的支持较弱,Greenplum、AWS 的 Redshift 等都是基于 PostgreSQL 开发的
- 使用 ASP.NET 2.0 ObjectDataSource 控件(整理自msdn)
- TreeSaver 使用教程整理——Step 1: Getting Started