使用SQL Editor串連StarRocks執行個體 - E-MapReduce

EMR StarRocks Manager是阿里雲EMR團隊為Serverless StarRocks執行個體提供的資料管理控制台。它為您提供了對執行個體內資料的全面管理，診斷與分析，以及安全許可權配置等能力。本文為您介紹如何使用SQL Editor串連StarRocks執行個體。

前提條件

已建立StarRocks執行個體，詳情請參見建立執行個體。

操作步驟

進入執行個體列表頁面。
1. 登入E-MapReduce控制台。
2. 在左側導覽列，選擇EMR Serverless > StarRocks。
3. 在頂部功能表列處，根據實際情況選擇地區。
在執行個體列表頁面，單擊已建立執行個體操作列的串連執行個體。

串連StarRocks執行個體。

建立串連

在建立串連頁簽，配置以下資訊。

參數	樣本	描述
地區	華東1（杭州）	選擇已建立的StarRocks執行個體所在的物理位置。
執行個體	StarRocks_Serverlesss	選擇已建立的StarRocks執行個體的名稱。
串連名稱	Connection_Serverlesss	執行個體名稱，自訂輸入。長度限制為1~64字元，僅可使用中文、字母、數字、短劃線（-）和底線（_）。
使用者名稱	根據實際情況輸入	預設初始使用者名稱為admin，您可以選擇使用該使用者名稱進行串連，或者根據需要建立其他使用者。
密碼	根據實際情況輸入	StarRocks執行個體中已建立的使用者名稱對應的密碼。

單擊測試連通性。
驗證通過後，單擊確定。

使用已有串連

重要

使用該方式時，需確保串連的執行個體存在。如果執行個體已被刪除，請使用建立串連的方式。

單擊已有串連頁簽。
單擊已有串連操作列的串連。

（可選）操作StarRocks執行個體。

在左側導覽列，單擊SQL Editor。

在查詢列表頁面，單擊表徵圖，輸入以下SQL語句，單擊運行。

/* 建立資料庫。*/
create database test_sql_editor_db;
/* 使用資料庫。*/
use test_sql_editor_db;
/* 建立表。*/
CREATE TABLE
    `emr_query_logs` (
        `conn_id` varchar(10) NULL COMMENT "",
        `database` varchar(100) NULL COMMENT "",
        `start_time` bigint (20) NULL COMMENT "",
        `end_time` bigint (20) NULL COMMENT "",
        `event_time` bigint (20) NULL COMMENT "",
        `is_query` boolean NULL COMMENT "",
        `latency` int (11) NULL COMMENT "",
        `query_id` varchar(40) NULL COMMENT "",
        `remote_ip` varchar(15) NULL COMMENT "",
        `state` varchar(20) NULL COMMENT "",
        `user` varchar(20) NULL COMMENT ""
    ) ENGINE = OLAP DUPLICATE KEY (`conn_id`) COMMENT "OLAP" DISTRIBUTED BY HASH (`user`) BUCKETS 10 PROPERTIES (
        "replication_num" = "2",
        "in_memory" = "false",
        "storage_format" = "DEFAULT",
        "enable_persistent_index" = "false",
        "compression" = "LZ4"
    );
/* 插入資料。*/
insert into
    test_sql_editor_db.emr_query_logs (
        `conn_id`,
        `database`,
        `start_time`,
        `end_time`,
        `event_time`,
        `is_query`,
        `latency`,
        `query_id`,
        `remote_ip`,
        `state`,
        `user`
    )
values
    (
        '54656',
        'tpc_h_sf1',
        1691635106990,
        1691635107405,
        1691635107405000000,
        1,
        415,
        'fbec0dd7-3726-11ee-a3ef-720338511ec3',
        '10.0.**.**',
        'FINISHED',
        'admin'
    ),
    (
        '54658',
        'tpc_h_sf1',
        1691635107632,
        1691635107860,
        1691635107860000000,
        1,
        228,
        'fc4e0301-3726-11ee-a3ef-720338511ec3',
        '10.0.**.**',
        'FINISHED',
        'admin'
    ),
    (
        '54659',
        'tpc_h_sf1',
        1691635108757,
        1691635108930,
        1691635108930000000,
        1,
        173,
        'fcf9ac5s8-3726-11ee-a3ef-720338511ec3',
        '10.0.**.**',
        'FINISHED',
        'admin'
    ),
    (
        '54661',
        'tpc_h_sf1',
        1691635108994,
        1691635109137,
        1691635109137000000,
        1,
        143,
        'fd1dd62e-3726-11ee-a3ef-720338511ec3',
        '10.0.**.**',
        'FINISHED',
        'admin'
    ),
    (
        '54663',
        'tpc_h_sf1',
        1691635109445,
        1691635109533,
        1691635109533000000,
        1,
        88,
        'fd62a765-3726-11ee-a3ef-720338511ec3',
        '10.0.**.**',
        'FINISHED',
        'admin'
    ),
    (
        '54664',
        'tpc_h_sf1',
        1691635109724,
        1691635109907,
        1691635109907000000,
        1,
        183,
        'fd8d39d9-3726-11ee-a3ef-720338511ec3',
        '10.0.**.**',
        'FINISHED',
        'admin'
    );
/* 查看錶資訊。*/
select * from test_sql_editor_db.emr_query_logs;

查詢結果會展示在下方。