Открыть страницу поиска
Привет, Я DocuDroid!
Открыть страницу ИИ Помощника
Оценка ИИ поиска
Спасибо за оценку нашего ИИ поиска!
Мы будем признательны, если вы поделитесь своими впечатлениями, чтобы мы могли улучшить наш ИИ поиск для вас и других читателей.
GitHub

Партиционирование

Андрей Аксенов

Партиционирование (или секционирование) помогает эффективно работать с очень большими таблицами, например таблицами фактов, разбивая их на меньшие части — партиции (секции). Это позволяет ускорить выполнение запросов, поскольку оптимизатор Greengage DB обращается только к нужным партициям, а не ко всей таблице.

Настройки партиционирования указываются при создании таблицы с помощью ключа партиционирования — одного или нескольких столбцов, по которым определяется, как данные распределяются по партициям.

Введение в партиционирование таблиц

Как работает партиционирование

Партиционирование и распределение данных выполняют разные задачи в Greengage DB. Партиционирование делит большую таблицу на меньшие части для повышения производительности запросов и упрощения обслуживания, например, архивирования или удаления устаревших данных. Распределение, в свою очередь, определяет, как данные (и в партиционированных, и в непартиционированных таблицах) распределяются по сегментам для обеспечения параллельного выполнения запросов. Партиционирование не влияет на распределение данных по сегментам.

Таблицы разбиваются на партиции при создании с помощью выражения PARTITION BY, при необходимости с последующим указанием SUBPARTITION BY для многоуровневого партиционирования. Партиционирование создает родительскую таблицу с одним или несколькими уровнями дочерних таблиц. Между родительской и дочерними таблицами устанавливается отношение наследования, схожее по функциональности с выражением INHERITS.

Greengage DB использует критерии партиционирования, определенные при создании таблицы, чтобы создавать отдельные партиции. Каждая партиция создается с ограничением-проверкой (CHECK), которое определяет допустимый диапазон данных для этой партиции. Оптимизатор запросов использует эти ограничения, чтобы понять, какие партиции нужно просканировать для выполнения запроса с заданным условием.

Данный пример показывает таблицу sales с одноуровневым партиционированием, где каждая партиция охватывает один месяц в первом квартале 2025 года. Каждая партиция соответствует определенному диапазону дат, заданному правилами партиционирования:

sales
   ├─── sales_1_prt_jan_2025    (date >= '2025-01-01' AND date < '2025-02-01')
   ├─── sales_1_prt_feb_2025    (date >= '2025-02-01' AND date < '2025-03-01')
   └─── sales_1_prt_mar_2025    (date >= '2025-03-01' AND date < '2025-04-01')

В следующем примере показана таблица sales с двухуровневым партиционированием. Ежемесячные партиции дополнительно разбиваются на сабпартиции по столбцу region, разделяя данные на сабпартиции asia и europe:

sales
   ├─── sales_1_prt_jan_2025                      (date >= '2025-01-01' AND date < '2025-02-01')
   │    ├─── sales_1_prt_jan_2025_2_prt_asia          (region = 'Asia')
   │    └─── sales_1_prt_jan_2025_2_prt_europe        (region = 'Europe')
   ├─── sales_1_prt_feb_2025                      (date >= '2025-02-01' AND date < '2025-03-01')
   │    ├─── sales_1_prt_feb_2025_2_prt_asia          (region = 'Asia')
   │    └─── sales_1_prt_feb_2025_2_prt_europe        (region = 'Europe')
   └─── sales_1_prt_mar_2025                      (date >= '2025-03-01' AND date < '2025-04-01')
        ├─── sales_1_prt_mar_2025_2_prt_asia          (region = 'Asia')
        └─── sales_1_prt_mar_2025_2_prt_europe        (region = 'Europe')
ПРИМЕЧАНИЕ

Партиционированная таблица может иметь максимум 32767 партиций на каждом уровне иерархии.

Для вставки данных в партиционированную таблицу обычно используется либо родительская партиционированная таблица (sales в приведенном выше примере), либо одна из ее конечных дочерних партиций (например, sales_1_prt_jan_2025_2_prt_asia и sales_1_prt_jan_2025_2_prt_europe). При вставке данных учитывайте следующее:

  • Вы можете вставлять данные в родительскую таблицу (например, sales), созданную с помощью команды CREATE TABLE. Greengage DB автоматически распределяет данные по дочерним партициям на основе правил партиционирования.

  • Вы можете вставлять данные напрямую в партицию нижнего уровня (например, sales_1_prt_jan_2025_2_prt_europe), если данные соответствуют критериям этой партиции.

  • Вставка данных в промежуточную партицию (например, sales_1_prt_jan_2025) не поддерживается и приведет к ошибке.

Обратите внимание, что верхнеуровневые и промежуточные таблицы — например, sales, sales_1_prt_jan_2025, sales_1_prt_feb_2025 и sales_1_prt_mar_2025 — остаются пустыми после вставки данных.

РЕКОМЕНДАЦИЯ

Рекомендуемая практика загрузки данных в партиционированные таблицы — использование обмена партиции.

Когда использовать партиционирование

Используйте партиционирование, если к таблице применимы большинство из следующих пунктов:

  • Таблица представляет собой большую таблицу фактов.

    Таблицы фактов с миллионами строк хорошо подходят для партиционирования. Партиционирование небольших таблиц с тысячами строк и меньше, напротив, малоэффективно.

  • Вас не устраивает текущая скорость выполнения запросов к данным.

    Применяйте партиционирование только к тем таблицам, запросы к которым выполняются значительно медленнее, чем требуется.

  • Существует столбец, позволяющий разделить таблицу на примерно равные по размеру партиции.

    Выберите ключ для партиционирования, чтобы количество строк в каждой партиции было приблизительно одинаковым. Чем равномернее таблица разбита на небольшие части, тем выше будет прирост производительности за счет партиционирования. Например, разделение таблицы на 10 партиций одинакового размера может увеличить производительность запросов до 10 раз — при условии, что ключ партиционирования используется в предикатах запроса (см. следующий пункт ниже).

  • Большинство запросов, требующих ускорения, используют ключ партиции в своих условиях.

    Партиционирование повышает производительность только тогда, когда оптимизатор может отфильтровать партиции на основе предикатов запроса. Если запрос сканирует все партиции, его выполнение может быть медленнее, чем при работе с непартиционированной таблицей. Убедитесь, что планы выполнения запросов содержат partition elimination (сканирование ограниченного числа партиций).

  • Существуют бизнес-требования по хранению исторических данных.

    Партиционирование хорошо подходит для управления хранением данных по периодам времени. Например, если нужно хранить данные только за последние 12 месяцев, можно удалить самую старую партицию и загрузить новые данные в новую партицию.

Избегайте создания большего числа партиций, чем необходимо. Чрезмерное партиционирование может негативно сказаться на работе системы, включая операции вакуумирования, восстановление сегментов, расширение кластера, проверку использования диска и другие операции.

Обзор синтаксиса

Чтобы задать стратегию партиционирования, используйте выражение PARTITION BY в команде CREATE TABLE. Чтобы партиционировать таблицу:

  1. Определите схему партиционирования: по временному диапазону, числовому диапазону или списку значений.

  2. Выберите столбец (или столбцы), который будет использоваться в качестве ключа партиционирования.

  3. Определите необходимое количество уровней партиционирования. Например, можно создать таблицу с партиционированием по месяцам, а затем разбить каждую месячную партицию на сабпартиции по региону продаж.

Упрощенный синтаксис команды CREATE TABLE с одноуровневым партиционированием выглядит следующим образом:

CREATE TABLE <table_name> (
  <column_definitions>
)
[ PARTITION BY <partition_type> (<column>)
  (
      <partition_spec>
  )]

Основные аргументы:

  • partition_type — указывает тип партиционирования: LIST (на основе списка значений) или RANGE (на основе диапазона: числового или дат).

  • column — определяет столбец, используемый для партиционирования.

  • partition_spec — определяет создаваемые партиции. Основные выражения:

    • START, END и EVERY — используются для определения партиций на основе диапазонов.

    • VALUES — указывает значения для партиций на основе списков значений.

    • DEFAULT PARTITION — служит для размещения строк, не соответствующих заданным условиям; применяется ко всем типам партиционирования. Обратите внимание, что оптимизатор запросов всегда сканирует партицию по умолчанию, что может замедлить общее время сканирования, если эта партиция содержит данные.

ПРИМЕЧАНИЕ

  • Если партиционируемая таблица содержит первичный ключ или столбец с ограничением уникальности (UNIQUE) — они должны быть указаны в ключе партиционирования.

  • Таблицы, созданные с использованием политики распределения данных DISTRIBUTED REPLICATED, не могут быть партиционированы.

Партиционирование на основе диапазонов

Партиционирование по диапазону делит данные на основе числовых или временных диапазонов. Используйте выражение PARTITION BY RANGE, чтобы указать столбец ключа партиционирования, а затем определите интервалы партиций с помощью ключевых слов START и END. Модификаторы INCLUSIVE и EXCLUSIVE определяют, включаются ли граничные значения в диапазон. По умолчанию значения START включаются в диапазон, а значения END — исключаются.

Существует два способа определить партиции на основе диапазонов — автоматически и вручную.

Автоматическое формирование партиций

Чтобы создать партиции автоматически, используйте выражения START и END для указания границ общего диапазона. Затем укажите размер партиции с помощью выражения EVERY:

  • Для временных диапазонов необходимо указать единицу интервала, например, day, month или year. Пример: EVERY (INTERVAL '1 month').

  • Для числовых диапазонов указывается значение шага. Пример: EVERY (100).

СУБД автоматически создает необходимые партиции, деля весь диапазон на равные интервалы на основании указанного шага.

PARTITION BY RANGE (<column>)
    (
    START ([<datatype>] '<start_value>') [INCLUSIVE | EXCLUSIVE]
        END ([<datatype>] '<end_value>') [INCLUSIVE | EXCLUSIVE] ]
        EVERY ([<datatype>] [<number> | INTERVAL] '<interval_value>') ]
    );

Определение партиций вручную

Альтернативный способ задания партиционированной таблицы — указание каждой партиции вручную. В этом случае перечислите определения партиций через запятую в скобках после выражения PARTITION BY RANGE.

Определение каждой партиции начинается с выражения PARTITION <partition_name>, где <partition_name> — пользовательский идентификатор, который используется в имени партиции вместо автоматически сгенерированного числа.

После имени партиции используйте стандартные выражения START и END для задания границ диапазона каждой партиции. Обратите внимание, что только для последней партиции необходимо указывать значение END; для всех остальных оно необязательно.

PARTITION BY RANGE (<column>)
    (
    PARTITION <name>
        START ([<datatype>] '<start_value>') [INCLUSIVE | EXCLUSIVE]
        END ([<datatype>] '<end_value>') [INCLUSIVE | EXCLUSIVE],
    [PARTITION <name> ...]
    );

Партиционирование на основе списков значений

Партиционирование на основе списков значений делит данные на основе заранее определенного набора значений ключа партиционирования. Используйте выражение PARTITION BY LIST, чтобы указать столбец ключа партиционирования, а затем — определения партиций в круглых скобках через запятую.

Определение каждой партиции следует этому шаблону:

PARTITION <partition_name> VALUES (<list_value>[, ...])

где:

  • <partition_name> — пользовательский идентификатор, используемый вместо автоматически сгенерированного номера в полном имени партиции;

  • <list_value> — одно или несколько значений ключа партиционирования, относящихся к данной партиции.

Многоуровневое партиционирование

Многоуровневое партиционирование сочетает партиционирование на основе диапазонов и списков значений на нескольких уровнях. Это позволяет делить партиции первого уровня на сабпартиции второго уровня, которые при необходимости можно разделить дальше.

Используйте выражение PARTITION BY (с RANGE или LIST), чтобы определить ключ партиционирования на первом уровне. Для всех последующих уровней используйте выражение SUBPARTITION BY (также с RANGE или LIST). Определения сабпартиций имеют тот же формат, как и обычные партиции, но с использованием ключевого слова SUBPARTITION вместо PARTITION.

Существует два способа определить сабпартиции — вручную или с помощью шаблона сабпартиций.

Определение сабпартиций вручную

В этом подходе каждая партиция и сабпартиция определяется явно. Сначала укажите все ключи партиционирования с помощью выражений PARTITION BY и SUBPARTITION BY. Затем перечислите спецификации партиций и сабпартиций.

Иерархия партиций и сабпартиций определяется с помощью вложенных круглых скобок, отражая их уровень в структуре партиционирования.

CREATE TABLE <table_name> (
  <column_definitions>
)
[ PARTITION BY <partition_type> (<column>)
   [ SUBPARTITION BY <partition_type> (<column1>) ]
      [ SUBPARTITION BY <partition_type> (<column2>) ]
         [...]
  ( <partition_spec>
     [ ( <subpartition_spec_column1>
          [ ( <subpartition_spec_column2>
               [...] ) ] ) ],
  [ <partition_spec>
     [ ( <subpartition_spec_column1>
        [ ( <subpartition_spec_column2>
             [...] ) ] ) ], ]
    [...]
  ) ]

Шаблоны сабпартиций

В этом подходе сабпартиции для каждого уровня иерархии задаются один раз с помощью выражения SUBPARTITION TEMPLATE, размещенного сразу после соответствующего выражения SUBPARTITION BY. Использование шаблона сабпартиций обеспечивает единообразную структуру всех партиций, включая те, что будут добавлены в будущем.

CREATE TABLE <table_name> (
  <column_definitions>
)
[ PARTITION BY <partition_type> (<column>)
  {  [ SUBPARTITION BY <partition_type> (<column1>)
       SUBPARTITION TEMPLATE ( <template_spec> ) ]
          [ SUBPARTITION BY partition_type (<column2>)
            SUBPARTITION TEMPLATE ( <template_spec> ) ]
              [...]  }
  ( <partition_spec> ) ]

Создание партиционированных таблиц

Предварительные требования

Для выполнения команд, описанных в следующих разделах, подключитесь к мастер-хосту Greengage DB с помощью psql, как описано в статье Подключение к Greengage DB с использованием psql. Затем создайте новую базу данных и подключитесь к ней:

CREATE DATABASE marketplace;
\c marketplace

Временные диапазоны

Команда ниже создает таблицу с партиционированием по диапазону, где каждая партиция охватывает один месяц первого квартала 2025 года, а также включает партицию по умолчанию для выходящих за пределы диапазона дат:

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        (
        START (DATE '2025-01-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE
            EVERY (INTERVAL '1 month'),
        DEFAULT PARTITION other_dates
        );

Следующая команда создает такую же партиционированную таблицу sales, но определяет каждую партицию вручную:

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        (
        PARTITION jan_2025 START (DATE '2025-01-01') INCLUSIVE,
        PARTITION feb_2025 START (DATE '2025-02-01') INCLUSIVE,
        PARTITION mar_2025 START (DATE '2025-03-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE,
        DEFAULT PARTITION other_dates
        );

Числовые диапазоны

Данная команда создает таблицу sales с партиционированием по диапазону значений на основе столбца amount:

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (amount)
        (
        START (0)
            END (1000)
            EVERY (250),
        DEFAULT PARTITION out_of_range
        );

Эта команда создает таблицу sales с вручную определенными партициями по диапазону значений:

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (amount)
        (
        PARTITION low_amounts START (0),
        PARTITION medium_amounts START (100),
        PARTITION high_amounts START (500)
            END (1000),
        DEFAULT PARTITION out_of_range);

Списки значений

Следующий SQL-запрос создает таблицу sales с партиционированием по region на основе списка значений. Указаны явные партиции для Asia и Europe, а также партиция по умолчанию для остальных регионов:

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    region TEXT,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY LIST (region)
        (
        PARTITION asia VALUES ('Asia'),
        PARTITION europe VALUES ('Europe'),
        DEFAULT PARTITION other_regions
        );

Многоуровневое партиционирование

Эта команда создает двухуровневую партиционированную таблицу sales: на первом уровне используется автоматическое партиционирование по диапазону по столбцу date, а на втором уровне с помощью SUBPARTITION TEMPLATE задаются дочерние сабпартиции по region:

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    region TEXT,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        SUBPARTITION BY LIST (region)
            SUBPARTITION TEMPLATE
            (
            SUBPARTITION asia VALUES ('Asia'),
            SUBPARTITION europe VALUES ('Europe'),
            DEFAULT SUBPARTITION other_regions
            )
        (
        START (DATE '2025-01-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE
            EVERY (INTERVAL '1 month'),
        DEFAULT PARTITION other_dates
        );

Следующая команда создает двухуровневую партиционированную таблицу sales с вручную заданными ежемесячными партициями по дате, каждая из которых содержит дочерние сабпартиции по region:

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    region TEXT,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        SUBPARTITION BY LIST (region)
        (
        PARTITION jan_2025 START (DATE '2025-01-01') INCLUSIVE (
        SUBPARTITION asia VALUES ('Asia'),
        SUBPARTITION europe VALUES ('Europe'),
        DEFAULT SUBPARTITION other_regions
            ),
        PARTITION feb_2025 START (DATE '2025-02-01') INCLUSIVE (
        SUBPARTITION asia VALUES ('Asia'),
        SUBPARTITION europe VALUES ('Europe'),
        DEFAULT SUBPARTITION other_regions
            ),
        PARTITION mar_2025 START (DATE '2025-03-01') INCLUSIVE (
        SUBPARTITION asia VALUES ('Asia'),
        SUBPARTITION europe VALUES ('Europe'),
        DEFAULT SUBPARTITION other_regions
            ),
        DEFAULT PARTITION other_dates (
        SUBPARTITION asia VALUES ('Asia'),
        SUBPARTITION europe VALUES ('Europe'),
        DEFAULT SUBPARTITION other_regions
            )
        );

Следующая команда создает таблицу sales с трехуровневым партиционированием:

  • автоматическое партиционирование по диапазону по столбцу date;

  • сабпартиционирование по значениям region;

  • сабпартиционирование по диапазонам значений amount.

Для обоих уровней сабпартиционирования используется SUBPARTITION TEMPLATE.

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    region TEXT,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        SUBPARTITION BY LIST (region)
            SUBPARTITION TEMPLATE
            (
            SUBPARTITION asia VALUES ('Asia'),
            SUBPARTITION europe VALUES ('Europe'),
            DEFAULT SUBPARTITION other_regions
            )
        SUBPARTITION BY RANGE (amount)
            SUBPARTITION TEMPLATE
            (
            START (0)
                END (1000)
                EVERY (100),
            DEFAULT SUBPARTITION out_of_range
            )
        (
        START (DATE '2025-01-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE
            EVERY (INTERVAL '1 month'),
        DEFAULT PARTITION other_dates
        );

Партиционирование существующей таблицы

Партиционирование таблицы можно указать только при ее создании. Чтобы партиционировать существующую таблицу, выполните следующие шаги:

  1. Создайте новую партиционированную таблицу:

    CREATE TABLE sales_partitioned
(
    LIKE sales
)
    WITH (appendoptimized = true)
    PARTITION BY RANGE (date)
        (
        START (DATE '2025-01-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE
            EVERY (INTERVAL '1 month'),
        DEFAULT PARTITION other_dates
        );

  2. Загрузите исходные данные таблицы в новую таблицу:

    INSERT INTO sales_partitioned
SELECT *
FROM sales;

  3. Удалите исходную таблицу:

    DROP TABLE sales;

  4. Переименуйте новую таблицу, присвоив ей имя исходной таблицы:

    ALTER TABLE sales_partitioned
    RENAME TO sales;
ПРИМЕЧАНИЕ

После создания новой таблицы необходимо заново выдать привилегии на таблицу. Узнайте больше в статье Роли и привилегии.

Просмотр информации о партиционировании

Ниже приведен пример партиционированной таблицы, используемой для демонстрации способов просмотра информации о партиционировании.

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    region TEXT,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        SUBPARTITION BY LIST (region)
            SUBPARTITION TEMPLATE
            (
            SUBPARTITION asia VALUES ('Asia'),
            SUBPARTITION europe VALUES ('Europe'),
            DEFAULT SUBPARTITION other_regions
            )
        (
        START (DATE '2025-01-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE
            EVERY (INTERVAL '1 month'),
        DEFAULT PARTITION other_dates
        );

Метакоманды psql

Метакоманда \d+ выводит информацию о таблице sales:

\d+ sales

Раздел Child tables в выводе содержит список дочерних таблиц, связанных с родительской таблицей:

                      Append-Only Table "public.sales"
 Column |     Type      | Modifiers | Storage  | Stats target | Description
--------+---------------+-----------+----------+--------------+-------------
 id     | integer       |           | plain    |              |
 date   | date          |           | plain    |              |
 region | text          |           | extended |              |
 amount | numeric(10,2) |           | main     |              |
Compression Type: None
Compression Level: 0
Block Size: 32768
Checksum: t
Child tables: sales_1_prt_2,
              sales_1_prt_3,
              sales_1_prt_4,
              sales_1_prt_other_dates
Distributed by: (id)
Partition by: (date)
Options: appendonly=true

Вы можете выполнить ту же команду для дочерней таблицы, чтобы увидеть ее дочерние таблицы, используемые для сабпартиционирования:

\d+ sales_1_prt_2

В дополнение к разделу Child tables в вывод также включается раздел Inherits, указывающий, что эта таблица наследует столбцы и ограничения таблицы sales:

                  Append-Only Table "public.sales_1_prt_2"
 Column |     Type      | Modifiers | Storage  | Stats target | Description
--------+---------------+-----------+----------+--------------+-------------
 id     | integer       |           | plain    |              |
 date   | date          |           | plain    |              |
 region | text          |           | extended |              |
 amount | numeric(10,2) |           | main     |              |
Compression Type: None
Compression Level: 0
Block Size: 32768
Checksum: t
Check constraints:
    "sales_1_prt_2_check" CHECK (date >= '2025-01-01'::date AND date < '2025-02-01'::date)
Inherits: sales
Child tables: sales_1_prt_2_2_prt_asia,
              sales_1_prt_2_2_prt_europe,
              sales_1_prt_2_2_prt_other_regions
Distributed by: (id)
Partition by: (region)
Options: appendonly=true

SQL-команды

Чтобы получить информацию о партиционированных таблицах в текущей базе данных, используйте один из описанных ниже способов.

pg_catalog.pg_partitions

Чтобы показать схему партиционирования указанной таблицы, выполните SQL-запрос к системному представлению pg_catalog.pg_partitions:

SELECT partitiontablename,
       partitionname,
       partitiontype,
       partitionlevel,
       partitionrank
FROM pg_catalog.pg_partitions
WHERE schemaname = 'public'
  AND tablename = 'sales';

Результат может выглядеть следующим образом:

             partitiontablename              | partitionname | partitiontype | partitionlevel | partitionrank
---------------------------------------------+---------------+---------------+----------------+---------------
 sales_1_prt_2                               |               | range         |              0 |             1
 sales_1_prt_3                               |               | range         |              0 |             2
 sales_1_prt_4                               |               | range         |              0 |             3
 sales_1_prt_other_dates                     | other_dates   | range         |              0 |
 sales_1_prt_2_2_prt_asia                    | asia          | list          |              1 |
 sales_1_prt_2_2_prt_europe                  | europe        | list          |              1 |
 sales_1_prt_2_2_prt_other_regions           | other_regions | list          |              1 |
 sales_1_prt_3_2_prt_asia                    | asia          | list          |              1 |
 sales_1_prt_3_2_prt_europe                  | europe        | list          |              1 |
 sales_1_prt_3_2_prt_other_regions           | other_regions | list          |              1 |
 sales_1_prt_4_2_prt_asia                    | asia          | list          |              1 |
 sales_1_prt_4_2_prt_europe                  | europe        | list          |              1 |
 sales_1_prt_4_2_prt_other_regions           | other_regions | list          |              1 |
 sales_1_prt_other_dates_2_prt_asia          | asia          | list          |              1 |
 sales_1_prt_other_dates_2_prt_europe        | europe        | list          |              1 |
 sales_1_prt_other_dates_2_prt_other_regions | other_regions | list          |              1 |
(16 rows)

Таблица содержит следующие столбцы:

  • partitiontablename — полное имя таблицы, используемое для обращения к партиции напрямую в DML-командах;

  • partitionname — имя партиции, которое назначается при создании таблицы и используется для обращения к партиции в командах ALTER TABLE;

  • partitiontype — тип партиционирования;

  • partitionlevel — уровень партиции (начиная с 0 для партиций первого уровня);

  • partitionrank — порядковый номер (rank) партиции в общем списке партиций на текущем уровне (начиная с 1). Заполняется только для range-партиций.

Вы также можете использовать столбец partitionboundary для получения полных спецификаций партиций.

pg_catalog.pg_partition_templates

Чтобы показать все сабпартиции, созданные с использованием шаблона сабпартиций, выполните SQL-запрос к системному представлению pg_catalog.pg_partition_templates:

SELECT schemaname,
       tablename,
       partitionname,
       partitiontype,
       partitionlevel,
       partitionrank
FROM pg_catalog.pg_partition_templates;

Результат должен выглядеть следующим образом:

 schemaname | tablename | partitionname | partitiontype | partitionlevel | partitionrank
------------+-----------+---------------+---------------+----------------+---------------
 public     | sales     | asia          | list          |              1 |
 public     | sales     | europe        | list          |              1 |
 public     | sales     | other_regions | list          |              1 |
(3 rows)

pg_catalog.pg_partition_columns

Чтобы вывести все ключи партиционирования, можно обратиться к системному представлению pg_catalog.pg_partition_columns:

SELECT *
FROM pg_catalog.pg_partition_columns;

Результат должен выглядеть следующим образом:

 schemaname | tablename | columnname | partitionlevel | position_in_partition_key
------------+-----------+------------+----------------+---------------------------
 public     | sales     | date       |              0 |                         1
 public     | sales     | region     |              1 |                         1
 public     | sales     | region     |              1 |                         1
(3 rows)

pg_catalog.pg_partition

Чтобы вывести уровни партиционирования с указанием соответствующих таблиц, выполните выборку из таблицы системного каталога pg_catalog.pg_partition:

SELECT parent_table.relname,
       partition_info.parkind,
       partition_info.parlevel,
       partition_info.paristemplate
FROM pg_catalog.pg_partition AS partition_info
         LEFT JOIN pg_class AS parent_table ON parent_table.oid = partition_info.parrelid;

Результат может выглядеть следующим образом:

 relname | parkind | parlevel | paristemplate
---------+---------+----------+---------------
 sales   | l       |        1 | f
 sales   | l       |        1 | t
 sales   | r       |        0 | f
(3 rows)

Обслуживание партиционированных таблиц

Добавление партиции по умолчанию

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    region TEXT,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        SUBPARTITION BY LIST (region)
            SUBPARTITION TEMPLATE
            (
            SUBPARTITION asia VALUES ('Asia'),
            SUBPARTITION europe VALUES ('Europe')
            )
        (
        START (DATE '2025-01-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE
            EVERY (INTERVAL '1 month')
        );

Вы можете добавить партицию по умолчанию в схему партиционирования с помощью команды ALTER TABLE:

ALTER TABLE sales
    ADD DEFAULT PARTITION other_dates;

Если ваша схема партиционирования многоуровневая, партиция по умолчанию должна быть на каждом уровне иерархии:

ALTER TABLE sales
    ALTER PARTITION FOR (RANK (1))
        ADD DEFAULT PARTITION other_regions;

ALTER TABLE sales
    ALTER PARTITION FOR (RANK (2))
        ADD DEFAULT PARTITION other_regions;

ALTER TABLE sales
    ALTER PARTITION FOR (RANK (3))
        ADD DEFAULT PARTITION other_regions;
ПРИМЕЧАНИЕ

Вы можете узнать порядковые номера партиций в системном представлении pg_catalog.pg_partitions.

Чтобы убедиться, что партиции по умолчанию добавлены, выполните следующий SQL-запрос:

SELECT partitiontablename,
       partitionname,
       partitiontype,
       partitionlevel,
       partitionrank
FROM pg_catalog.pg_partitions
WHERE schemaname = 'public'
  AND tablename = 'sales';

Вывод должен включать партиции other_dates и other_regions:

          partitiontablename          | partitionname | partitiontype | partitionlevel | partitionrank
--------------------------------------+---------------+---------------+----------------+---------------
 sales_1_prt_1                        |               | range         |              0 |             1
 sales_1_prt_2                        |               | range         |              0 |             2
 sales_1_prt_3                        |               | range         |              0 |             3
 sales_1_prt_other_dates              | other_dates   | range         |              0 |
 sales_1_prt_1_2_prt_asia             | asia          | list          |              1 |
 sales_1_prt_1_2_prt_europe           | europe        | list          |              1 |
 sales_1_prt_1_2_prt_other_regions    | other_regions | list          |              1 |
 sales_1_prt_2_2_prt_asia             | asia          | list          |              1 |
 sales_1_prt_2_2_prt_europe           | europe        | list          |              1 |
 sales_1_prt_2_2_prt_other_regions    | other_regions | list          |              1 |
 sales_1_prt_3_2_prt_asia             | asia          | list          |              1 |
 sales_1_prt_3_2_prt_europe           | europe        | list          |              1 |
 sales_1_prt_3_2_prt_other_regions    | other_regions | list          |              1 |
 sales_1_prt_other_dates_2_prt_asia   | asia          | list          |              1 |
 sales_1_prt_other_dates_2_prt_europe | europe        | list          |              1 |
(15 rows)

Добавление новой партиции

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    region TEXT,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        SUBPARTITION BY LIST (region)
            SUBPARTITION TEMPLATE
            (
            SUBPARTITION asia VALUES ('Asia'),
            SUBPARTITION europe VALUES ('Europe')
            )
        (
        PARTITION jan_2025 START (DATE '2025-01-01') INCLUSIVE ,
        PARTITION feb_2025 START (DATE '2025-02-01') INCLUSIVE ,
        PARTITION mar_2025 START (DATE '2025-03-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE
        );

Вы можете добавить новую партицию с помощью команды ALTER TABLE. Если исходная схема партиционирования использует шаблон сабпартиционирования, то вновь добавленная партиция будет автоматически партиционирована в соответствии с этим шаблоном.

Следующая команда добавляет новую партицию для апреля 2025 года в таблицу sales:

ALTER TABLE sales
    ADD PARTITION apr_2025 START (DATE '2025-04-01')
        END (DATE '2025-05-01') EXCLUSIVE;

Когда вы добавляете сабпартицию в существующую партицию, вы можете указать партицию для изменения:

ALTER TABLE sales
    ALTER PARTITION FOR (RANK (4))
        ADD PARTITION africa VALUES ('Africa');

Чтобы проверить, что новые партиции добавлены, выполните следующий запрос:

SELECT partitiontablename,
       partitionname,
       partitiontype,
       partitionlevel,
       partitionrank
FROM pg_catalog.pg_partitions
WHERE schemaname = 'public'
  AND tablename = 'sales';

Результат включает партиции sales_1_prt_apr_2025 и sales_1_prt_apr_2025_2_prt_africa:

        partitiontablename         | partitionname | partitiontype | partitionlevel | partitionrank
-----------------------------------+---------------+---------------+----------------+---------------
 sales_1_prt_jan_2025              | jan_2025      | range         |              0 |             1
 sales_1_prt_feb_2025              | feb_2025      | range         |              0 |             2
 sales_1_prt_mar_2025              | mar_2025      | range         |              0 |             3
 sales_1_prt_apr_2025              | apr_2025      | range         |              0 |             4
 sales_1_prt_apr_2025_2_prt_asia   | asia          | list          |              1 |
 sales_1_prt_apr_2025_2_prt_europe | europe        | list          |              1 |
 sales_1_prt_apr_2025_2_prt_africa | africa        | list          |              1 |
 sales_1_prt_feb_2025_2_prt_asia   | asia          | list          |              1 |
 sales_1_prt_feb_2025_2_prt_europe | europe        | list          |              1 |
 sales_1_prt_jan_2025_2_prt_asia   | asia          | list          |              1 |
 sales_1_prt_jan_2025_2_prt_europe | europe        | list          |              1 |
 sales_1_prt_mar_2025_2_prt_asia   | asia          | list          |              1 |
 sales_1_prt_mar_2025_2_prt_europe | europe        | list          |              1 |
(13 rows)
ПРИМЕЧАНИЕ

Вы не можете добавить партицию в схему партиционирования, если в ней есть партиция по умолчанию. Для добавления партиции необходимо разделить партицию по умолчанию. Узнайте подробнее в разделе Разделение партиции по умолчанию.

Разделение партиции

Разделение указанной партиции

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        (
        PARTITION jan_2025 START (DATE '2025-01-01') INCLUSIVE ,
        PARTITION feb_2025 START (DATE '2025-02-01') INCLUSIVE ,
        PARTITION mar_2025 START (DATE '2025-03-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE
        );

Разделение партиции разбивает существующую партицию на две новые. Вы можете разделить партицию с помощью команды ALTER TABLE. Указанное при разделении значение попадает во вторую (новую) партицию.

Обратите внимание, что разделять можно только партиции самого нижнего уровня — те, которые фактически содержат данные. Для одноуровневого партиционирования можно разделять как range-, так и list-партиции, а для многоуровневого — только range-партиции.

Выполните следующую команду, чтобы разделить месячную партицию на две: первую — для дат с 1 по 15 марта, вторую — для дат с 16 по 31 марта:

ALTER TABLE sales
    SPLIT PARTITION FOR ('2025-03-01')
        AT ('2025-03-16')
        INTO (PARTITION mar_1to15_2025, PARTITION mar_16to31_2025);

Чтобы увидеть обновленную схему партиционирования таблицы, выполните следующий SQL-запрос:

SELECT partitionname,
       partitionboundary
FROM pg_catalog.pg_partitions
WHERE schemaname = 'public'
  AND tablename = 'sales';

Результат выглядит следующим образом:

  partitionname  |                                           partitionboundary
-----------------+--------------------------------------------------------------------------------------------------------
 jan_2025        | PARTITION jan_2025 START ('2025-01-01'::date) END ('2025-02-01'::date) WITH (appendonly='true')
 feb_2025        | PARTITION feb_2025 START ('2025-02-01'::date) END ('2025-03-01'::date) WITH (appendonly='true')
 mar_1to15_2025  | PARTITION mar_1to15_2025 START ('2025-03-01'::date) END ('2025-03-16'::date) WITH (appendonly='true')
 mar_16to31_2025 | PARTITION mar_16to31_2025 START ('2025-03-16'::date) END ('2025-04-01'::date) WITH (appendonly='true')
(4 rows)

Разделение партиции по умолчанию

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        (
        PARTITION jan_2025 START (DATE '2025-01-01') INCLUSIVE ,
        PARTITION feb_2025 START (DATE '2025-02-01') INCLUSIVE ,
        PARTITION mar_2025 START (DATE '2025-03-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE,
        DEFAULT PARTITION other_dates
        );

Чтобы разделить партицию по умолчанию, используйте выражение SPLIT DEFAULT PARTITION:

ALTER TABLE sales
    SPLIT DEFAULT PARTITION
        START ('2025-04-01') INCLUSIVE
        END ('2025-05-01') EXCLUSIVE
        INTO (PARTITION apr_2025, DEFAULT PARTITION);

Чтобы увидеть обновленную схему партиционирования, выполните следующий SQL-запрос:

SELECT partitionname,
       partitionboundary
FROM pg_catalog.pg_partitions
WHERE schemaname = 'public'
  AND tablename = 'sales';

Результат должен выглядеть так:

 partitionname |                                        partitionboundary
---------------+-------------------------------------------------------------------------------------------------
 jan_2025      | PARTITION jan_2025 START ('2025-01-01'::date) END ('2025-02-01'::date) WITH (appendonly='true')
 feb_2025      | PARTITION feb_2025 START ('2025-02-01'::date) END ('2025-03-01'::date) WITH (appendonly='true')
 mar_2025      | PARTITION mar_2025 START ('2025-03-01'::date) END ('2025-04-01'::date) WITH (appendonly='true')
 apr_2025      | PARTITION apr_2025 START ('2025-04-01'::date) END ('2025-05-01'::date) WITH (appendonly='true')
 other_dates   | DEFAULT PARTITION other_dates  WITH (appendonly='true')
(5 rows)

Изменение шаблона сабпартиционирования

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    region TEXT,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        SUBPARTITION BY LIST (region)
            SUBPARTITION TEMPLATE
            (
            SUBPARTITION asia VALUES ('Asia'),
            SUBPARTITION europe VALUES ('Europe')
            )
        (
        PARTITION jan_2025 START (DATE '2025-01-01') INCLUSIVE ,
        PARTITION feb_2025 START (DATE '2025-02-01') INCLUSIVE ,
        PARTITION mar_2025 START (DATE '2025-03-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE
        );

Используйте выражение SET SUBPARTITION TEMPLATE, чтобы изменить шаблон сабпартиций для партиционированной таблицы. Партиции, добавленные после указания нового шаблона сабпартиций, будут иметь новую схему партиционирования. Существующие партиции не изменяются.

В следующем примере изменяется шаблон сабпартиции таблицы sales:

ALTER TABLE sales
    SET SUBPARTITION TEMPLATE
        (SUBPARTITION asia VALUES ('Asia'),
         SUBPARTITION europe VALUES ('Europe'),
         SUBPARTITION africa VALUES ('Africa'),
         DEFAULT SUBPARTITION other_regions);

Когда вы добавляете новую партицию диапазона дат, она должна включать новую сабпартицию для значения Africa:

ALTER TABLE sales
    ADD PARTITION apr_2025 START (DATE '2025-04-01')
        END (DATE '2025-05-01') EXCLUSIVE;

Чтобы просмотреть обновленную схему партиционирования, выполните следующий SQL-запрос:

SELECT partitiontablename,
       partitionboundary
FROM pg_catalog.pg_partitions
WHERE schemaname = 'public'
  AND tablename = 'sales';

Результат должен включать сабпартиции asia, europe, africa и партицию по умолчанию с именем other_regions:

            partitiontablename            |                                        partitionboundary
------------------------------------------+-------------------------------------------------------------------------------------------------
 sales_1_prt_jan_2025                     | PARTITION jan_2025 START ('2025-01-01'::date) END ('2025-02-01'::date) WITH (appendonly='true')
 sales_1_prt_feb_2025                     | PARTITION feb_2025 START ('2025-02-01'::date) END ('2025-03-01'::date) WITH (appendonly='true')
 sales_1_prt_mar_2025                     | PARTITION mar_2025 START ('2025-03-01'::date) END ('2025-04-01'::date) WITH (appendonly='true')
 sales_1_prt_apr_2025                     | PARTITION apr_2025 START ('2025-04-01'::date) END ('2025-05-01'::date)
 sales_1_prt_apr_2025_2_prt_asia          | SUBPARTITION asia VALUES('Asia')
 sales_1_prt_apr_2025_2_prt_europe        | SUBPARTITION europe VALUES('Europe')
 sales_1_prt_apr_2025_2_prt_africa        | SUBPARTITION africa VALUES('Africa')
 sales_1_prt_apr_2025_2_prt_other_regions | DEFAULT SUBPARTITION other_regions
 sales_1_prt_feb_2025_2_prt_asia          | SUBPARTITION asia VALUES('Asia') WITH (appendonly='true')
 sales_1_prt_feb_2025_2_prt_europe        | SUBPARTITION europe VALUES('Europe') WITH (appendonly='true')
 sales_1_prt_jan_2025_2_prt_asia          | SUBPARTITION asia VALUES('Asia') WITH (appendonly='true')
 sales_1_prt_jan_2025_2_prt_europe        | SUBPARTITION europe VALUES('Europe') WITH (appendonly='true')
 sales_1_prt_mar_2025_2_prt_asia          | SUBPARTITION asia VALUES('Asia') WITH (appendonly='true')
 sales_1_prt_mar_2025_2_prt_europe        | SUBPARTITION europe VALUES('Europe') WITH (appendonly='true')
(14 rows)

Обмен партиции

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        (
        PARTITION jan_2025 START (DATE '2025-01-01') INCLUSIVE ,
        PARTITION feb_2025 START (DATE '2025-02-01') INCLUSIVE ,
        PARTITION mar_2025 START (DATE '2025-03-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE,
        DEFAULT PARTITION other_dates
        );

Обмен партициями позволяет заменить партицию таблицы на другую таблицу с такой же структурой, которая обычно называется staging-таблицей. После обмена партиция содержит данные из staging-таблицы, а staging-таблица — исходные данные партиции.

Эта возможность полезна для загрузки данных, так как вставка данных напрямую в партиционированные таблицы может быть неэффективной. Кроме того, обмен партициями можно использовать для изменения типа хранения существующих партиций.

Чтобы продемонстрировать обмен партициями, сначала добавьте тестовые данные в таблицу sales:

INSERT INTO sales (id, date, amount)
SELECT gs.id,
       DATE '2025-01-01' + (gs.id % 59),
       round((random() * 1000)::NUMERIC, 2)
FROM generate_series(1, 40000) AS gs(id);

Проверьте, что таблица, соответствующая партиции mar_2025, не содержит данных:

SELECT count(*)
FROM sales_1_prt_mar_2025;

Создайте таблицу с такой же структурой, как у партиционированной таблицы, но с другим типом хранения:

CREATE TABLE stg_mar_2025
(
    LIKE sales
)
    WITH (appendoptimized = false);

Добавьте данные в таблицу:

INSERT INTO stg_mar_2025 (id, date, amount)
SELECT gs.id,
       DATE '2025-03-01' + (gs.id % 31),
       round((random() * 1000)::NUMERIC, 2)
FROM generate_series(1, 20000) AS gs(id);

Для обмена партиции используйте команду ALTER TABLE с выражением EXCHANGE PARTITION:

ALTER TABLE sales
    EXCHANGE PARTITION FOR (DATE '2025-03-01')
        WITH TABLE stg_mar_2025 WITH VALIDATION;

Проверьте, что таблица, соответствующая партиции mar_2025, теперь содержит данные:

SELECT count(*)
FROM sales_1_prt_mar_2025;

Результат должен выглядеть следующим образом:

 count
-------
 20000

Убедитесь, что тип хранения данных в партиции также изменился:

\dt+ sales*

Результат должен показать, что тип хранения для sales_1_prt_mar_2025 — heap:

                                    List of relations
 Schema |          Name           | Type  |  Owner  |   Storage   |  Size   | Description
--------+-------------------------+-------+---------+-------------+---------+-------------
 public | sales                   | table | gpadmin | append only | 160 kB  |
 public | sales_1_prt_feb_2025    | table | gpadmin | append only | 803 kB  |
 public | sales_1_prt_jan_2025    | table | gpadmin | append only | 854 kB  |
 public | sales_1_prt_mar_2025    | table | gpadmin | heap        | 1280 kB |
 public | sales_1_prt_other_dates | table | gpadmin | append only | 160 kB  |
(5 rows)
ВАЖНО

Перед обменом партиции по умолчанию убедитесь, что данные в staging-таблице корректны и не принадлежат каким-либо дочерним партициям. В противном случае запросы, использующие GPORCA, могут возвращать неверные результаты или приводить к повреждению данных при операциях UPDATE и DELETE.

Переименование партиции

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    region TEXT,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        SUBPARTITION BY LIST (region)
            SUBPARTITION TEMPLATE
            (
            SUBPARTITION asia VALUES ('Asia'),
            SUBPARTITION europe VALUES ('Europe')
            )
        (
        START (DATE '2025-01-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE
            EVERY (INTERVAL '1 month')
        );

Данная команда переименовывает верхнеуровневую родительскую таблицу:

ALTER TABLE sales
    RENAME TO globalsales;

Обратите внимание, что это автоматически изменяет префиксы имен всех ее дочерних таблиц.

Чтобы изменить имя партиции, используйте команду ALTER TABLE с выражением RENAME PARTITION:

ALTER TABLE globalsales
    RENAME PARTITION FOR ('2025-01-01') TO jan_2025;

ALTER TABLE globalsales
    RENAME PARTITION FOR ('2025-02-01') TO feb_2025;

ALTER TABLE globalsales
    RENAME PARTITION FOR ('2025-03-01') TO mar_2025;

Для проверки новых имен партиций используйте следующий запрос:

SELECT partitiontablename,
       partitionname,
       partitiontype,
       partitionlevel,
       partitionrank
FROM pg_catalog.pg_partitions
WHERE schemaname = 'public'
  AND tablename = 'globalsales';

Результат должен выглядеть так:

           partitiontablename            | partitionname | partitiontype | partitionlevel | partitionrank
-----------------------------------------+---------------+---------------+----------------+---------------
 globalsales_1_prt_jan_2025              | jan_2025      | range         |              0 |             1
 globalsales_1_prt_feb_2025              | feb_2025      | range         |              0 |             2
 globalsales_1_prt_mar_2025              | mar_2025      | range         |              0 |             3
 globalsales_1_prt_feb_2025_2_prt_asia   | asia          | list          |              1 |
 globalsales_1_prt_feb_2025_2_prt_europe | europe        | list          |              1 |
 globalsales_1_prt_jan_2025_2_prt_asia   | asia          | list          |              1 |
 globalsales_1_prt_jan_2025_2_prt_europe | europe        | list          |              1 |
 globalsales_1_prt_mar_2025_2_prt_asia   | asia          | list          |              1 |
 globalsales_1_prt_mar_2025_2_prt_europe | europe        | list          |              1 |

Удаление данных из партиции

CREATE TABLE sales
(
    id     INT,
    date   DATE,
    region TEXT,
    amount DECIMAL(10, 2)
)
    WITH (appendoptimized = true)
    DISTRIBUTED BY (id)
    PARTITION BY RANGE (date)
        SUBPARTITION BY LIST (region)
            SUBPARTITION TEMPLATE
            (
            SUBPARTITION asia VALUES ('Asia'),
            SUBPARTITION europe VALUES ('Europe')
            )
        (
        PARTITION jan_2025 START (DATE '2025-01-01') INCLUSIVE ,
        PARTITION feb_2025 START (DATE '2025-02-01') INCLUSIVE ,
        PARTITION mar_2025 START (DATE '2025-03-01') INCLUSIVE
            END (DATE '2025-04-01') EXCLUSIVE
        );

Чтобы удалить все данные из указанной партиции без удаления самой партиции, используйте команду ALTER TABLE с выражением TRUNCATE PARTITION.

Вставьте данные в таблицу:

INSERT INTO sales (id, date, region, amount)
SELECT gs.id,
       DATE '2025-01-01' + (gs.id % 90),
       CASE WHEN gs.id % 2 = 0 THEN 'Asia' ELSE 'Europe' END,
       round((random() * 1000)::NUMERIC, 2)
FROM generate_series(1, 40000) AS gs(id);

Просмотрите информацию о доступных партициях:

SELECT partitiontablename,
       partitionname,
       partitionrank
FROM pg_catalog.pg_partitions
WHERE schemaname = 'public'
  AND tablename = 'sales';

Результат должен выглядеть так:

        partitiontablename         | partitionname | partitionrank
-----------------------------------+---------------+---------------
 sales_1_prt_jan_2025              | jan_2025      |             1
 sales_1_prt_feb_2025              | feb_2025      |             2
 sales_1_prt_mar_2025              | mar_2025      |             3
 sales_1_prt_feb_2025_2_prt_asia   | asia          |
 sales_1_prt_feb_2025_2_prt_europe | europe        |
 sales_1_prt_jan_2025_2_prt_asia   | asia          |
 sales_1_prt_jan_2025_2_prt_europe | europe        |
 sales_1_prt_mar_2025_2_prt_asia   | asia          |
 sales_1_prt_mar_2025_2_prt_europe | europe        |
(9 rows)

Проверьте количество строк в таблице sales_1_prt_jan_2025, соответствующей промежуточной партиции:

SELECT count(*)
FROM sales_1_prt_jan_2025;

Результат может выглядеть так:

 count
-------
 13794

Затем проверьте, что таблица sales_1_prt_feb_2025_2_prt_asia, соответствующая дочерней партиции, также содержит данные:

SELECT count(*)
FROM sales_1_prt_feb_2025_2_prt_asia;

Для удаления данных из промежуточной партиции jan_2025 используйте следующую команду:

ALTER TABLE sales
    TRUNCATE PARTITION jan_2025;

Чтобы удалить данные из сабпартиции asia партиции feb_2025, используйте следующий SQL-запрос:

ALTER TABLE sales
    ALTER PARTITION feb_2025
        TRUNCATE PARTITION asia;

Затем снова используйте команду SELECT count(*), чтобы проверить, что количество строк равно 0 для обеих партиций.

Удаление партиции

Чтобы удалить указанную партицию, используйте команду ALTER TABLE с выражением DROP PARTITION. В следующем примере удаляется партиция jan_2025 из таблицы sales, созданной в разделе Удаление данных из партиции:

ALTER TABLE sales
    DROP PARTITION jan_2025;

Убедитесь, что партиция больше не существует, выполнив запрос к pg_partitions:

SELECT partitiontablename,
       partitionname,
       partitionrank
FROM pg_catalog.pg_partitions
WHERE schemaname = 'public'
  AND tablename = 'sales';

Результат должен выглядеть следующим образом:

        partitiontablename         | partitionname | partitionrank
-----------------------------------+---------------+---------------
 sales_1_prt_feb_2025              | feb_2025      |             1
 sales_1_prt_mar_2025              | mar_2025      |             2
 sales_1_prt_feb_2025_2_prt_asia   | asia          |
 sales_1_prt_feb_2025_2_prt_europe | europe        |
 sales_1_prt_mar_2025_2_prt_asia   | asia          |
 sales_1_prt_mar_2025_2_prt_europe | europe        |
(6 rows)
Предыдущая
Распределение данных
Следующая
Последовательности