opengauss创建和管理分区表

创建和管理分区表

背景信息

openGauss数据库支持的分区表为范围分区表、列表分区表、哈希分区表

  • 范围分区表:将数据基于范围映射到每一个分区,这个范围是由创建分区表时指定的分区键决定的。这种分区方式是最为常用的,并且分区键经常采用日期,例如将销售数据按照月份进行分区。
  • 列表分区表:将数据中包含的键值分别存储在不同的分区中,依次将数据映射到每一个分区,分区中包含的键值由创建分区表时指定。
  • 哈希分区表:将数据根据内部哈希算法依次映射到每一个分区中,包含的分区个数由创建分区表时指定。

分区表和普通表相比具有以下优点:

  • 改善查询性能:对分区对象的查询可以仅搜索自己关心的分区,提高检索效率。
  • 增强可用性:如果分区表的某个分区出现故障,表在其他分区的数据仍然可用。
  • 方便维护:如果分区表的某个分区出现故障,需要修复数据,只修复该分区即可。
  • 均衡I/O:可以把不同的分区映射到不同的磁盘以平衡I/O,改善整个系统性能。

普通表若要转成分区表,需要新建分区表,然后把普通表中的数据导入到新建的分区表中。因此在初始设计表时,请根据业务提前规划是否使用分区表。

如果需要查看分区表的信息,可以通过pg_partition来查看

操作步骤

示例一:使用默认表空间

  • 创建范围分区表(假设用户已创建tpcds schema)
    postgres=# CREATE TABLE tpcds.customer_address
    (ca_address_sk       integer                  NOT NULL   ,ca_address_id       character(16)            NOT NULL   ,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
    

     说明: 创建列存分区表的数量建议不超过1000个。

另一种写法,使用start和end:
CREATE TABLE ptest4
(
    id        integer                  NOT NULL   ,
 name varchar(10)
)
PARTITION BY RANGE (id)
(
        PARTITION P1 start (0) end (9999),
        PARTITION P2 start (9999) end (20000),
        partition p3 end (MAXVALUE)
)
ENABLE ROW MOVEMENT;
  • 其它说明
1.对于没有maxvalue的范围分区,如果插入超过范围的值,会报错:
test=> insert into ptest1 values(50000,'dd');
ERROR:  inserted partition key does not map to any table partition
Time: 10.239 ms
2.对于有maxvalue的范围分区,则不能再添加新的分区,必须用split,否则报错:
test=> alter table ptest2 add partition p10 values less than (60000);
ERROR:  upper boundary of adding partition MUST overtop last existing partition
必须先删除top分区即maxval分区,再新增分区.
3.对于使用start和end的语法,前一个分区的end必须和后一个分区的start连续,否则报错:
ERROR:  start value of partition "p2" is too high.
HINT:  partition gap or overlapping is not allowed.
4.
interval range分区:
CREATE TABLE ptest3
(
    order_no              INTEGER          NOT NULL,
    sales_date            DATE             NOT NULL
)
PARTITION BY RANGE(sales_date) INTERVAL ('1 month') 
(
PARTITION start VALUES LESS THAN('2021-01-01 00:00:00')
);
interval分区会自动创建分区
  • interval_expr自动创建分区的间隔,例如:

    自动创建分区的间隔,例如:1 day、1 month。

  • 插入数据

    将表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)            NOT NULL   ,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
  • date类型的分区表
openGauss=# CREATE TABLE sales_table
(
    order_no              INTEGER          NOT NULL,
    goods_name            CHAR(20)         NOT NULL,
    sales_date            DATE             NOT NULL,
    sales_volume          INTEGER,
    sales_store           CHAR(20)
)
PARTITION BY RANGE(sales_date)
(
        PARTITION season1 VALUES LESS THAN('2021-04-01 00:00:00'),
        PARTITION season2 VALUES LESS THAN('2021-07-01 00:00:00'),
        PARTITION season3 VALUES LESS THAN('2021-10-01 00:00:00'),
        PARTITION season4 VALUES LESS THAN(MAXVALUE)
);
  • 修改分区表行迁移属性
    postgres=# ALTER TABLE tpcds.web_returns_p2 DISABLE ROW MOVEMENT;
    ALTER TABLE
    
  • 删除分区

    删除分区P8。

    postgres=# ALTER TABLE tpcds.web_returns_p2 DROP PARTITION P8;
    ALTER TABLE
    
  • 增加分区

    增加分区P8,范围为 40000<= P8<=MAXVALUE。

    postgres=# ALTER TABLE tpcds.web_returns_p2 ADD PARTITION P8 VALUES LESS THAN (MAXVALUE);
    ALTER TABLE
    
  • 重命名分区
    • 重命名分区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
      
  • 查询分区

    查询分区P6。

    postgres=# SELECT * FROM tpcds.web_returns_p2 PARTITION (P6);
    postgres=# SELECT * FROM tpcds.web_returns_p2 PARTITION FOR (35888);
    
  • 删除分区表和表空间
    postgres=# DROP TABLE tpcds.customer_address;
    DROP TABLE
    postgres=# DROP TABLE tpcds.web_returns_p2;
    DROP TABLE
  • 分裂分区(指定切割点split_partition_value的语法):
    ALTER TABLE partition_table_name SPLIT PARTITION partition_name AT ( split_partition_value ) INTO ( PARTITION partition_new_name1, PARTITION partition_new_name2); 
    test=> alter table ptest2 split partition p8 at (60000) into (partition p9,partition pmax);
    分裂分区(指定分区范围的语法):
    ALTER TABLE partition_table_name SPLIT PARTITION partition_name INTO { ( partition_less_than_item [, ...] ) | ( partition_start_end_item [, ...] ) }; 
    合并分区:
    ALTER TABLE partition_table_name MERGE PARTITIONS { partition_name } [, ...] INTO PARTITION partition_name; 
    test=> alter table ptest2 merge partitions p9,pmax into partition pmax;
    
    

示例二:使用用户自定义表空间

按照以下方式对范围分区表的进行操作。

  • 创建表空间
    openGauss=# CREATE TABLESPACE example1 RELATIVE LOCATION 'tablespace1/tablespace_1';
    openGauss=# CREATE TABLESPACE example2 RELATIVE LOCATION 'tablespace2/tablespace_2';
    openGauss=# CREATE TABLESPACE example3 RELATIVE LOCATION 'tablespace3/tablespace_3';
    openGauss=# CREATE TABLESPACE example4 RELATIVE LOCATION 'tablespace4/tablespace_4';
    

    当结果显示为如下信息,则表示创建成功。

    CREATE TABLESPACE
    
  • 创建分区表
    openGauss=# CREATE TABLE tpcds.customer_address
    (ca_address_sk       integer                  NOT NULL   ,ca_address_id       character(16)            NOT NULL   ,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)
    )
    TABLESPACE example1PARTITION 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) TABLESPACE example2
    )
    ENABLE ROW MOVEMENT;
    

    当结果显示为如下信息,则表示创建成功。

    CREATE TABLE
    

     说明: 创建列存分区表的数量建议不超过1000个。

  • 插入数据

    将表tpcds.customer_address的数据插入到表tpcds.web_returns_p2中。

    例如在数据库中创建了一个表tpcds.customer_address的备份表tpcds.web_returns_p2,现在需要将表tpcds.customer_address中的数据插入到表tpcds.web_returns_p2中,则可以执行如下命令。

    openGauss=# CREATE TABLE tpcds.web_returns_p2
    (ca_address_sk       integer                  NOT NULL   ,ca_address_id       character(16)            NOT NULL   ,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)
    )
    TABLESPACE example1
    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) TABLESPACE example2
    )
    ENABLE ROW MOVEMENT;
    CREATE TABLE
    openGauss=# INSERT INTO tpcds.web_returns_p2 SELECT * FROM tpcds.customer_address;
    INSERT 0 0
  • 修改分区表行迁移属性
    openGauss=# ALTER TABLE tpcds.web_returns_p2 DISABLE ROW MOVEMENT;
    ALTER TABLE
    
  • 删除分区

    删除分区P8。

    openGauss=# ALTER TABLE tpcds.web_returns_p2 DROP PARTITION P8;
    ALTER TABLE
    
  • 增加分区

    增加分区P8,范围为 40000<= P8<=MAXVALUE。

    openGauss=# ALTER TABLE tpcds.web_returns_p2 ADD PARTITION P8 VALUES LESS THAN (MAXVALUE);
    ALTER TABLE
    
  • 重命名分区
    • 重命名分区P8为P_9。
      openGauss=# ALTER TABLE tpcds.web_returns_p2 RENAME PARTITION P8 TO P_9;
      ALTER TABLE
      
    • 重命名分区P_9为P8。
      openGauss=# ALTER TABLE tpcds.web_returns_p2 RENAME PARTITION FOR (40000) TO P8;
      ALTER TABLE
      
  • 修改分区的表空间
    • 修改分区P6的表空间为example3。
      openGauss=#  ALTER TABLE tpcds.web_returns_p2 MOVE PARTITION P6 TABLESPACE example3;
      ALTER TABLE
      
    • 修改分区P4的表空间为example4。
      openGauss=#  ALTER TABLE tpcds.web_returns_p2 MOVE PARTITION P4 TABLESPACE example4;
      ALTER TABLE
      
  • 查询分区

    查询分区P6。

    openGauss=# SELECT * FROM tpcds.web_returns_p2 PARTITION (P6);
    openGauss=# SELECT * FROM tpcds.web_returns_p2 PARTITION FOR (35888);
    
  • 删除分区表和表空间
    openGauss=# DROP TABLE tpcds.web_returns_p2;
    DROP TABLE
    openGauss=# DROP TABLESPACE example1;
    openGauss=# DROP TABLESPACE example2;
    openGauss=# DROP TABLESPACE example3;
    openGauss=# DROP TABLESPACE example4;
    DROP TABLESPACE
list分区
openGauss=# CREATE TABLE graderecord 
  ( 
  number INTEGER, 
  name CHAR(20), 
  class CHAR(20), 
  grade INTEGER
  ) 
  PARTITION BY LIST(class) 
  ( 
  PARTITION class_01 VALUES ('21.01'), 
  PARTITION class_02 VALUES ('21.02'),
  PARTITION class_03 VALUES ('21.03'),
  PARTITION class_04 VALUES ('21.04')
  );
hash分区
openGauss=# create table hash_partition_table (
col1 int,
col2 int)
partition by hash(col1)
(
partition p1,
partition p2
);
子分区表创建语法:
CREATE TABLE t_sub_partition
( dept_no number, country varchar2(20), sale_date date)
PARTITION BY RANGE(sale_date)
SUBPARTITION BY LIST(country)
( PARTITION q1_2012 VALUES LESS THAN('2012-Apr-01')
( SUBPARTITION q1_europe VALUES ('FRANCE', 'ITALY'),
SUBPARTITION q1_asia VALUES ('INDIA', 'PAKISTAN'),
SUBPARTITION q1_americas VALUES ('US', 'CANADA') ),
PARTITION q2_2012 VALUES LESS THAN('2012-Jul-01')
( SUBPARTITION q2_europe VALUES ('FRANCE', 'ITALY'),
SUBPARTITION q2_asia VALUES ('INDIA', 'PAKISTAN'),
SUBPARTITION q2_americas VALUES ('US', 'CANADA') ),
PARTITION q3_2012 VALUES LESS THAN('2012-Oct-01')
( SUBPARTITION q3_europe VALUES ('FRANCE', 'ITALY'),
SUBPARTITION q3_asia VALUES ('INDIA', 'PAKISTAN'),
SUBPARTITION q3_americas VALUES ('US', 'CANADA') ),
PARTITION q4_2012 VALUES LESS THAN('2013-Jan-01')
( SUBPARTITION q4_europe VALUES ('FRANCE', 'ITALY'),
SUBPARTITION q4_asia VALUES ('INDIA', 'PAKISTAN'),
SUBPARTITION q4_americas VALUES ('US', 'CANADA') ) );

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.mzph.cn/pingmian/22529.shtml

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈email:809451989@qq.com,一经查实,立即删除!

相关文章

Springboot 开发-- 集成 Activiti 7 流程引擎

引言 Activiti 7是一款遵循BPMN 2.0标准的开源工作流引擎&#xff0c;旨在为企业提供灵活、可扩展的流程管理功能。它支持图形化的流程设计、丰富的API接口、强大的执行引擎和完善的监控报表&#xff0c;帮助企业实现业务流程的自动化、规范化和智能化。本文将为您详细介绍 Ac…

Spring (39)微服务架构

微服务架构是一种将单个应用程序作为一套小服务开发的方法&#xff0c;每个服务运行在其自身的进程中&#xff0c;并且通常围绕业务能力构建&#xff0c;使用轻量级的通信机制&#xff08;常见的如HTTP RESTful API&#xff09;。这些服务是自包含的&#xff0c;因为它们分别持…

kubesphere报错

1.安装过程报错unable to sign certificate: must specify a CommonName [rootnode1 ~]# ./kk init registry -f config-sample.yaml -a kubesphere.tar.gz _ __ _ _ __ | | / / | | | | / / | |/ / _ _| |__ ___| |/…

pytest-playwright 插件的使用

引言 在自动化测试领域&#xff0c;Playwright 是一个强大的工具&#xff0c;它支持 Chromium、Firefox 和 WebKit 三大浏览器引擎。Playwright 提供了与 Pytest 集成的插件&#xff0c;使得编写端到端测试变得更加简单和高效。本文将介绍如何使用 Pytest Playwright 插件来编…

Git - 创建和应用patch

如何在 Git 中打补丁 创建和应用 Git 补丁需要几个步骤。以下是详细的操作指南&#xff1a; 创建 Git 补丁 修改&#xff1a; 首先&#xff0c;在本地仓库中进行您想要的修改。 保存修改&#xff1a; 使用 "git add "对更改进行暂存。例如 git add modified_file…

Leetcode:最长公共前缀

题目链接&#xff1a;14. 最长公共前缀 - 力扣&#xff08;LeetCode&#xff09; 普通版本&#xff08;横向扫描&#xff09; 主旨&#xff1a;用第一个字符串与后续的每个字符串进行比较&#xff0c;先获取S1和S2的最长公共前缀&#xff0c;然后将该次比较获得的最长公共前缀…

python中如何使用密码字典

使用itertools循环迭代的模块来实现生成密码字典&#xff0c;用这个模块可以省不少事。 首先要调用itertools。 import itertools as its 然后将字典需要的元素&#xff08;或者说是关键字&#xff09;赋给word变量。 我们这里假设密码是纯数字&#xff0c;所以元素就是12345…

创新指南|2024企业如何开启生成式AI创新?从5大应用场景和6步抓手

想要了解如何采用生成式AI来提高企业效率和竞争力&#xff1f;本指南将介绍如何采用生成式AI来实现数字化转型&#xff0c;并打造智能化商业模式。从5大应用场景和6大步骤切入&#xff0c;让您了解如何开启生成式AI创新。立即连线创新专家咨询或观看创新战略方案视频进一步了解…

test2042

语义边缘检测和语义分割的区别 语义边缘检测&语义分割 Semantic Edge Detection vs. Semantic Segmentation 区别difference 任务目标 Task Objective 语义边缘检测 Semantic Edge Detection 识别图像中不同物体之间的边界线或轮廓及语义类别 Identifying the boundaries …

Less is more VS 精一 [生活感悟]

"Less is More”和王阳明的“精一”思想确实有相似之处。 王阳明的“精一”思想强调的是专注于一件事&#xff0c;将其做到极致&#xff0c;这与"Less is More”中提倡的通过减少数量来提高质量的理念不谋而合。两者都强调了专注和深度的重要性&#xff0c;而不是追…

2024如何优化SEO?

在2024年的今天&#xff0c;要问我会如何优化seo&#xff0c;我会专注于几个关键的方面。首先&#xff0c;随着AI内容生成技术的发展&#xff0c;我会利用这些工具来帮助创建或优化我的网站内容&#xff0c;但是&#xff0c;随着谷歌3月份的算法更新&#xff0c;纯粹的ai内容可…

无法访问内网怎么办?

许多用户在日常生活和工作中&#xff0c;经常需要进行远程连接和访问内网的需求。出于各种原因&#xff0c;有时我们会遇到无法访问内网的问题。本文将从可能的原因和解决方案的角度来探讨此问题。 原因分析 网络设置问题: 在一些情况下&#xff0c;我们无法访问内网可能是因为…

奈奎斯特极限定理(B=2W)

信道的带宽决定了信道中能不是阵地传输脉冲序列的最高速率。一个数字脉冲称为一个码元&#xff0c;用码元速率表示单位时间内信号波形的变化次数&#xff0c;即单位时间内通过信道传输的码元个数。若信号码元宽度为T秒&#xff0c;则码元速率B1/T。码元速率的单位叫波特。所以码…

分层存储的图片的3d显示

分层存储的图片叠层成为3d&#xff0c;并显示。 文件夹D:\mask内的分层存储的图像文件mask_1.PNG至mask_12.PNG&#xff1a; 1、显示为3d点云&#xff1a; import open3d as o3d import numpy as np from PIL import Imagedef images2point_cloud(paths, layer_height):point…

音频滤波笔记之高低通滤波器

音频滤波 音频滤波数字滤波器设计一阶IIR数字滤波器的设计最简单的低通滤波器高通滤波器带通滤波器带阻滤波器 算法高通滤波 参考文档 音频滤波 数字滤波器设计 一阶IIR数字滤波器的设计 最简单的低通滤波器 传递函数 H ( s ) 1 1 s H(s) \frac{1}{1 s} H(s)1s1​ 傅氏…

(九)Spring教程——ApplicationContext中Bean的生命周期

1.前言 ApplicationContext中Bean的生命周期和BeanFactory中的生命周期类似&#xff0c;不同的是&#xff0c;如果Bean实现了org.springframework.context.ApplicationContextAware接口&#xff0c;则会增加一个调用该接口方法setApplicationContext()的步骤。 此外&#xff0c…

NeMo训练llama2_7b(不用NeMo-Framework-Launcher)

TOC 本文介绍了NeMo如何训练llama2_7b模型 1.参考链接 支持的模型列表功能特性LLAMA2端到端流程(基于NeMo-Framework-Launcher) 2.创建容器 docker run --gpus all --shm-size32g -ti -e NVIDIA_VISIBLE_DEVICESall \--privileged --nethost -v $PWD:/home \-w /home --na…

香橙派 Orange AIpro 测评记录视频硬件解码

香橙派 Orange AIpro 测评记录视频硬件解码 香橙派官网&#xff1a;http://www.orangepi.cn/ 收到了一块Orange Pi AIpro开发板&#xff0c;记录一下我的测评~测评简介如下&#xff1a;1.连接网络2.安装流媒体进行硬件解码测试3.安装IO测试 简介 Orange Pi AI Pro 是香橙派联合…

0基础学习区块链技术——链之间数据同步样例

我们可以在https://blockchaindemo.io/体验这个过程。 创建区块 默认第一个链叫Satoshi(中本聪)。链上第一个区块叫“创世区块”——Genesis Block。后面我们会看到创建的第二条链第一个区块也是如此。 新增链 新创建的链叫Debby。默认上面有一个创世区块。 然后我们让这…

Android自定义View - LayoutParams

这一期我们来讲一讲LayoutParams这个玩意儿。Android入门的第一行代码就牵扯到这个东西&#xff0c;然而&#xff0c;你真的理解够了吗&#xff1f; 第一层理解 <RelativeLayout xmlns:android"http://schemas.android.com/apk/res/android"xmlns:app"http…