Lindorm:CREATE TABLE

テーブル名 (table_identifier)

テーブル名は、次の要件を満たす必要があります：

• 名前に使用できる文字は、数字、大文字、小文字、ピリオド (.)、ハイフン (-)、アンダースコア (_) です。

• 名前の先頭にピリオド (.) やハイフン (-) を使用することはできません。

• 名前の長さは 1～255 文字である必要があります。

列定義 (column_definition)

プライマリキー (primary_key)

プライマリキーは、テーブル内のデータを一意に識別するもので、1 つ以上の列で構成されます。テーブルを作成する際には、プライマリキー (PRIMARY KEY) を指定する必要があります。

CREATE TABLE ステートメントを使用してテーブルを作成する際には、次の点にご注意ください：

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

CREATE TABLE ステートメントを使用してインデックスを作成する場合、KEY または INDEX キーワードを使用してインデックスを指定します。

パーティション (partition_definition)

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

テーブルを作成する際、PARTITION BY HASH(column1, column2, ..., columnN) ステートメントを使用して、ハッシュパーティショニングのために 1 つ以上の列を明示的に指定できます。例：PARTITION BY HASH(c1, p1)。

テーブル属性 (table_options)

LindormTable のみがテーブル属性をサポートしています。WITH キーワードを使用して、次のテーブル属性を追加できます：

テーブルの作成

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; ステートメントを実行して、テーブルが作成されたことを検証します。

• クラスター管理システムの Overview ページに移動し、目的のテーブルの名前をクリックします。[現在のテーブル詳細] エリアで、[テーブルプロパティの表示] をクリックして、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; ステートメントを実行して、テーブルが作成されたことを検証します。

• クラスター管理システムの Overview ページに移動し、対象テーブルの名前をクリックします。[現在のテーブル詳細] エリアで、[テーブルプロパティの表示] をクリックして、COMPACTION_MAJOR_PERIOD パラメーターの値を確認します。

動的カラムの有効化

ワイドテーブルの作成時に動的カラムへのデータ書き込みを有効にするには、DYNAMIC_COLUMNS を TRUE に設定します。

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; ステートメントを実行して、テーブルが作成されたことを検証します。

• クラスター管理システムの Overview ページに移動して対象のテーブル名をクリックします。[現在のテーブル詳細] エリアで [テーブルプロパティの表示] をクリックし、DYNAMIC_COLUMNS パラメーターの値を確認します。

ホット/コールドデータ境界の指定

この例では、ワイドテーブルを作成し、データアーカイブ用にホット/コールドデータ境界を設定します。

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');

検証

• DESCRIBE table sensor; ステートメントを実行して、テーブルが作成されたことを検証します。

• クラスター管理システムのOverview ページに移動して対象テーブルの名前をクリックし、[現在のテーブル詳細] エリアで[テーブルプロパティを表示] をクリックして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; ステートメントを実行して、テーブルが作成されたことを検証します。

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

パーティションの構成

この例では、開始キーを 1000、終了キーを 9000 として、5 つのパーティションに事前分割したワイドテーブルを作成します。

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; ステートメントを実行して、テーブルが作成されたことを検証します。

• クラスター管理システムの Overview ページに移動し、対象のテーブル名をクリックします。 [シャード情報] エリアで、各パーティションの startKey と endKey パラメーターを確認します。

複数パーティションの開始キーの設定

コード例

• 数値キーによるパーティションの指定 (データ分散に基づく)

  この例では、5 つのパーティションの開始キーを事前定義したワイドテーブルを作成することで、合計 6 つのパーティションが事前分割されます。

  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');

• 文字列キーによるパーティションの指定 (データ分散に基づく)

  CREATE TABLE your_table (
      address VARCHAR NOT NULL,
      col1 VARCHAR,
      PRIMARY KEY (address)
  ) WITH (
      SPLITKEYS = '0x01,0x02,0x03,0x04,0x05,0x06,0x07,0x08,0x09,0x0a,0x0b,0x0c,0x0d,0x0e,0x0f,0x10,0x11,0x12,0x13,0x14,0x15,0x16,0x17,0x18,0x19,0x1a,0x1b,0x1c,0x1d,0x1e,0x1f,0x20,0x21,0x22,0x23,0x24,0x25,0x26,0x27,0x28,0x29,0x2a,0x2b,0x2c,0x2d,0x2e,0x2f,0x30,0x31,0x32,0x33,0x34,0x35,0x36,0x37,0x38,0x39,0x3a,0x3b,0x3c,0x3d,0x3e,0x3f,0x40,0x41,0x42,0x43,0x44,0x45,0x46,0x47,0x48,0x49,0x4a,0x4b,0x4c,0x4d,0x4e,0x4f,0x50,0x51,0x52,0x53,0x54,0x55,0x56,0x57,0x58,0x59,0x5a,0x5b,0x5c,0x5d,0x5e,0x5f,0x60,0x61,0x62,0x63,0x64,0x65,0x66,0x67,0x68,0x69,0x6a,0x6b,0x6c,0x6d,0x6e,0x6f,0x70,0x71,0x72,0x73,0x74,0x75,0x76,0x77,0x78,0x79,0x7a,0x7b,0x7c,0x7d,0x7e,0x7f,0x80,0x81,0x82,0x83,0x84,0x85,0x86,0x87,0x88,0x89,0x8a,0x8b,0x8c,0x8d,0x8e,0x8f,0x90,0x91,0x92,0x93,0x94,0x95,0x96,0x97,0x98,0x99,0x9a,0x9b,0x9c,0x9d,0x9e,0x9f,0xa0,0xa1,0xa2,0xa3,0xa4,0xa5,0xa6,0xa7,0xa8,0xa9,0xaa,0xab,0xac,0xad,0xae,0xaf,0xb0,0xb1,0xb2,0xb3,0xb4,0xb5,0xb6,0xb7,0xb8,0xb9,0xba,0xbb,0xbc,0xbd,0xbe,0xbf,0xc0,0xc1,0xc2,0xc3,0xc4,0xc5,0xc6,0xc7,0xc8,0xc9,0xca,0xcb,0xcc,0xcd,0xce,0xcf,0xd0,0xd1,0xd2,0xd3,0xd4,0xd5,0xd6,0xd7,0xd8,0xd9,0xda,0xdb,0xdc,0xdd,0xde,0xdf,0xe0,0xe1,0xe2,0xe3,0xe4,0xe5,0xe6,0xe7,0xe8,0xe9,0xea,0xeb,0xec,0xed,0xee,0xef,0xf0,0xf1,0xf2,0xf3,0xf4,0xf5,0xf6,0xf7,0xf8,0xf9,0xfa,0xfb,0xfc,0xfd,0xfe,0xff'
  );

• 分割アルゴリズムの指定

  CREATE TABLE your_table2 (
      address VARCHAR NOT NULL,
      col1 VARCHAR,
      PRIMARY KEY (address)
  ) WITH (
      NUMREGIONS = 256,
      SPLITALGO = 'HexStringSplit'
  );

検証

• DESCRIBE table sensor;、DESCRIBE table your_table;、または DESCRIBE table your_table2; などのステートメントを実行して、テーブルが作成されたことを検証します。

• クラスター管理システムの Overview ページに移動し、対象テーブルの名前をクリックします。 [シャード情報] 領域で、各パーティションの 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))'));

• Point データ型用のテーブルを作成します。このテーブルにはポイントデータのみを書き込めます。

  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));

• Polygon データ型用のテーブルを作成します。このテーブルにはポリゴンデータのみを書き込めます。

  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)))'));

• Geometry 型の列を複数持つテーブルを作成します。

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