通过Presto查询RDS MySQL数据库 -

本文介绍在同一VPC下创建的E-MapReduce集群和RDS MySQL实例，如何通过E-MapReduce集群的Presto查询RDS MySQL数据库信息。

前提条件

已创建集群，并且选择了Presto服务。详情请参见创建集群。
已购买RDS，详情请参见创建RDS MySQL实例。
说明本文以RDS为例介绍。建议类型选择MySQL的5.7；系列选择高可用版。

背景信息

Presto的相关概念，请参见概述。

步骤一：配置Connector

进入Presto服务。
1. 登录阿里云E-MapReduce控制台。
2. 在顶部菜单栏处，根据实际情况选择地域和资源组。
3. 单击上方的集群管理页签。
4. 在集群管理页面，单击相应集群所在行的详情。
5. 在左侧导航栏，选择集群服务 > Presto。

添加Connector信息。

在Presto页面，单击配置。
在服务配置区域，单击connector1.properties页签。
如果您需要连接多个RDS MySQL数据库时，可以配置多个connector.properties。
修改connector.name为mysql。
单击右上角的自定义配置。

在新增配置项对话框中，配置如下参数。

配置项	描述
connection-user	数据库的用户名。本文示例是hiveuser。
connection-password	数据库的密码。
connection-url	数据连接字符串，详情请参见查看和管理实例连接地址和端口。例如jdbc:mysql://rm-2ze5ipacsu8265qxxxxxxxx.mysql.rds.aliyuncs.com:3306。

保存配置。
1. 单击右上角的保存。
2. 在确认修改对话框中，输入执行原因，开启自动更新配置。
3. 单击确定。
重启服务使配置生效。
1. 选择右上角的操作 > 重启All Components。
2. 在执行集群操作对话框中，输入执行原因。
3. 单击确定。
4. 在确认对话框中，单击确定。

步骤二：查看RDS的数据库

通过SSH方式连接集群。
详情请参见登录集群。

执行如下命令，连接Presto客户端。

presto --server emr-header-1:9090 --catalog hive --schema default --user hadoop

返回如下信息，表示Presto连接成功。

presto:default>

执行如下命令，查看connector1.properties下的Schema。
```
show schemas from connector1;
```
说明 connector1是您在步骤一：配置Connector中配置的properties的名称。
返回如下类似信息。
```
      Schema
--------------------
 emruser
 information_schema
 performance_schema
 sys
(4 rows)
```

步骤三：查询表数据

说明本文示例中的hive.default.tbl_department是您在Hive上创建的表，connector1.emruser.tbl_employee是您在MySQL上创建的表。

查询emruser.tbl_employee表的数据。

select * from connector1.emruser.tbl_employee;

返回类似如下表数据。

 id |    name    | dept_id | salary
----+------------+---------+---------
  1 | Ming Li    |       1 | 10000.0
  2 | Eric Cai   |       1 | 11000.0
  3 | Bonnie Liu |       2 | 11000.0
(3 rows)

查询tbl_department表的数据。

select * from hive.default.tbl_department;

返回类似如下表数据。

dept_id | dept_name
--------+----------
      1 | IT
      2 | Finance
(2 rows)

交叉查询表数据。

执行如下命令，交叉查询表default.tbl_department和emruser.tbl_employee的数据。

select * from hive.default.tbl_department a, connector1.emruser.tbl_employee b where a.dept_id = b.dept_id;

返回结果信息如下表所示。

dept_id |dept_name | id |    name    | dept_id | salary
--------+----------+----+------------+---------+---------
      2 | Finance  |  3 | Bonnie Liu |       2 | 11000.0
      1 | IT       |  2 | Eric Cai   |       1 | 11000.0
      1 | IT       |  1 | Ming Li    |       1 | 10000.0
(3 rows)