Tablestore:PrestoDB を使用して Tablestore にアクセスする

手順 1: PrestoDB を Tablestore に接続する

PrestoDB をインストールした後、PrestoDB を Tablestore に接続するために、PrestoDB のカタログとスキーマを設定する必要があります。カタログ設定ファイルは、etc/catalog/tablestore.properties パスに保存されます。

手順 2: Presto の SQL CLI を実行する

Tablestore が PrestoDB に接続されたら、Presto サーバーを起動し、SQL ステートメントを実行できます。

1. PrestoDB クライアントをインストールするために実行できるプログラムを取得します。

   1. PrestoDB クライアントのインストールパッケージをダウンロードします。

      この例では、presto-cli-0.280-executable.jar パッケージがダウンロードされます。

   2. PrestoDB クライアントのインストールパッケージを、PrestoDB がインストールされているディレクトリの下の bin ディレクトリに保存します。

   3. bin ディレクトリで次のコマンドを実行して、PrestoDB クライアントをインストールするために実行できるプログラムを取得します。

      # PrestoDB クライアントのインストールパッケージの名前を presto に変更します。presto-cli-0.280-executable.jar を PrestoDB クライアントの実際のバージョン名に置き換えます。
      mv presto-cli-0.280-executable.jar presto
      # ユーザーに presto ファイルに対する操作を実行するための権限を付与します。
      chmod +x presto

      次の図は、PrestoDB クライアントをインストールするために実行できるプログラムが配置されているディレクトリを示しています。

      

2. bin ディレクトリで次のコマンドを実行して、Presto サーバーを起動します。

   重要

   Presto サーバーを起動する場合は、コーディネーターと少なくとも 1 つのワーカーを個別に起動する必要があります。

   # Presto サーバーはフォアグラウンドまたはバックグラウンドで実行できます。Presto サーバーをフォアグラウンドで実行すると、操作ログをより簡単に表示できます。
   # 方法 1: Presto サーバーをバックグラウンドで実行する
   ./launcher start
   # 方法 2: Presto サーバーをフォアグラウンドで実行する
   ./launcher run

3. bin ディレクトリで次のコマンドを実行して、SQL CLI を起動します。

   説明

   • デフォルトでは、PrestoDB はポート 8080 で実行されます。ポート設定を変更する場合は、etc/config.properties ファイルの http-server.http.port パラメータの値を変更します。

   • 特定の設定を変更した後、新しい設定を有効にするには、Presto サーバーを再起動する必要があります。

   • コマンドの ./presto は、bin ディレクトリにある PrestoDB クライアントをインストールするために実行できるプログラムの相対パスを示しています。

   ./presto --server localhost:8080 --catalog tablestore --schema default

   次の表は、コマンドのパラメータを示しています。

   パラメータ	例	必須	説明
   --server	localhost:8080	はい	Presto サーバーの URI。値を Presto サーバーの実際の URI に置き換えます。パラメータの値は、PrestoDB がインストールされているディレクトリの etc/config.properties ファイルの discovery.uri パラメータの値と同じでなければなりません。
   --catalog	tablestore	はい	カタログ設定ファイルの名前。この例では、パラメータは tablestore に設定されています。
   --schema	default	はい	スキーマ設定。デフォルト設定を保持します。

手順 3: スキーマとマッピングテーブルを作成する

メタデータテーブルに基づく動的設定モードでスキーマを設定する場合は、スキーマを手動で作成および使用して、PrstoDB が接続されている Tablestore インスタンスを設定し、ユーザー権限を認証する必要があります。次に、Tablestore テーブルのマッピングテーブルを作成して、データのクエリと分析を行うことができます。

1. 次のステートメントを実行して、スキーマを作成します。

   次の SQL ステートメントの例は、myinstance という名前の Tablestore インスタンスにアクセスするために使用される testdb という名前のスキーマを作成する方法の例を示しています。

   CREATE SCHEMA tablestore.testdb
   WITH (
     endpoint = 'https://myinstance.cn-hangzhou.ots.aliyuncs.com',
     instance_name = 'myinstance',
     access_id = '************************',
     access_key = '********************************'
   );

   次の表は、パラメータを示しています。

   パラメータ	例	必須	説明
   endpoint	https://myinstance.cn-hangzhou.ots.aliyuncs.com	はい	Tablestore インスタンスのエンドポイント。詳細については、エンドポイント を参照してください。
   instance_name	myinstance	はい	接続されている Tablestore インスタンスの名前。詳細については、インスタンス を参照してください。
   access_id	************************	はい	Alibaba Cloud アカウントまたは RAM ユーザーの AccessKey ID。
   access_key	********************************	はい	Alibaba Cloud アカウントまたは RAM ユーザーの AccessKey シークレット。

2. use <SCHEMA_NAME>; ステートメントを実行して、作成したスキーマを使用します。

   <SCHEMA_NAME> を作成したスキーマの名前に置き換えます。show schemas; ステートメントを実行して、スキーマのリストを表示できます。

3. 次のステートメントを実行して、Tablestore テーブルのマッピングテーブルを作成します。

   重要

   マッピングテーブルを作成する場合は、次の点に注意してください。

   • マッピングテーブルのカラムのデータ型が Tablestore テーブルのデータ型にマッピングされていることを確認してください。詳細については、「PrtestoDB を使用して Tablestore にアクセスする」トピックの データ型のマッピング セクションを参照してください。

   • マッピングテーブルの名前は、Tablestore テーブルの実際の名前と同じでなければなりません。

   • CREATE TABLE ステートメントの table_name パラメータで指定されたテーブルは、Tablestore の実際のテーブルにマッピングされます。同じ Tablestore テーブルに対して複数のマッピングテーブルを作成できます。

   • マッピングテーブルには、Tablestore テーブルのすべてのプライマリキーカラムが含まれている必要がありますが、特定の属性カラムのみが含まれている必要があります。

   • マッピングテーブルのプライマリキーカラムの名前と順序は、Tablestore テーブルの名前と順序と同じでなければなりません。origin_name パラメータを指定することで、マッピングテーブルの各属性カラムを Tablestore テーブルのカラム名にマッピングできます。

   この例では、gid と uid という名前の 2 つのプライマリキーカラムと col1、col2、col3 という名前の 3 つの属性カラムを含む main_table Tablestore テーブルを使用します。

   次の SQL ステートメントの例は、main_table Tablestore テーブルと同じ名前のマッピングテーブルを作成する方法の例を示しています。

   CREATE TABLE if not exists main_table
   (
      gid bigint,
      uid bigint,
      c1 boolean with (origin_name = 'col1'),
      c2 bigint with (origin_name = 'col2'),
      c3 varchar with (origin_name = 'col3')
   ) WITH (
      table_name = 'main_table'
   );

手順 4: SQL ステートメントを実行してデータに対する操作を実行する

SQL ステートメントを実行して、スキーマ設定とマッピングテーブルのメタデータをクエリし、Tablestore テーブルからデータを読み取り、Tablestore テーブルにデータを書き込みます。SQL ステートメントの例については、「Presto サーバーを設定し、サンプル SQL ステートメントを実行する」トピックの「一般的な SQL ステートメントの例」セクションを参照してください Presto サーバーを設定し、サンプル SQL ステートメントを実行する。

1. スキーマ設定をクエリします。

   • スキーマのリストをクエリする

     show schemas;

   • 特定のスキーマのテーブルのリストをクエリする

     show tables;

2. 特定のテーブルのメタデータをクエリする

   <TABLE_NAME> をテーブルの実際の名前に置き換えます。

   describe <TABLE_NAME>;

3. データに対する操作を実行します。

   Tablestore データを読み書きします。

   • データを書き込む

     • データの行を挿入する

       次の SQL ステートメントの例は、main_table テーブルにデータの行を挿入する方法の例を示しています。

       insert into main_table values(10001,10001,true,100,'hangzhou');

     • 複数のデータレコードを同時にインポートする

       重要

       複数のデータレコードを同時にインポートする前に、宛先テーブルが作成され、宛先テーブルのスキーマがソーステーブルのスキーマと同じであることを確認してください。

       次の SQL ステートメントの例は、gid カラムの値が 0 より大きく、uid カラムの値が 10000 未満の行の gid、uid、c1、c2、c3 カラムを main_table テーブルから sampletable テーブルにインポートする方法の例を示しています。

       insert into sampletableselect gid, uid, c1, c2, c3 from main_table where gid > 0 and uid < 100000;

   • データを読み取る

     次の SQL ステートメントの例は、sampletable テーブルで gid カラムの値が 0 より大きく、uid カラムの値が 10 未満で、c1 カラムの値が true である行をクエリする方法の例を示しています。

     select * from sampletable where gid > 0 and uid < 10 and c1 = true;