Перейти к основному содержимому
Перейти к основному содержимому

Движок таблицы Merge

Движок Merge (не путать с MergeTree) не хранит данные сам, но позволяет одновременно читать из любого количества других таблиц.

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

Создание таблицы​

CREATE TABLE ... Engine=Merge(db_name, tables_regexp)

Параметры движка​

db_name​

db_name — Возможные значения:

  • название базы данных,
  • константное выражение, возвращающее строку с названием базы данных, например, currentDatabase(),
  • REGEXP(выражение), где выражение — регулярное выражение для соответствия названиям БД.

tables_regexp​

tables_regexp — Регулярное выражение для соответствия названиям таблиц в указанной БД или БД.

Регулярные выражения — re2 (поддерживает подмножество PCRE), чувствительны к регистру. Смотрите примечания о экранировании символов в регулярных выражениях в разделе "match".

Использование​

При выборе таблиц для чтения сам движок Merge не выбирается, даже если он соответствует регулярному выражению. Это сделано для избежания циклов. Возможно создать две таблицы Merge, которые будут бесконечно пытаться читать данные друг друга, но это не лучшая идея.

Типичный способ использования движка Merge — работа с большим количеством таблиц TinyLog как с одной таблицей.

Примеры​

Пример 1

Рассмотрим две базы данных ABC_corporate_site и ABC_store. Таблица all_visitors будет содержать ID из таблиц visitors в обеих базах данных.

CREATE TABLE all_visitors (id UInt32) ENGINE=Merge(REGEXP('ABC_*'), 'visitors');

Пример 2

Предположим, у вас есть старая таблица WatchLog_old, и вы решили изменить партиционирование, не перемещая данные в новую таблицу WatchLog_new, и вам нужно видеть данные из обеих таблиц.

CREATE TABLE WatchLog_old(date Date, UserId Int64, EventType String, Cnt UInt64)
    ENGINE=MergeTree(date, (UserId, EventType), 8192);
INSERT INTO WatchLog_old VALUES ('2018-01-01', 1, 'hit', 3);

CREATE TABLE WatchLog_new(date Date, UserId Int64, EventType String, Cnt UInt64)
    ENGINE=MergeTree PARTITION BY date ORDER BY (UserId, EventType) SETTINGS index_granularity=8192;
INSERT INTO WatchLog_new VALUES ('2018-01-02', 2, 'hit', 3);

CREATE TABLE WatchLog AS WatchLog_old ENGINE=Merge(currentDatabase(), '^WatchLog');

SELECT * FROM WatchLog;

┌───────date─┬─UserId─┬─EventType─┬─Cnt─┐
│ 2018-01-01 │      1 │ hit       │   3 │
└────────────┴────────┴───────────┴─────┘
┌───────date─┬─UserId─┬─EventType─┬─Cnt─┐
│ 2018-01-02 │      2 │ hit       │   3 │
└────────────┴────────┴───────────┴─────┘

Виртуальные колонки​

  • _table — Содержит название таблицы, из которой были прочитаны данные. Тип: String.

    Вы можете установить константные условия для _table в условии WHERE/PREWHERE (например, WHERE _table='xyz'). В этом случае операция чтения выполняется только для тех таблиц, где выполнено условие по _table, так что колонка _table действует как индекс.

Смотрите также