Lindorm:CREATE TABLE

テーブル名

• 使用可能な文字：数字、大文字、小文字、ピリオド (.)、ハイフン (-)、アンダースコア (_)

• ピリオド (.) またはハイフン (-) で開始することはできません。

• 長さ：1～255 文字

カラム定義

TIMESTAMP 型 (LindormTSDB のみ)：

• テーブルごとに TIMESTAMP 型のカラムは 1 つのみ許可されます。

• LindormTSDB はタイムスタンプを UTC + 08:00 に基づいてエンコードおよび解析します。

• レガシーシステムの 32 ビット UNIX タイムスタンプは、LindormTSDB に書き込む前に 1000 倍する必要があります。32 ビット UNIX タイムスタンプをそのまま書き込むと、意味解釈エラーが発生します。たとえば、1641009600 はレガシーシステムでは 2022-01-01 12:00:00 を表しますが、LindormTSDB では 1970-01-20 07:50:09 (UTC + 08:00) と解釈されます。

NULL 制約の動作：

プライマリキー

プライマリキーはテーブル内の行を一意に識別します。1 つ以上のカラムで構成され、テーブル作成時に必ず指定する必要があります。

LindormTable のプライマリキー制限：

LindormTSDB のプライマリキー構造：

時系列テーブルでは、プライマリキー列は次の 2 つの異なるロールを果たします。

• タグ列：VARCHAR 型のプライマリキー列。データソースを識別します。たとえば、IoT シナリオではデバイス ID、IoV シナリオでは車両識別子、モニタリングシナリオではアプリケーション ID または ip:port などです。

• タイムスタンプ列：TIMESTAMP 型のプライマリキー列。テーブルごとに 1 つのみ許可されます。

プライマリキーには 1 つ以上の VARCHAR (タグ) 列を含めることができますが、TIMESTAMP 列は 1 つのみです。すべてのプライマリキー列は VARCHAR または TIMESTAMP 型である必要があります。

時系列テーブルのプライマリキー設計に関するガイダンスについては、「プライマリキー設計のベストプラクティス」をご参照ください。

インデックス式 (KEY|INDEX)

KEY または INDEX キーワードを CREATE TABLE 文内で使用すると、テーブル作成時にインデックスを作成できます。これにより、セカンダリインデックスおよび検索インデックスを作成できます。

インデックス命名： インデックス名を指定しない場合、システムは table_name_idx_${auto_increment_id} の形式で自動生成します。

セカンダリインデックスの冗長性 (INCLUDE を指定しない場合)：

KEY/INDEX 使用時のデフォルトテーブルプロパティ (MUTABILITY および CONSISTENCY を指定しない場合)：

• CONSISTENCY = 'strong'

• MUTABILITY = 'MUTABLE_LATEST'

インデックス作成失敗時の残留状態： インデックス作成中に例外が発生した場合、テーブルおよびインデックスが残留状態のままとなり、自動的にクリアされません。SHOW 文および DESCRIBE 文では引き続き表示されますが、データの書き込みおよびクエリが失敗する可能性があります。手動で残留テーブルおよびインデックスを削除し、再度作成してください。

パーティション

パーティションは LindormTSDB のみでサポートされています。PARTITION BY で使用するカラムは、プライマリキー内の VARCHAR カラムである必要があります。

構文：PARTITION BY HASH(column1, column2, ..., columnN)

テーブルプロパティ

テーブルプロパティは、WITH キーワードを介して LindormTable のみがサポートしています。

LindormTable 2.2.16 より前のバージョンでは、WITH キーワードはサポートされていません。代わりに、プロパティキーワードを一重引用符で囲んでください。文字列値の場合は、値も一重引用符で囲んでください。例：CREATE TABLE IF NOT EXISTS t1(c1 varchar, c2 bigint, c3 int, c4 int, PRIMARY KEY(c1,c2)) 'CONSISTENCY'='strong';

基本テーブルの作成

CREATE TABLE sensor (
    device_id VARCHAR NOT NULL,
    region VARCHAR NOT NULL,
    time TIMESTAMP NOT NULL,
    temperature DOUBLE,
    humidity BIGINT,
    PRIMARY KEY(device_id, region, time)
);

DESCRIBE table sensor; を実行して、テーブルが作成されたことを確認します。

セカンダリインデックス付きテーブルの作成

CREATE TABLE IF NOT EXISTS sensor (
    device_id VARCHAR NOT NULL,
    region VARCHAR NOT NULL,
    time TIMESTAMP NOT NULL,
    temperature DOUBLE,
    humidity BIGINT,
    PRIMARY KEY(device_id, region, time),
    KEY (temperature, time)
);

確認方法：

• DESCRIBE table sensor; を実行してテーブルを確認します。

• SHOW INDEX FROM sensor; を実行してセカンダリインデックスを確認します。

TTL および圧縮アルゴリズムの設定

TTL を 30 日 (2,592,000 秒)、圧縮を ZSTD に設定します。

CREATE TABLE sensor (
    device_id VARCHAR NOT NULL,
    region VARCHAR NOT NULL,
    time TIMESTAMP NOT NULL,
    temperature DOUBLE,
    humidity BIGINT,
    PRIMARY KEY(device_id, region, time)
) WITH (COMPRESSION='ZSTD', TTL='2592000');

確認方法：

• DESCRIBE table sensor; を実行してテーブルを確認します。

• クラスター管理システムで 概要 ページに移動し、テーブル名をクリックして、現在の詳細テーブル エリアの [テーブルプロパティの表示] をクリックし、COMPRESSION および TTL の値を確認します。

メジャーコンパクション期間の設定

メジャーコンパクション期間を 10 日 (864,000,000 ミリ秒) に設定します。

CREATE TABLE sensor (
    device_id VARCHAR NOT NULL,
    region VARCHAR NOT NULL,
    time TIMESTAMP NOT NULL,
    temperature DOUBLE,
    humidity BIGINT,
    PRIMARY KEY(device_id, region, time)
) WITH (COMPACTION_MAJOR_PERIOD='864000000');

確認方法：DESCRIBE table sensor; を実行するか、クラスター管理システムの 現在の詳細テーブル エリアで [テーブルプロパティの表示] をクリックします。

動的カラムの有効化

CREATE TABLE sensor (
    device_id VARCHAR NOT NULL,
    region VARCHAR NOT NULL,
    time TIMESTAMP NOT NULL,
    temperature DOUBLE,
    humidity BIGINT,
    PRIMARY KEY(device_id, region, time)
) WITH (DYNAMIC_COLUMNS='TRUE');

確認方法：DESCRIBE table sensor; を実行するか、クラスター管理システムの 現在の詳細テーブル エリアで [テーブルプロパティの表示] をクリックします。

ホット／コールドデータ境界の設定

86,400 秒 (1 日) より古いデータをコールドストレージにアーカイブします。

CREATE TABLE sensor (
    device_id VARCHAR NOT NULL,
    region VARCHAR NOT NULL,
    time TIMESTAMP NOT NULL,
    temperature DOUBLE,
    humidity BIGINT,
    PRIMARY KEY(device_id, region, time)
) WITH (CHS = '86400', CHS_L2 = 'storagetype=COLD');

CHS はコールドストレージを有効にする必要があり、CHS_L2='storagetype=COLD' と併用する必要があります。

確認方法：DESCRIBE table sensor; を実行するか、クラスター管理システムの 現在の詳細テーブル エリアで [テーブルプロパティの表示] をクリックし、CHS および CHS_L2 の値を確認します。

複数プロパティの組み合わせ

圧縮、TTL、ホット／コールドデータ境界を同時に設定します。

CREATE TABLE sensor (
    device_id VARCHAR NOT NULL,
    region VARCHAR NOT NULL,
    time TIMESTAMP NOT NULL,
    temperature DOUBLE,
    humidity BIGINT,
    PRIMARY KEY(device_id, region, time)
) WITH (
    COMPRESSION='ZSTD',
    CHS = '86400',
    CHS_L2 = 'storagetype=COLD',
    TTL = '2592000');

確認方法：DESCRIBE table sensor; を実行するか、クラスター管理システムの 現在の詳細テーブル エリアで [テーブルプロパティの表示] をクリックし、COMPRESSION、CHS、CHS_L2、および TTL の値を確認します。

開始キーおよび終了キーによるパーティションの事前作成

開始キー 1000、終了キー 9000 で 5 つのパーティションを事前作成します。STARTKEY および ENDKEY には NUMREGIONS が必要です。

CREATE TABLE sensor (
  p1 INTEGER NOT NULL,
  c1 INTEGER,
  c2 VARCHAR,
  c3 VARCHAR,
  PRIMARY KEY(p1)
) WITH (NUMREGIONS='5', STARTKEY='1000', ENDKEY='9000');

確認方法：DESCRIBE table sensor; を実行するか、クラスター管理システムの シャード詳細 エリアに移動して、各シャードの startKey および endKey の値を確認します。

明示的な分割キーによるパーティションの事前作成

5 つの分割キーを指定して 6 つのパーティションを事前作成します。SPLITKEYS は NUMREGIONS、STARTKEY、または ENDKEY と併用できません。

CREATE TABLE sensor (
  p1 INT NOT NULL,
  p2 INT NOT NULL,
  c1 VARCHAR,
  c2 BIGINT,
  PRIMARY KEY(p1, p2)
) WITH (SPLITKEYS = '100000,300000,500000,700000,900000');

確認方法：DESCRIBE table sensor; を実行するか、クラスター管理システムの シャード詳細 エリアで startKey および endKey の値を確認します。

パーティションキー列の指定

単一デバイスの瞬間データを対象とするクエリの場合、device_id をパーティションキー列として指定してデータ分散を制御します。

CREATE TABLE sensor (
    device_id VARCHAR NOT NULL,
    region VARCHAR NOT NULL,
    time TIMESTAMP NOT NULL,
    temperature DOUBLE,
    humidity BIGINT,
    PRIMARY KEY(device_id, region, time)
) PARTITION BY HASH(device_id);

DESCRIBE TABLE sensor; を実行してテーブル作成結果を確認します。

時空間データテーブルの作成

任意の空間型 (GEOMETRY) — 任意の空間データ型を受け入れます：

CREATE TABLE geoms(gid INT, g GEOMETRY, PRIMARY KEY(gid));

任意の空間型のデータを書き込みます：

UPSERT INTO geoms(gid, g) VALUES
  (0, ST_GeomFromText('POINT(-10.1 3.3)')),
  (1, ST_GeomFromText('LINESTRING(-12.2 4.3, -10.2 4.3)')),
  (2, ST_GeomFromText('POLYGON((2 2, 2 8, 8 8, 8 2, 2 2))'));

ポイント型のみ：

CREATE TABLE pts(gid INT, g GEOMETRY(POINT), PRIMARY KEY(gid));

UPSERT INTO pts(gid, g) VALUES(0, ST_MakePoint(0,0)),(1, ST_MakePoint(1,1));

ポリゴン型のみ：

CREATE TABLE polys(gid INT, g GEOMETRY(POLYGON), PRIMARY KEY(gid));

UPSERT INTO polys(gid,g) VALUES(0, ST_GeomFromText('POLYGON((2 2, 2 8, 8 8, 8 2, 2 2))'));

ラインストリング型のみ：

CREATE TABLE lines(gid INT, g GEOMETRY(LINESTRING), PRIMARY KEY(gid));

UPSERT INTO lines(gid,g) VALUES(0, ST_GeomFromText('LINESTRING(-12.2 4.3, -10.2 4.3)'));

MULTIPOINT 型のみ：

CREATE TABLE multipoints(gid INT, g GEOMETRY(MULTIPOINT), PRIMARY KEY(gid));

UPSERT INTO multipoints(gid,g) VALUES(0, ST_GeomFromText('MULTIPOINT (10 40, 40 30, 20 20, 30 10)'));

MULTILINESTRING 型のみ：

CREATE TABLE multilines(gid INT, g GEOMETRY(MULTILINESTRING), PRIMARY KEY(gid));

UPSERT INTO multilines(gid,g) VALUES(0, ST_GeomFromText('MULTILINESTRING ((10 10, 20 20, 10 40),(40 40, 30 30, 40 20, 30 10))'));

MULTIPOLYGON 型のみ：

CREATE TABLE multipolys(gid INT, g GEOMETRY(MULTIPOLYGON), PRIMARY KEY(gid));

UPSERT INTO multipolys(gid,g) VALUES(0, ST_GeomFromText('MULTIPOLYGON (((30 20, 45 40, 10 40, 30 20)),((15 5, 40 10, 10 20, 5 10, 15 5)))'));

GEOMETRYCOLLECTION 型のみ：

CREATE TABLE collections(gid INT, g GEOMETRY(GEOMETRYCOLLECTION), PRIMARY KEY(gid));

UPSERT INTO collections(gid,g) VALUES(0, ST_GeomFromText('GEOMETRYCOLLECTION (POINT (40 10), LINESTRING (10 10, 20 20, 10 40), POLYGON ((40 40, 20 45, 45 30, 40 40)))'));

複数の空間カラム：

CREATE TABLE mix(gid INT, pt GEOMETRY(POINT), ply GEOMETRY(POLYGON), PRIMARY KEY(gid));