前往小程序,Get更优阅读体验!
立即前往
首页
学习
活动
专区
工具
TVP
发布
社区首页 >专栏 >Palo Doris不会用?(基础指南)

Palo Doris不会用?(基础指南)

作者头像
857技术社区
发布2022-05-17 15:50:59
5500
发布2022-05-17 15:50:59
举报
文章被收录于专栏:857-Bigdata

基础使用指南

在快速入门教程中,我们通过 Doris 的 UI 界面完成了 Doris 的一些基本操作。而在实际生产环境中,用户通常需要使用程序连接到 Doris 并进行各种操作。

Doris 采用 MySQL 协议进行通信,因此用户可以标准的 MySQL 客户端,或者使用各种语言的 MySQL 库、JDBC、ODBC 等连接Doris。本文以 MySQL client 为例,通过一个完整的流程向用户展示 Doris 的基本使用方法。

选择 MySQL client 版本时建议采用5.1 之后的版本,因为 5.1 之前不能支持长度超过 16 个字符的用户名。 您可以从这里下载 Linux 版本的 MySQL 客户端:mysql-5.7.22-linux-glibc2.12-x86_64。(解压后,在 bin/ 目录下有 mysql 二进制程序。)

创建用户和数据库

用户在创建 Doris 集群时设置的密码即为 Doris 的 admin 用户的密码。Doris 集群初始默认包含一个 admin 用户,用户可以通过 admin 用户和 Doris 进行初次连接。

代码语言:javascript
复制
mysql -hDORIS_HOST -PDORIS_PORT -uadmin -pyour_password

如果使用的是 8.0 以上版本的 MySQL 客户端,请添加参数:

代码语言:javascript
复制
mysql --default-auth=mysql_native_password -hDORIS_HOST -PDORIS_PORT -uadmin -pyour_password

这里的 host 和 port 为在 Doris 控制台页面给出的MySQL协议连接目标。如果用户绑定了 EIP,则替换为 EIP 即可。

admin 用户拥有集群的全部操作权限。建议仅管理员使用。管理员可以使用 admin 用户创建普通用户并授予相应的权限。

通过下面的命令创建一个普通用户。

代码语言:javascript
复制
CREATE USER 'jack' IDENTIFIED BY 'jack_passwd';

新创建的普通用户默认没有任何权限。我们接下来可以创建一个数据库并授权给用户 jack。

代码语言:javascript
复制
CREATE DATABASE example_db;

GRANT ALL ON example_db to "jack";

之后,我们可以使用 jack 用户进行登录并查看数据库。

代码语言:javascript
复制
mysql -hDORIS_HOST -PDORIS_PORT -ujack -pjack_passwordMySQL>SHOWDATABASES;
代码语言:javascript
复制
+--------------------+
| Database           |
+--------------------+
| example_db         |
| information_schema |
+--------------------+
2 rows in set (0.00 sec)

创建表

首先切换数据库:

代码语言:javascript
复制
USE example_db;

接下来创建一张表:

代码语言:javascript
复制
CREATE TABLE lineorder (

这里我们创建一个 Star Schema Benchmark 中的 lineorder 表。使用 lo_orderkey 作为分桶列,并设置副本数为1。

默认建表的副本数为3,而当集群的 BE 节点数小于3时,副本数不得大于 BE 节点数。

表建完之后,可以查看 example_db 中表的信息:

代码语言:javascript
复制
MySQL> SHOW TABLES;
+----------------------+
| Tables_in_example_db |
+----------------------+
| lineorder            |
+----------------------+
2 rows in set (0.01 sec)

mysql> DESC lineorder;
+------------------+-------------+------+-------+---------+-------+
| Field            | Type        | Null | Key   | Default | Extra |
+------------------+-------------+------+-------+---------+-------+
| lo_orderkey      | BIGINT      | Yes  | true  | NULL    |       |
| lo_linenumber    | BIGINT      | Yes  | true  | NULL    |       |
| lo_custkey       | INT         | Yes  | true  | NULL    |       |
| lo_partkey       | INT         | Yes  | false | NULL    | NONE  |
| lo_suppkey       | INT         | Yes  | false | NULL    | NONE  |
| lo_orderdate     | INT         | Yes  | false | NULL    | NONE  |
| lo_orderpriotity | VARCHAR(16) | Yes  | false | NULL    | NONE  |
| lo_shippriotity  | INT         | Yes  | false | NULL    | NONE  |
| lo_quantity      | BIGINT      | Yes  | false | NULL    | NONE  |
| lo_extendedprice | BIGINT      | Yes  | false | NULL    | NONE  |
| lo_ordtotalprice | BIGINT      | Yes  | false | NULL    | NONE  |
| lo_discount      | BIGINT      | Yes  | false | NULL    | NONE  |
| lo_revenue       | BIGINT      | Yes  | false | NULL    | NONE  |
| lo_supplycost    | BIGINT      | Yes  | false | NULL    | NONE  |
| lo_tax           | BIGINT      | Yes  | false | NULL    | NONE  |
| lo_commitdate    | BIGINT      | Yes  | false | NULL    | NONE  |
| lo_shipmode      | VARCHAR(11) | Yes  | false | NULL    | NONE  |
+------------------+-------------+------+-------+---------+-------+
17 rows in set (0.02 sec)

导入数据

Doris 支持多种数据导入方式。具体可以参阅数据导入文档。这里我们使用 Broker 导入做示例。

Broker 导入通过集群内置的 Broker 进程,读取外部存储上的数据进行导入。更多帮助请参阅操作手册中关于 Broker 的介绍。

使用 Broker 导入需要预先将导入数据文件存放到百度对象存储 BOS 上。我们在这里准备了一份 lineorder 表的数据(约 100MB)。用户可以下载后上传到自己的 BOS 中。并开始导入。

lineorder数据示例

如何上传至 BOS 以及从 BOS 导入数据的详细文档可参阅 导入BOS中的数据。

假设用户存放导入文件的 BOS 路径为:bos://example_bucket/lineorder_1.tbl

则我们可以通过以下命令导入数据:

代码语言:javascript
复制
LOAD LABEL example_db.my_first_load

  1. 公有云 Doris 集群的 Broker 名称为 bos。可以通过 SHOW BROKER; 查看。
  2. 本示例中 bos_endpointhttp://bj.bcebos.com。用户需根据不同的地域指定不同的 endpoint。
  3. accesskey 和 secret_accesskey 可以在公有云安全认证中心查看。

Broker 导入是异步命令。以上命令执行成功只表示提交任务成功。

导入是否成功需要根据导入 label,通过 SHOW LOAD 命令查看。本示例的 label 为 my_first_load

SHOW LOAD WHERE LABLE = "my_first_load";

返回结果中,State 字段为 FINISHED 则表示导入成功。之后我们就可以查询数据了。

数据的查询

Doris 支持绝大部分 SQL 92 和 99 标准中的 SQL 语法,以及部分 SQL 2003 标准中的语法。基本可以涵盖绝大部分 SQL 使用场景。以下通过一些简单的示例进行展示。

简单查询

示例:

代码语言:javascript
复制
MySQL> SELECT * FROM table1 LIMIT 3;
+--------+----------+----------+------+
| siteid | citycode | username | pv   |
+--------+----------+----------+------+
|      2 |        1 | 'grace'  |    2 |
|      5 |        3 | 'helen'  |    3 |
|      3 |        2 | 'tom'    |    2 |
+--------+----------+----------+------+
5 rows in set (0.01 sec)

MySQL> SELECT * FROM table1 ORDER BY citycode;
+--------+----------+----------+------+
| siteid | citycode | username | pv   |
+--------+----------+----------+------+
|      2 |        1 | 'grace'  |    2 |
|      1 |        1 | 'jim'    |    2 |
|      3 |        2 | 'tom'    |    2 |
|      4 |        3 | 'bush'   |    3 |
|      5 |        3 | 'helen'  |    3 |
+--------+----------+----------+------+
5 rows in set (0.01 sec)

Join 查询

示例:

代码语言:javascript
复制
MySQL> SELECT SUM(table1.pv) FROM table1 JOIN table2 WHERE table1.siteid = table2.siteid;
+--------------------+
| sum(`table1`.`pv`) |
+--------------------+
|                 12 |
+--------------------+
1 row in set (0.20 sec)

子查询

示例:

代码语言:javascript
复制
MySQL> SELECT SUM(pv) FROM table2 WHERE siteid IN (SELECT siteid FROM table1 WHERE siteid > 2);
本文参与 腾讯云自媒体同步曝光计划,分享自微信公众号。
原始发表:2021-11-03,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 857Hub 微信公众号,前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
0 条评论
热度
最新
推荐阅读
目录
  • 基础使用指南
    • 创建用户和数据库
      • 创建表
        • 导入数据
          • 数据的查询
            • 简单查询
            • Join 查询
            • 子查询
        相关产品与服务
        云数据库 SQL Server
        腾讯云数据库 SQL Server (TencentDB for SQL Server)是业界最常用的商用数据库之一,对基于 Windows 架构的应用程序具有完美的支持。TencentDB for SQL Server 拥有微软正版授权,可持续为用户提供最新的功能,避免未授权使用软件的风险。具有即开即用、稳定可靠、安全运行、弹性扩缩等特点。
        领券
        问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档