更新日期：2024年09月11日
功能描述
通过predpush_same_level Hint 来指定同层表或物化视图之间参数化路径生成。
语法格式
predpush_same_level(src, dest)
predpush_same_level(src1 src2 ..., dest)
本参数仅在rewrite_rule 中的predpushforce 选项打开时生效。
示例
准备参数和表及索引：
GBase 8c V5 开发者手册
南大通用数据技术股份有限公司
580
gsql=# set rewrite_rule = 'predpushforce';
SET
gsql=# create table t1(a int, b int);
CREATE TABLE
gsql=# create table t2(a int, b int);
CREATE TABLE
gsql=# create index idx1 on t1(a);
CREATE INDEX
gsql=# create index idx2 on t2(a);
CREATE INDEX
执行语句查看计划：
gsql=# explain select * from t1, t2 where t1.a = t2.a;
QUERY PLAN
------------------------------------------------------------------
Hash Join
(cost=27.50..56.25 rows=1000 width=16)
Hash Cond: (t1.a = t2.a)
->
Seq Scan on t1
(cost=0.00..15.00 rows=1000 width=8)
->
Hash
(cost=15.00..15.00 rows=1000 width=8)
->
Seq Scan on t2
(cost=0.00..15.00 rows=1000 width=8)
(5 rows)
可以看到t1.a = t2.a 条件过滤在Join 上面，此时可以通过predpush_same_level(t1, t2)将
条件下推至t2 的扫描算子上：
gsql=# explain select /*+predpush_same_level(t1, t2)*/ * from t1, t2 where t1.a = t2.a;
QUERY PLAN
---------------------------------------------------------------------
Nested Loop
(cost=0.00..335.00 rows=1000 width=16)
->
Seq Scan on t1
(cost=0.00..15.00 rows=1000 width=8)
->
Index Scan using idx2 on t2
(cost=0.00..0.31 rows=1 width=8)
Index Cond: (a = t1.a)
(4 rows)
predpush_same_level 可以指定多个src，但是所有的src 必须在同一个条件中。
如果指定的src 和dest 条件不存在，
或该条件不符合参数化路径要求，
则本hint 不生效。
GBase 8c V5 开发者手册
南大通用数据技术股份有限公司
581
创建和管理分区表
背景信息
GBase 8c 数据库支持的分区表为范围分区表、间隔分区表、列表分区表、哈希分区表。
范围分区表：
将数据基于范围映射到每一个分区，
这个范围是由创建分区表时指定的分
区键决定的。这种分区方式是最为常用的，并且分区键经常采用日期，例如将销售数据
按照月份进行分区。
GBase 8c V5 开发者手册
南大通用数据技术股份有限公司
36
间隔分区表：是一种特殊的范围分区表，相比范围分区表，新增间隔值定义，当插入记
录找不到匹配的分区时，可以根据间隔值自动创建分区。
列表分区表：
将数据中包含的键值分别存储再不同的分区中，
依次将数据映射到每一个
分区，分区中包含的键值由创建分区表时指定。
哈希分区表：
将数据根据内部哈希算法依次映射到每一个分区中，
包含的分区个数由创
建分区表时指定。
分区表和普通表相比具有以下优点：
改善查询性能：对分区对象的查询可以仅搜索自己关心的分区，提高检索效率。
增强可用性：如果分区表的某个分区出现故障，表在其他分区的数据仍然可用。
方便维护：如果分区表的某个分区出现故障，需要修复数据，只修复该分区即可。
均衡I/O：可以把不同的分区映射到不同的磁盘以平衡I/O，改善整个系统性能。
普通表若要转成分区表，
需要新建分区表，
然后把普通表中的数据导入到新建的分区表
中。因此在初始设计表时，请根据业务提前规划是否使用分区表。
操作步骤
创建和管理表操作步骤如下，以使用默认表空间为例。
步骤1 创建分区表（假设用户已创建tpcds schema）
postgres=# CREATE TABLE
tpcds.customer_address (ca_address_sk integer NOT
NULL , ca_address_id character(16) NOT NULL , ca_country character varying(20),
ca_gmt_offset numeric(5,2), ca_location_type character(20), ca_street_number
character(10), ca_street_name character varying(60), ca_street_type
character(15), ca_suite_number character(10),ca_city character varying(60),
ca_county character varying(30), ca_state character(2), ca_zip character(10),
ca_country character varying(20), ca_gmt_offset
numeric(5,2),
ca_location_type character(20)) PARTITION BY RANGE (ca_address_sk) (PARTITION P1
VALUES LESS THAN(5000), PARTITION P2 VALUES LESS THAN(10000), PARTITION P3 VALUES
LESS THAN(15000), PARTITION P4 VALUES LESS THAN(20000), PARTITION P5 VALUES LESS
THAN(25000), PARTITION P6 VALUES LESS THAN(30000), PARTITION P7 VALUES LESS
THAN(40000), PARTITION P8 VALUES LESS THAN(MAXVALUE)) ENABLE ROW MOVEMENT;
当结果显示为如下信息，则表示创建成功。
CREATE TABLE
GBase 8c V5 开发者手册
南大通用数据技术股份有限公司
37
创建列存分区表的数量建议不超过1000 个。
步骤2 插入数据
将表tpcds.customer_address 的数据插入到表tpcds.web_returns_p2 中。例如在数据库中
创建了一个表tpcds.customer_address 的备份表tpcds.web_returns_p2 ，现在需要将表
tpcds.customer_address 中的数据插入到表tpcds.web_returns_p2 中，则可以执行如下命令。
postgres=# CREATE TABLE tpcds.web_returns_p2 (
ca_address_sk
integer NOT NULL, ca_address_id character(16),
ca_street_number character(10) , ca_street_name character varying(60),
ca_street_type character(15), ca_suite_number
character(10), ca_city
character varying(60), ca_county character varying(30), ca_state character(2),
ca_zip character(10), ca_country
character varying(20), ca_gmt_offset
numeric(5,2), ca_location_type character(20))
PARTITION BY RANGE (ca_address_sk) (
PARTITION P1 VALUES LESS THAN(5000), PARTITION P2 VALUES LESS THAN(10000),
PARTITION P3 VALUES LESS THAN(15000), PARTITION P4 VALUES LESS THAN(20000),
PARTITION P5 VALUES LESS THAN(25000), PARTITION P6 VALUES LESS THAN(30000),
PARTITION P7 VALUES LESS THAN(40000), PARTITION P8 VALUES LESS THAN(MAXVALUE)
)
ENABLE ROW MOVEMENT;
CREATE TABLE
postgres=# INSERT INTO tpcds.web_returns_p2 SELECT * FROM
tpcds.customer_address;
INSERT 0 0
步骤3 修改分区表行迁移属性
postgres=# ALTER TABLE tpcds.web_returns_p2 DISABLE ROW MOVEMENT;
ALTER TABLE
步骤4 删除分区
删除分区P8。
postgres=# ALTER TABLE tpcds.web_returns_p2 DROP PARTITION P8;
ALTER TABLE
步骤5 增加分区
增加分区P8，范围为40000<= P8<=MAXVALUE。
postgres=# ALTER TABLE tpcds.web_returns_p2 ADD PARTITION P8 VALUES LESS THAN
(MAXVALUE);
ALTER TABLE
GBase 8c V5 开发者手册
南大通用数据技术股份有限公司
38
步骤6 重命名分区
重命名分区P8 为P_9。
postgres=# ALTER TABLE tpcds.web_returns_p2 RENAME PARTITION P8 TO P_9;
ALTER TABLE
重命名分区P_9 为P8。
postgres=# ALTER TABLE tpcds.web_returns_p2 RENAME PARTITION FOR (40000) TO P8;
ALTER TABLE
步骤7 查询分区
查询分区P6。
postgres=# SELECT * FROM tpcds.web_returns_p2 PARTITION (P6);
postgres=# SELECT * FROM tpcds.web_returns_p2 PARTITION FOR (35888);
步骤8 删除分区表和表空间
postgres=# DROP TABLE tpcds.customer_address; DROP TABLE
postgres=# DROP TABLE tpcds.web_returns_p2; DROP TABLE