Apache Presto - MySQL 连接器

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

先决条件

MySQL服务器安装。

配置设置

希望你已经在你的机器上安装了 mysql 服务器。要在 Presto 服务器上启用 mysql 属性，您必须在 etc/catalog 目录中创建一个文件。要创建 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 Server 并使用以下命令创建数据库。

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 Server查询了数据。让我们将 Mysql 存储插件连接到 Presto 服务器。

连接 Presto CLI

键入以下命令将 MySql 插件连接到 Presto CLI

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

您将收到以下回复。

presto:tutorials>

这里"tutorials"指的是mysql服务器中的模式。

列出架构

要列出 Mysql 中的所有架构，请在 Presto Server 中键入以下查询。

查询

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

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

create
insert
update
delete
drop

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

查询

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

结果

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

Apache Presto 教程