Apache Presto - MySQL 连接器

MySQL 连接器用于查询外部 MySQL 数据库。

先决条件

MySQL 服务器安装。

配置设置

希望你已经在你的机器上安装了 mysql 服务器。要在 Presto 服务器上启用 mysql 属性，您必须在“etc/catalog”目录中创建文件“mysql.properties” 。发出以下命令来创建 mysql.properties 文件。

$ cd etc 
$ cd catalog 
$ vi mysql.properties   

connector.name = mysql 
connection-url = jdbc:mysql://localhost:3306 
connection-user = root 
connection-password = pwd

保存文件并退出终端。在上面的文件中，您必须在连接密码字段中输入 mysql 密码。

在MySQL服务器中创建数据库

打开 MySQL 服务器并使用以下命令创建数据库。

create database tutorials

现在您已经在服务器中创建了“tutorials”数据库。要启用数据库类型，请在查询窗口中使用命令“usetutorials”。

创建表

让我们在“tutorials”数据库上创建一个简单的表。

create table author(auth_id int not null, auth_name varchar(50),topic varchar(100))

插入表

创建表后，使用以下查询插入三条记录。

insert into author values(1,'Doug Cutting','Hadoop') 
insert into author values(2,’James Gosling','java') 
insert into author values(3,'Dennis Ritchie’,'C')

选择记录

要检索所有记录，请键入以下查询。

询问

select * from author

结果

auth_id    auth_name      topic  
1        Doug Cutting     Hadoop 
2        James Gosling    java 
3        Dennis Ritchie     C

至此，您已经使用MySQL服务器查询了数据。让我们将 Mysql 存储插件连接到 Presto 服务器。

连接 Presto CLI

键入以下命令以在 Presto CLI 上连接 MySql 插件。

./presto --server localhost:8080 --catalog mysql --schema tutorials

您将收到以下回复。

presto:tutorials>

这里的“教程”指的是mysql服务器中的模式。

列表模式

要列出 mysql 中的所有模式，请在 Presto 服务器中键入以下查询。

询问

presto:tutorials> show schemas from mysql;

结果

      Schema 
-------------------- 
 information_schema 
 performance_schema 
 sys 
 tutorials

从这个结果中，我们可以得出结论，前三个模式是预定义的，最后一个模式是您自己创建的。

列出架构中的表

以下查询列出了教程架构中的所有表。

询问

presto:tutorials> show tables from mysql.tutorials;

结果

  Table 
-------- 
 author

我们在此模式中仅创建了一张表。如果您创建了多个表，它将列出所有表。

描述表

要描述表字段，请键入以下查询。

询问

presto:tutorials> describe mysql.tutorials.author;

结果

  Column   |     Type     | Comment 
-----------+--------------+--------- 
 auth_id   | integer      | 
 auth_name | varchar(50)  | 
 topic     | varchar(100) |

显示表中的列

询问

presto:tutorials> show columns from mysql.tutorials.author;

结果

 Column    |     Type     | Comment 
-----------+--------------+--------- 
 auth_id   | integer      | 
 auth_name | varchar(50)  | 
 topic     | varchar(100) |

访问表记录

要从 mysql 表中获取所有记录，请发出以下查询。

询问

presto:tutorials> select * from mysql.tutorials.author;

结果

auth_id  |   auth_name    | topic 
---------+----------------+-------- 
       1 | Doug Cutting   | Hadoop 
       2 | James Gosling  | java 
       3 | Dennis Ritchie | C

从这个结果中，您可以检索 Presto 中的 mysql 服务器记录。

使用 as 命令创建表

Mysql连接器不支持创建表查询，但您可以使用as命令创建表。

询问

presto:tutorials> create table mysql.tutorials.sample as 
select * from mysql.tutorials.author;

结果

CREATE TABLE: 3 rows

您无法直接插入行，因为此连接器有一些限制。它不能支持以下查询 -

创造
插入
更新
删除
降低

要查看新创建的表中的记录，请键入以下查询。

询问

presto:tutorials> select * from mysql.tutorials.sample;

结果

auth_id  |   auth_name    | topic 
---------+----------------+-------- 
       1 | Doug Cutting   | Hadoop 
       2 | James Gosling  | java 
       3 | Dennis Ritchie | C