メインコンテンツへスキップ
メインコンテンツへスキップ

Alias テーブルエンジン

Experimental feature. Learn more.

Alias エンジンは、別のテーブルへのプロキシを作成します。すべての読み取りおよび書き込み操作は対象テーブルに転送され、エイリアス自体はデータを保持せず、対象テーブルへの参照のみを保持します。

参考文献

これは実験的な機能であり、将来のリリースで後方互換性を損なう形で変更される可能性があります。 Alias テーブルエンジンを使用するには、 allow_experimental_alias_table_engine 設定を有効にしてください。 次のコマンドを実行します: set allow_experimental_alias_table_engine = 1

テーブルの作成

CREATE TABLE [db_name.]alias_name
ENGINE = Alias(target_table)

または、データベース名を明示的に指定する場合:

CREATE TABLE [db_name.]alias_name
ENGINE = Alias(target_db, target_table)
注記

Alias テーブルでは、明示的な列定義を行うことはできません。列はターゲットテーブルから自動的に継承されます。これにより、エイリアスは常にターゲットテーブルのスキーマと一致します。

エンジンパラメータ

  • target_db (optional) — 対象テーブルを含むデータベースの名前(省略可能)。
  • target_table — 対象テーブルの名前。

サポートされている操作

Alias テーブルエンジンは、主要な操作をすべてサポートします。

ターゲットテーブルに対する操作

これらの操作はターゲットテーブルに対してプロキシ経由で実行されます:

OperationSupportDescription
SELECTターゲットテーブルからデータを読み取る
INSERTターゲットテーブルにデータを書き込む
INSERT SELECTターゲットテーブルへのバッチ挿入を行う
ALTER TABLE ADD COLUMNターゲットテーブルに列を追加する
ALTER TABLE MODIFY SETTINGターゲットテーブルの設定を変更する
ALTER TABLE PARTITIONターゲットに対するパーティション操作 (DETACH/ATTACH/DROP) を行う
ALTER TABLE UPDATEターゲットテーブルの行を更新する (mutation)
ALTER TABLE DELETEターゲットテーブルから行を削除する (mutation)
OPTIMIZE TABLEターゲットテーブルを最適化する (パートをマージ)
TRUNCATE TABLEターゲットテーブルを空にする

エイリアス自体への操作

これらの操作はエイリアスのみに作用し、ターゲットテーブルには影響しません

OperationSupportDescription
DROP TABLEエイリアスのみを削除し、ターゲットテーブルには変更が加わらない
RENAME TABLEエイリアスの名前だけを変更し、ターゲットテーブルには変更が加わらない

使用例

基本的なエイリアスの作成

同一データベース内で簡単なエイリアスを作成します。

-- ソーステーブルを作成
CREATE TABLE source_data (
    id UInt32,
    name String,
    value Float64
) ENGINE = MergeTree
ORDER BY id;

-- データを挿入
INSERT INTO source_data VALUES (1, 'one', 10.1), (2, 'two', 20.2);

-- エイリアスを作成
CREATE TABLE data_alias ENGINE = Alias('source_data');

-- エイリアス経由でクエリ
SELECT * FROM data_alias;
┌─id─┬─name─┬─value─┐
│  1 │ one  │  10.1 │
│  2 │ two  │  20.2 │
└────┴──────┴───────┘

データベース間エイリアス

別のデータベース内のテーブルを参照するエイリアスを作成します。

-- データベースを作成
CREATE DATABASE db1;
CREATE DATABASE db2;

-- db1にソーステーブルを作成
CREATE TABLE db1.events (
    timestamp DateTime,
    event_type String,
    user_id UInt32
) ENGINE = MergeTree
ORDER BY timestamp;

-- db1.eventsを指すエイリアスをdb2に作成
CREATE TABLE db2.events_alias ENGINE = Alias('db1', 'events');

-- またはdatabase.table形式を使用
CREATE TABLE db2.events_alias2 ENGINE = Alias('db1.events');

-- どちらのエイリアスも同じように動作します
INSERT INTO db2.events_alias VALUES (now(), 'click', 100);
SELECT * FROM db2.events_alias2;

エイリアス経由での書き込み操作

すべての書き込みはターゲットテーブルに転送されます。

CREATE TABLE metrics (
    ts DateTime,
    metric_name String,
    value Float64
) ENGINE = MergeTree
ORDER BY ts;

CREATE TABLE metrics_alias ENGINE = Alias('metrics');

-- エイリアス経由で挿入
INSERT INTO metrics_alias VALUES 
    (now(), 'cpu_usage', 45.2),
    (now(), 'memory_usage', 78.5);

-- SELECTで挿入
INSERT INTO metrics_alias 
SELECT now(), 'disk_usage', number * 10 
FROM system.numbers 
LIMIT 5;

-- ターゲットテーブルにデータが格納されていることを確認
SELECT count() FROM metrics;  -- 7を返す
SELECT count() FROM metrics_alias;  -- 7を返す

スキーマの変更

ALTER 操作は対象テーブルのスキーマを変更します。

CREATE TABLE users (
    id UInt32,
    name String
) ENGINE = MergeTree
ORDER BY id;

CREATE TABLE users_alias ENGINE = Alias('users');

-- エイリアス経由でカラムを追加
ALTER TABLE users_alias ADD COLUMN email String DEFAULT '';

-- カラムは対象テーブルに追加される
DESCRIBE users;
┌─name──┬─type───┬─default_type─┬─default_expression─┐
│ id    │ UInt32 │              │                    │
│ name  │ String │              │                    │
│ email │ String │ DEFAULT      │ ''                 │
└───────┴────────┴──────────────┴────────────────────┘

データの変更

UPDATE 文および DELETE 文がサポートされています。

CREATE TABLE products (
    id UInt32,
    name String,
    price Float64,
    status String DEFAULT 'active'
) ENGINE = MergeTree
ORDER BY id;

CREATE TABLE products_alias ENGINE = Alias('products');

INSERT INTO products_alias VALUES 
    (1, 'item_one', 100.0, 'active'),
    (2, 'item_two', 200.0, 'active'),
    (3, 'item_three', 300.0, 'inactive');

-- エイリアス経由で更新
ALTER TABLE products_alias UPDATE price = price * 1.1 WHERE status = 'active';

-- エイリアス経由で削除
ALTER TABLE products_alias DELETE WHERE status = 'inactive';

-- 変更は対象テーブルに適用される
SELECT * FROM products ORDER BY id;
┌─id─┬─name─────┬─price─┬─status─┐
│  1 │ item_one │ 110.0 │ active │
│  2 │ item_two │ 220.0 │ active │
└────┴──────────┴───────┴────────┘

パーティション操作

パーティション化されたテーブルでは、パーティション操作はそのまま伝播されます。

CREATE TABLE logs (
    date Date,
    level String,
    message String
) ENGINE = MergeTree
PARTITION BY toYYYYMM(date)
ORDER BY date;

CREATE TABLE logs_alias ENGINE = Alias('logs');

INSERT INTO logs_alias VALUES 
    ('2024-01-15', 'INFO', 'message1'),
    ('2024-02-15', 'ERROR', 'message2'),
    ('2024-03-15', 'INFO', 'message3');

-- エイリアス経由でパーティションをデタッチ
ALTER TABLE logs_alias DETACH PARTITION '202402';

SELECT count() FROM logs_alias;  -- 2を返す(パーティション202402はデタッチ済み)

-- パーティションを再アタッチ
ALTER TABLE logs_alias ATTACH PARTITION '202402';

SELECT count() FROM logs_alias;  -- 3を返す

テーブル最適化

ターゲットテーブル内のパーツをマージする処理を最適化します。

CREATE TABLE events (
    id UInt32,
    data String
) ENGINE = MergeTree
ORDER BY id;

CREATE TABLE events_alias ENGINE = Alias('events');

-- 複数の INSERT により複数のパートが作成される
INSERT INTO events_alias VALUES (1, 'data1');
INSERT INTO events_alias VALUES (2, 'data2');
INSERT INTO events_alias VALUES (3, 'data3');

-- パート数を確認
SELECT count() FROM system.parts 
WHERE database = currentDatabase() 
  AND table = 'events' 
  AND active;

-- エイリアス経由で最適化
OPTIMIZE TABLE events_alias FINAL;

-- ターゲットテーブルでパートがマージされる
SELECT count() FROM system.parts 
WHERE database = currentDatabase() 
  AND table = 'events' 
  AND active;  -- 1 を返す

エイリアスの管理

エイリアスはそれぞれ独立して名前を変更したり削除したりできます。

CREATE TABLE important_data (
    id UInt32,
    value String
) ENGINE = MergeTree
ORDER BY id;

INSERT INTO important_data VALUES (1, 'critical'), (2, 'important');

CREATE TABLE old_alias ENGINE = Alias('important_data');

-- エイリアスの名前を変更(対象テーブルは変更されません)
RENAME TABLE old_alias TO new_alias;

-- 同じテーブルに別のエイリアスを作成
CREATE TABLE another_alias ENGINE = Alias('important_data');

-- エイリアスを1つ削除(対象テーブルと他のエイリアスは変更されません)
DROP TABLE new_alias;

SELECT * FROM another_alias;  -- 引き続き動作します
SELECT count() FROM important_data;  -- データは保持されており、2を返します