メインコンテンツまでスキップ

Load and query data

データのロードとクエリ

このクイックスタートチュートリアルでは、作成したテーブル(詳細はテーブルの作成を参照)にデータをロードし、そのデータにクエリを実行する手順をステップバイステップで説明します。

StarRocksは、主要なクラウドサービス、ローカルファイル、またはストリーミングデータシステムを含む多様なデータソースからデータのロードをサポートしています。詳細については、データの読み込み概要を参照してください。以下の手順では、INSERT INTOステートメントを使用してStarRocksにデータを挿入し、データ上でクエリを実行する方法を示します。

注意

既存のStarRocksインスタンス、データベース、テーブル、ユーザー、および独自のデータを使用して、このチュートリアルを完了することができます。しかし、単純化のために、チュートリアルで提供されるスキーマとデータを使用することを推奨します。

ステップ1:INSERTを使用してデータをロードする

INSERTを使用して追加のデータ行を挿入できます。詳しい手順については、INSERTを参照してください。

MySQLクライアントを使用してStarRocksにログインし、以下のステートメントを実行して作成したsr_memberテーブルに次のデータ行を挿入します。

use sr_hub
INSERT INTO sr_member
WITH LABEL insertDemo
VALUES
(001,"tom",100000,"2022-03-13",true),
(002,"johndoe",210000,"2022-03-14",false),
(003,"maruko",200000,"2022-03-14",true),
(004,"ronaldo",100000,"2022-03-15",false),
(005,"pavlov",210000,"2022-03-16",false),
(006,"mohammed",300000,"2022-03-17",true);

ロードトランザクションが成功した場合、以下のメッセージが返されます。

クエリ OK、6行が変更されました (0.07 sec)
{'label':'insertDemo', 'status':'VISIBLE', 'txnId':'5'}

注意

INSERT INTO VALUESを使用してデータをロードすることは、小規模なデータセットでDEMOを検証する場合にのみ適用されます。大量のテストや本番環境では推奨されません。StarRocksに大量のデータをロードするには、シナリオに合った他のオプションについては、データの読み込み概要を参照してください。

ステップ2:データのクエリ

StarRocksはSQL-92に準拠しています。

  • テーブル内のすべてのデータ行をリストする単純なクエリを実行します。

    SELECT * FROM sr_member;

    返される結果は以下のようになります。

    +-------+----------+-----------+------------+----------+
    | sr_id | name | city_code | reg_date | verified |
    +-------+----------+-----------+------------+----------+
    | 3 | maruko | 200000 | 2022-03-14 | 1 |
    | 1 | tom | 100000 | 2022-03-13 | 1 |
    | 4 | ronaldo | 100000 | 2022-03-15 | 0 |
    | 6 | mohammed | 300000 | 2022-03-17 | 1 |
    | 5 | pavlov | 210000 | 2022-03-16 | 0 |
    | 2 | johndoe | 210000 | 2022-03-14 | 0 |
    +-------+----------+-----------+------------+----------+
    6 行が選択されました (0.05 sec)
  • 指定した条件で標準的なクエリを実行します。

    SELECT sr_id, name 
    FROM sr_member
    WHERE reg_date <= "2022-03-14";

    返される結果は以下のようになります。

    +-------+----------+
    | sr_id | name |
    +-------+----------+
    | 1 | tom |
    | 3 | maruko |
    | 2 | johndoe |
    +-------+----------+
    3 行が選択されました (0.01 sec)
  • 指定したパーティション上でクエリを実行します。

    SELECT sr_id, name 
    FROM sr_member
    PARTITION (p2);

    返される結果は以下のようになります。

    +-------+---------+
    | sr_id | name |
    +-------+---------+
    | 3 | maruko |
    | 2 | johndoe |
    +-------+---------+
    2 行が選択されました (0.01 sec)

次になにをするか

StarRocksのデータ読み込み方法の詳細については、データの読み込み概要を参照してください。ビルトイン関数の豊富な数に加えて、StarRocksはJava UDFもサポートしています。これにより、ビジネスシナリオに合わせた独自のデータ処理関数を作成することができます。

また、次の方法についても学ぶことができます: