本文主要通過示例為您介紹,如何快速使用E-MapReduce上的StarRocks集群進行基本的建表和查詢操作。
前提條件
已創建StarRocks集群,詳情請參見創建StarRocks集群。
使用示例
使用SSH方式登錄StarRocks集群,詳情請參見登錄集群。
執行以下命令,連接StarRocks集群。
mysql -h127.0.0.1 -P 9030 -uroot
執行以下命令,創建數據庫并選擇數據庫。
CREATE DATABASE IF NOT EXISTS load_test; USE load_test;
執行以下命令,創建表。
CREATE TABLE insert_wiki_edit ( event_time DATETIME, channel VARCHAR(32) DEFAULT '', user VARCHAR(128) DEFAULT '', is_anonymous TINYINT DEFAULT '0', is_minor TINYINT DEFAULT '0', is_new TINYINT DEFAULT '0', is_robot TINYINT DEFAULT '0', is_unpatrolled TINYINT DEFAULT '0', delta INT SUM DEFAULT '0', added INT SUM DEFAULT '0', deleted INT SUM DEFAULT '0' ) AGGREGATE KEY(event_time, channel, user, is_anonymous, is_minor, is_new, is_robot, is_unpatrolled) PARTITION BY RANGE(event_time) ( PARTITION p06 VALUES LESS THAN ('2015-09-12 06:00:00'), PARTITION p12 VALUES LESS THAN ('2015-09-12 12:00:00'), PARTITION p18 VALUES LESS THAN ('2015-09-12 18:00:00'), PARTITION p24 VALUES LESS THAN ('2015-09-13 00:00:00') ) DISTRIBUTED BY HASH(user) BUCKETS 10 PROPERTIES("replication_num" = "1");
執行以下命令,導入測試數據。
INSERT INTO insert_wiki_edit VALUES("2015-09-12 00:00:00","#en.wikipedia","GELongstreet",0,0,0,0,0,36,36,0),("2015-09-12 00:00:00","#ca.wikipedia","PereBot",0,1,0,1,0,17,17,0);
執行以下命令,查詢數據。
select * from insert_wiki_edit;
返回信息如下所示。
+---------------------+---------------+--------------+--------------+----------+--------+----------+----------------+-------+-------+---------+ | event_time | channel | user | is_anonymous | is_minor | is_new | is_robot | is_unpatrolled | delta | added | deleted | +---------------------+---------------+--------------+--------------+----------+--------+----------+----------------+-------+-------+---------+ | 2015-09-12 00:00:00 | #en.wikipedia | GELongstreet | 0 | 0 | 0 | 0 | 0 | 36 | 36 | 0 | | 2015-09-12 00:00:00 | #ca.wikipedia | PereBot | 0 | 1 | 0 | 1 | 0 | 17 | 17 | 0 | +---------------------+---------------+--------------+--------------+----------+--------+----------+----------------+-------+-------+---------+ 2 rows in set (0.16 sec)
使用Catalog管理內部和外部數據
EMR-5.8.0及后續版本的StarRocks集群支持使用Catalog(數據目錄)管理內部和外部數據。StarRocks 2.3及以上版本提供以下兩種數據目錄:
Internal Catalog:內部數據目錄,用于存儲StarRocks內部所有的數據庫和數據表。您可以使用內部數據目錄管理內部數據。例如,執行
CREATE DATABASE
和CREATE TABLE
語句創建的數據庫和數據表都會存儲在內部數據目錄中。 每個StarRocks集群都有一個默認的內部數據目錄default_catalog。StarRocks暫不支持修改默認的內部數據目錄的名稱,也不支持創建新的內部數據目錄。External Catalog:外部數據目錄,用于管理外部數據源中的數據。創建外部數據目錄時需指定外部數據源訪問信息。創建后,無需創建外部表即可查詢外部數據。
Catalog更多信息,請參見Catalog概述。
文檔內容是否對您有幫助?