opengauss创建和管理分区表

2024-06-05 08:20
文章标签 创建 管理 opengauss 分区表

本文主要是介绍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') ) );

这篇关于opengauss创建和管理分区表的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/1032555。

相关文章

综合安防管理平台LntonAIServer视频监控汇聚抖动检测算法优势

综合安防管理平台LntonAIServer视频监控汇聚抖动检测算法优势

LntonAIServer视频质量诊断功能中的抖动检测是一个专门针对视频稳定性进行分析的功能。抖动通常是指视频帧之间的不必要运动，这种运动可能是由于摄像机的移动、传输中的错误或编解码问题导致的。抖动检测对于确保视频内容的平滑性和观看体验至关重要。 优势 1. 提高图像质量 - 清晰度提升：减少抖动，提高图像的清晰度和细节表现力，使得监控画面更加真实可信。 - 细节增强：在低光条件下，抖
阅读更多...
【Python编程】Linux创建虚拟环境并配置与notebook相连接

【Python编程】Linux创建虚拟环境并配置与notebook相连接

1.创建 使用 venv 创建虚拟环境。例如，在当前目录下创建一个名为 myenv 的虚拟环境： python3 -m venv myenv 2.激活 激活虚拟环境使其成为当前终端会话的活动环境。运行： source myenv/bin/activate 3.与notebook连接 在虚拟环境中，使用 pip 安装 Jupyter 和 ipykernel： pip instal
阅读更多...
在cscode中通过maven创建java项目

在cscode中通过maven创建java项目

在cscode中创建java项目 可以通过博客完成maven的导入 建立maven项目 使用快捷键 Ctrl + Shift + P 建立一个 Maven 项目 1 Ctrl + Shift + P 打开输入框2 输入 "> java create"3 选择 maven4 选择 No Archetype5 输入 域名6 输入项目名称7 建立一个文件目录存放项目，文件名一般为项目名8 确定
阅读更多...
软考系统规划与管理师考试证书含金量高吗？

软考系统规划与管理师考试证书含金量高吗？

2024年软考系统规划与管理师考试报名时间节点： 报名时间：2024年上半年软考将于3月中旬陆续开始报名 考试时间：上半年5月25日到28日，下半年11月9日到12日 分数线：所有科目成绩均须达到45分以上（包括45分）方可通过考试 成绩查询：可在“中国计算机技术职业资格网”上查询软考成绩 出成绩时间：预计在11月左右 证书领取时间：一般在考试成绩公布后3~4个月，各地领取时间有所不同
阅读更多...
安全管理体系化的智慧油站开源了。

安全管理体系化的智慧油站开源了。

AI视频监控平台简介 AI视频监控平台是一款功能强大且简单易用的实时算法视频监控系统。它的愿景是最底层打通各大芯片厂商相互间的壁垒，省去繁琐重复的适配流程，实现芯片、算法、应用的全流程组合，从而大大减少企业级应用约95%的开发成本。用户只需在界面上进行简单的操作，就可以实现全视频的接入及布控。摄像头管理模块用于多种终端设备、智能设备的接入及管理。平台支持包括摄像头等终端感知设备接入，为整个平台提
阅读更多...
Java 创建图形用户界面（GUI）入门指南（Swing库 JFrame 类）概述

Java 创建图形用户界面（GUI）入门指南（Swing库 JFrame 类）概述

概述 基本概念 Java Swing 的架构 Java Swing 是一个为 Java 设计的 GUI 工具包，是 JAVA 基础类的一部分，基于 Java AWT 构建，提供了一系列轻量级、可定制的图形用户界面（GUI）组件。 与 AWT 相比，Swing 提供了许多比 AWT 更好的屏幕显示元素，更加灵活和可定制，具有更好的跨平台性能。 组件和容器 Java Swing 提供了许多
阅读更多...
顺序表之创建，判满，插入，输出

顺序表之创建，判满，插入，输出

文章目录 🍊自我介绍🍊创建一个空的顺序表，为结构体在堆区分配空间🍊插入数据🍊输出数据🍊判断顺序表是否满了，满了返回值1，否则返回0🍊main函数 你的点赞评论就是对博主最大的鼓励 当然喜欢的小伙伴可以：点赞+关注+评论+收藏（一键四连）哦~ 🍊自我介绍   Hello,大家好，我是小珑也要变强（也是小珑），我是易编程·终身成长社群的一名“创始团队·嘉宾”
阅读更多...
从状态管理到性能优化：全面解析 Android Compose

从状态管理到性能优化：全面解析 Android Compose

文章目录 引言一、Android Compose基本概念1.1 什么是Android Compose?1.2 Compose的优势1.3 如何在项目中使用Compose 二、Compose中的状态管理2.1 状态管理的重要性2.2 Compose中的状态和数据流2.3 使用State和MutableState处理状态2.4 通过ViewModel进行状态管理 三、Compose中的列表和滚动
阅读更多...
Maven创建项目中的groupId, artifactId, 和 version的意思

Maven创建项目中的groupId, artifactId, 和 version的意思

文章目录 groupIdartifactIdversionname groupId 定义：groupId 是 Maven 项目坐标的第一个部分，它通常表示项目的组织或公司的域名反转写法。例如，如果你为公司 example.com 开发软件，groupId 可能是 com.example。作用：groupId 被用来组织和分组相关的 Maven artifacts，这样可以避免
阅读更多...
批处理以当前时间为文件名创建文件

批处理以当前时间为文件名创建文件

批处理以当前时间为文件名创建文件 批处理创建空文件 有时候，需要创建以当前时间命名的文件，手动输入当然可以，但是有更省心的方法吗？ 假设我是 windows 操作系统，打开命令行。 输入以下命令试试： echo %date:~0,4%_%date:~5,2%_%date:~8,2%_%time:~0,2%_%time:~3,2%_%time:~6,2% 输出类似： 2019_06
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2