メインコンテンツまでスキップ
バージョン: 3.2

INSERT

説明​

特定のテーブルにデータを挿入するか、特定のテーブルをデータで上書きします。v3.2.0以降、INSERTはリモートストレージ内のファイルにデータを書き込むことをサポートしています。INSERT INTO FILES() を使用して、StarRocksからリモートストレージにデータをアンロードできます。

非同期のINSERTタスクを SUBMIT TASK を使用して送信できます。

構文​

  • データロード:

    INSERT { INTO | OVERWRITE } [db_name.]<table_name>
    [ PARTITION (<partition_name> [, ...] ) ]
    [ TEMPORARY PARTITION (<temporary_partition_name> [, ...] ) ]
    [ WITH LABEL <label>]
    [ (<column_name>[, ...]) ]
    { VALUES ( { <expression> | DEFAULT } [, ...] ) | <query> }

  • データアンロード:

    INSERT INTO FILES()
    [ WITH LABEL <label> ]
    { VALUES ( { <expression> | DEFAULT } [, ...] ) | <query> }

パラメータ​

パラメータ説明
INTOテーブルにデータを追加します。
OVERWRITEテーブルをデータで上書きします。
table_nameデータをロードしたいテーブルの名前です。テーブルが存在するデータベースと一緒に db_name.table_name として指定できます。
PARTITIONデータをロードしたいパーティションです。複数のパーティションを指定でき、カンマ (,) で区切る必要があります。指定した場合、データは指定されたパーティションにのみ挿入されます。指定しない場合、データはすべてのパーティションに挿入されます。
TEMPORARY PARTITIONデータをロードしたい temporary partition の名前です。複数の一時パーティションを指定でき、カンマ (,) で区切る必要があります。
labelデータロードトランザクションごとに一意の識別ラベルです。指定しない場合、システムが自動的に生成します。トランザクションのラベルを指定することをお勧めします。そうしないと、接続エラーが発生して結果が返されない場合にトランザクションの状態を確認できません。SHOW LOAD WHERE label="label" ステートメントを使用してトランザクションの状態を確認できます。ラベルの命名規則については、System Limits を参照してください。
column_nameデータをロードする宛先の列名です。宛先テーブルに存在する列として設定する必要があります。指定した宛先列は、宛先列名に関係なく、ソーステーブルの列と順番に一対一でマッピングされます。宛先列が指定されていない場合、デフォルト値は宛先テーブルのすべての列です。ソーステーブルで指定された列が宛先列に存在しない場合、デフォルト値がこの列に書き込まれ、指定された列にデフォルト値がない場合、トランザクションは失敗します。ソーステーブルの列タイプが宛先テーブルのものと一致しない場合、システムは不一致の列に対して暗黙の変換を行います。変換が失敗した場合、構文解析エラーが返されます。
expression列に値を割り当てる式です。
DEFAULT列にデフォルト値を割り当てます。
query結果が宛先テーブルにロードされるクエリステートメントです。StarRocksがサポートする任意のSQLステートメントを使用できます。
FILES()テーブル関数 FILES()。この関数を使用して、リモートストレージにデータをアンロードできます。

戻り値​

Query OK, 5 rows affected, 2 warnings (0.05 sec)
{'label':'insert_load_test', 'status':'VISIBLE', 'txnId':'1008'}
戻り値説明
rows affectedロードされた行数を示します。warnings はフィルタリングされた行を示します。
labelデータロードトランザクションごとに一意の識別ラベルです。ユーザーが割り当てることも、システムが自動的に割り当てることもできます。
statusロードされたデータが可視かどうかを示します。VISIBLE: データが正常にロードされ、可視です。COMMITTED: データが正常にロードされましたが、現在は不可視です。
txnId各INSERTトランザクションに対応するID番号です。

使用上の注意​

  • 現在のバージョンでは、StarRocksがINSERT INTOステートメントを実行する際、データのいずれかの行が宛先テーブルの形式と一致しない場合（例えば、文字列が長すぎる場合）、デフォルトでINSERTトランザクションは失敗します。セッション変数 enable_insert_strict を false に設定すると、システムは宛先テーブルの形式と一致しないデータをフィルタリングし、トランザクションの実行を続行します。

  • INSERT OVERWRITEステートメントが実行されると、StarRocksは元のデータを格納するパーティションの一時パーティションを作成し、一時パーティションにデータを挿入し、元のパーティションと一時パーティションを入れ替えます。これらの操作はすべてLeader FEノードで実行されます。したがって、Leader FEノードがINSERT OVERWRITEステートメントを実行中にクラッシュした場合、ロードトランザクション全体が失敗し、一時パーティションは削除されます。

例​

以下の例は、test テーブルを基にしており、c1 と c2 の2つの列を含んでいます。c2 列にはデフォルト値が設定されています。

  • test テーブルに1行のデータをインポートします。
INSERT INTO test VALUES (1, 2);
INSERT INTO test (c1, c2) VALUES (1, 2);
INSERT INTO test (c1, c2) VALUES (1, DEFAULT);
INSERT INTO test (c1) VALUES (1);

宛先列が指定されていない場合、列はデフォルトで順番に宛先テーブルにロードされます。したがって、上記の例では、最初と2番目のSQLステートメントの結果は同じです。

宛先列（データが挿入されるかどうかに関係なく）がDEFAULTを値として使用する場合、その列はデフォルト値をロードされたデータとして使用します。したがって、上記の例では、3番目と4番目のステートメントの出力は同じです。

  • test テーブルに一度に複数の行のデータをロードします。
INSERT INTO test VALUES (1, 2), (3, 2 + 2);
INSERT INTO test (c1, c2) VALUES (1, 2), (3, 2 * 2);
INSERT INTO test (c1, c2) VALUES (1, DEFAULT), (3, DEFAULT);
INSERT INTO test (c1) VALUES (1), (3);

式の結果が等しいため、最初と2番目のステートメントの結果は同じです。3番目と4番目のステートメントの結果も同じです。なぜなら、どちらもデフォルト値を使用しているからです。

  • クエリステートメントの結果を test テーブルにインポートします。
INSERT INTO test SELECT * FROM test2;
INSERT INTO test (c1, c2) SELECT * from test2;
  • クエリ結果を test テーブルにインポートし、パーティションとラベルを指定します。
INSERT INTO test PARTITION(p1, p2) WITH LABEL `label1` SELECT * FROM test2;
INSERT INTO test WITH LABEL `label1` (c1, c2) SELECT * from test2;
  • クエリ結果で test テーブルを上書きし、パーティションとラベルを指定します。
INSERT OVERWRITE test PARTITION(p1, p2) WITH LABEL `label1` SELECT * FROM test3;
INSERT OVERWRITE test WITH LABEL `label1` (c1, c2) SELECT * from test3;

以下の例では、AWS S3バケット inserttest 内のParquetファイル parquet/insert_wiki_edit_append.parquet から insert_wiki_edit テーブルにデータ行を挿入します:

INSERT INTO insert_wiki_edit
    SELECT * FROM FILES(
        "path" = "s3://inserttest/parquet/insert_wiki_edit_append.parquet",
        "format" = "parquet",
        "aws.s3.access_key" = "XXXXXXXXXX",
        "aws.s3.secret_key" = "YYYYYYYYYY",
        "aws.s3.region" = "ap-southeast-1"
);