通过PrestoDB使用Tablestore

步骤一：使用PrestoDB对接Tablestore

安装PrestoDB后，您需要进行PrestoDB的Catalog配置和Schema配置来完成PrestoDB和Tablestore的对接，其中Catalog配置文件的存放路径为etc/catalog/tablestore.properties。

步骤二：运行Presto的SQL CLI

对接完成后，您可以启动Presto Server并运行SQL。

1. 获取client可执行程序。

   1. 下载PrestoDB客户端。

      此处以presto-cli-0.280-executable.jar为例介绍。

   2. 将PrestoDB客户端保存到PrestoDB安装目录下的bin目录中。

   3. 在PrestoDB安装目录下的bin目录中执行如下命令获取client可执行程序。

      # 将PrestoDB客户端文件重命名为presto。其中presto-cli-0.280-executable.jar请替换为实际所用的客户端版本名称。
      mv presto-cli-0.280-executable.jar presto
      # 为用户授予操作presto文件的权限。
      chmod +x presto

      client可执行程序的所处目录如下图所示。

      

2. 在PrestoDB安装目录下的bin目录中执行命令启动Presto Server。

   重要

   启动Presto Server时，您必须分别启动Coordinator和至少一个Worker。

   # 支持前台运行和后台运行两种启动方式，其中前台运行方式更方便查看运行日志。
   # 方式一：后台运行
   ./launcher start
   # 方式二：前台运行
   ./launcher run

3. 在PrestoDB安装目录下的bin目录中执行如下命令启动SQL CLI。

   说明

   • PrestoDB默认运行在8080端口。如果要修改端口配置，请修改etc/config.properties中的http-server.http.port配置。

   • 修改部分config配置后需要重启服务器使配置生效。

   • 命令中的./presto为client可执行程序在PrestoDB安装目录下的bin目录中的相对路径。

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

   配置项说明请参见下表。

   配置项	示例	是否必选	说明
   --server	localhost:8080	是	Presto Server的URI，请根据实际替换。此项的配置必须与PrestoDB安装目录下etc/config.properties文件中的discovery.uri参数的配置相同。
   --catalog	tablestore	是	Catalog配置文件的名称，此处配置为tablestore，与创建的Catalog配置文件名称相同。
   --schema	default	是	Schema配置，保持default配置即可。

步骤三：创建Schema和映射表

使用Meta表动态配置的Schema配置模式时，您需要手动创建并使用Schema用于配置对接的Tablestore实例和进行用户鉴权，然后再创建Tablestore表的映射表用于数据查询和分析。

1. 执行如下命令创建Schema。

   创建一个访问Tablestore myinstance实例的Schema，Schema名称为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	************************	是	阿里云账号或者RAM用户的AccessKey ID。
   access_key	********************************	是	阿里云账号或者RAM用户的AccessKey Secret。

2. 执行use <SCHEMA_NAME>;命令使用创建的Schema。

   其中<SCHEMA_NAME>请替换为实际创建的Schema名称。您可以执行show schemas;命令获取Schema列表。

3. 执行如下命令Tablestore数据表的映射表。

   重要

   创建映射表时，请注意如下事项：

   • 请确保映射表中的字段类型和表格Tablestore数据表中的字段类型相匹配更多信息，请参见字段类型映射。

   • 映射表名称必须与Tablestore中实际的表名称相同。

   • SQL语句CREATE TABLE中的table_name用于映射到Tablestore中实际的表。您可以为Tablestore中的同一个数据表创建多个不同的映射表。

   • 映射表中必须包括数据表的所有主键列，但是支持只包括部分属性列。

   • 映射表中主键列的名称和顺序必须与Tablestore数据表中主键列的名称和顺序保持一致。映射表中每一个属性列可通过指定 origin_name参数来映射到Tablestore中实际表内的列名。

   假设数据表名为main_table，包括gid和uid两个主键列以及col1、col2和col3三个属性列。

   以下SQL示例用于为Tablestore数据表main_table创建一个同名映射表。

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

步骤四：使用SQL操作数据

使用SQL语句查询Schema配置、表的元数据以及读写Tablestore表中数据。更多SQL示例，请参见常用SQL示例。

1. 查询Schema配置。

   • 获取Schema列表

     show schemas;

   • 获取指定Schema中表列表

     show tables;

2. 查看指定表的元数据

   其中<TABLE_NAME>请替换为实际的表名称。

   describe <TABLE_NAME>;

3. 数据操作。

   读写Tablestore数据。

   • 写入数据

     • 插入一行数据

       以下示例用于在main_table中插入一行数据。

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

     • 批量导入数据

       重要

       批量导入数据前，请确保已创建目标表，且目标表的表结构与源数据表的表结构保持一致。

       以下示例用于将main_table表中gid大于0且uid小于10000的gid、uid、c1、c2和c3列数据批量导入到sampletable表中。

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

   • 读取数据

     以下示例用于查询sampletable表中gid列值大于0，uid列值小于10且c1等于true的行数据。

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