2. 程式人生 > >hbase入門 一些簡單的查詢語句

hbase入門 一些簡單的查詢語句

阿新 • • 發佈：2019-02-14
這裡我們用一個學生成績表作為例子,對HBase的基本操作和基本概念進行講解:

下面是學生的成績表:
name     grade      course:math   course:art
Tom        1                87                    97

Jerry       2               100                   80

        這裡grad對於表來說是一個列,course對於表來說是一個列族,這個列族由兩個列組成:math和art,當然我們可以根據我們的需要在course中建立更多的列族,如computer,physics等相應的列新增入course列族.


        有了上面的想法和需求,我們就可以在HBase中建立相應的資料表啦!

1, 建立一個表格 scores 具有兩個列族grad 和courese

hbase(main):002:0> create 'scores', 'grade', 'course'

0 row(s) in 4.1610 seconds

2,檢視當先HBase中具有哪些表

hbase(main):003:0> list

scores

1 row(s) in 0.0210 seconds

3,查看錶的構造

hbase(main):004:0> describe 'scores'

{NAME => 'scores', IS_ROOT => 'false', IS_META => 'false', FAMILIES => [{NAME => 'course', BLOOMFILTER => 'false', IN_MEMORY => 'false', LENGTH => '2147483647', BLOCKCACHE => 'false', VERSIONS => '3', TTL => '-1', COMPRESSION => 'NONE'}, {NAME => 'grade', BLOOMFILTER => 'false', IN_MEMORY => 'false', LENGTH => '2147483647', BLOCKCACHE => 'false', VERSIONS => '3', TTL => '-1', COMPRESSION => 'NONE'}]}


1 row(s) in 0.0130 seconds

4, 加入一行資料,行名稱為 Tom 列族grad的列名為”” 值位1

hbase(main):005:0> put 'scores', 'Tom', 'grade:', '1'

0 row(s) in 0.0070 seconds

5,給Tom這一行的資料的列族新增一列 <math,87>

hbase(main):006:0> put 'scores', 'Tom', 'course:math', '87'

0 row(s) in 0.0040 seconds

6,給Tom這一行的資料的列族新增一列 <art,97>

hbase(main):007:0> put 'scores', 'Tom', 'course:art', '97'


0 row(s) in 0.0030 seconds

7, 加入一行資料,行名稱為 Jerry 列族grad的列名為”” 值位2

hbase(main):008:0> put 'scores', 'Jerry', 'grade:', '2'

0 row(s) in 0.0040 seconds

8,給Jerry這一行的資料的列族新增一列 <math,100>

hbase(main):009:0> put 'scores', 'Jerry', 'course:math', '100'

0 row(s) in 0.0030 seconds

9,給Jerry這一行的資料的列族新增一列 <art,80>

hbase(main):010:0> put 'scores', 'Jerry', 'course:art', '80'

0 row(s) in 0.0050 seconds

10,檢視scores表中Tom的相關資料

hbase(main):011:0> get 'scores', 'Tom'

COLUMN                       CELL

course:art                  timestamp=1224726394286, value=97

course:math                 timestamp=1224726377027, value=87

grade:                      timestamp=1224726360727, value=1

3 row(s) in 0.0070 seconds

11,檢視scores表中所有資料

hbase(main):012:0> scan 'scores'

ROW                          COLUMN+CELL

Tom                         column=course:art, timestamp=1224726394286, value=97

Tom                         column=course:math, timestamp=1224726377027, value=87

Tom                         column=grade:, timestamp=1224726360727, value=1

Jerry                        column=course:art, timestamp=1224726424967, value=80

Jerry                        column=course:math, timestamp=1224726416145, value=100

Jerry                        column=grade:, timestamp=1224726404965, value=2

6 row(s) in 0.0410 seconds

12,檢視scores表中所有資料courses列族的所有資料

hbase(main):013:0> scan 'scores', ['course:']

ROW                          COLUMN+CELL

Tom                         column=course:art, timestamp=1224726394286, value=97

Tom                         column=course:math, timestamp=1224726377027, value=87

Jerry                        column=course:art, timestamp=1224726424967, value=80

Jerry                        column=course:math, timestamp=1224726416145, value=100

4 row(s) in 0.0200 seconds

        上面就是HBase的基本shell操作的一個例子,可以看出,hbase的shell還是比較簡單易用的,從中也可以看出HBase shell缺少很多傳統sql中的一些類似於like等相關操作,當然,HBase作為BigTable的一個開源實現,而BigTable是作為 google業務的支援模型,很多sql語句中的一些東西可能還真的不需要.

        當然,通過程式我們也可以對HBase進行相關的操作.下面的程式就完成了上面shell操作的內容:

import java.io.IOException;

import java.io.ByteArrayOutputStream;

import java.io.DataOutputStream;

import java.io.ByteArrayInputStream;

import java.io.DataInputStream;

import java.util.Map;

import org.apache.hadoop.io.Writable;

import org.apache.hadoop.io.IntWritable;

import org.apache.hadoop.hbase.HBaseConfiguration;

import org.apache.hadoop.hbase.HTableDescriptor;

import org.apache.hadoop.hbase.HColumnDescriptor;

import org.apache.hadoop.hbase.client.HBaseAdmin;

import org.apache.hadoop.hbase.client.HTable;

import org.apache.hadoop.hbase.io.BatchUpdate;

import org.apache.hadoop.hbase.io.RowResult;

import org.apache.hadoop.hbase.io.Cell;

import org.apache.hadoop.hbase.util.Writables;



public class HBaseBasic {



    public static void main(String[] args) throws Exception {

        HBaseConfiguration config = new HBaseConfiguration();

        HBaseAdmin admin = new HBaseAdmin(config);



        if (admin.tableExists("scores")) {

            System.out.println("drop table");

            admin.disable Table("scores");

            admin.deleteTable("scores");

        }



        System.out.println("create table");

        HTableDescriptor tableDescripter = new HTableDescriptor("scores".getBytes());

        tableDescripter.addFamily(new HColumnDescriptor("grade:"));

        tableDescripter.addFamily(new HColumnDescriptor("course:"));

        admin.createTable(tableDescripter);



        HTable table = new HTable(config, "scores");



        System.out.println("add Tom's data ");

        BatchUpdate tomUpdate = new BatchUpdate("Tom");

        tomUpdate.put("grade:", Writables.getBytes(new IntWritable(1)));

        tomUpdate.put("course:math", Writables.getBytes(new IntWritable(87)));

        tomUpdate.put("course:art", Writables.getBytes(new IntWritable(97)));

        table.commit(tomUpdate);



        System.out.println("add Jerry's data");

        BatchUpdate jerryUpdate = new BatchUpdate("Jerry");

        jerryUpdate.put("grade:", Writables.getBytes(new IntWritable(2)));

        jerryUpdate.put("course:math", Writables.getBytes(new IntWritable(100)));

        jerryUpdate.put("course:art", Writables.getBytes(new IntWritable(80)));

        table.commit(jerryUpdate);



        for (RowResult row : table.getScanner(new String[] { "course:" })) {

            System.out.format("ROW\t%s\n", new String(row.getRow()));

            for (Map.Entry<byte[], Cell> entry : row.entrySet()) {

                String column = new String(entry.getKey());

                Cell cell = entry.getValue();

                IntWritable value = new IntWritable();

                Writables.copyWritable(cell.getValue(), value);

                System.out.format("  COLUMN\t%s\t%d\n", column, value.get());

            }

        }

    }

}

        輸出如下:

drop table

09/07/11 08:51:59 INFO client.HBaseAdmin: Disabled scores

09/07/11 08:51:59 INFO client.HBaseAdmin: Deleted scores

create table

add Tom's data

add Jerry's data

ROW     Tom

  COLUMN        course:art      97

  COLUMN        course:math     87

ROW     Jerry

  COLUMN        course:art      80

  COLUMN        course:math     100

相關推薦

hbase入門 一些簡單的查詢語句

這裡我們用一個學生成績表作為例子,對HBase的基本操作和基本概念進行講解:下面是學生的成績表:name     grade      course:math   course:artTom        1                87               

SQL中的SELECT 簡單查詢語句總結

clas 識別 結果集 -i ear get int 一個 lec --scott用戶不能使用，使用system登錄--修改用戶scott賬戶解鎖ALTER USER SCOTT ACCOUNT UNLOCK;--重新設置密碼identified被識別的alter user

MongoDB簡單查詢語句

lte sts key str asc == 無法 簡單 mongodb查詢 左邊是mongodb查詢語句，右邊是sql語句。對照著用，挺方便。 db.users.find() select * from users db.users.find({"age" :

mongodb和MySql的一些等價查詢語句，方便大家映照學習

文章目錄 查詢 find方法: 查詢所有的結果： 指定返回那些列（鍵）： where條件： 1.簡單的等於: 2.使用and 3.使用

ORACLE中關於表的一些特殊查詢語句

2018-11-22 10:57 by 瀟湘隱者, ... 閱讀, ... 評論, 收藏, 編輯 1： 如何判斷欄位的值裡面:那些資料包含小寫字母或大小字母 判斷欄位NAME的值裡面有小寫字母的記錄 方式1： SELECT NAME

SPLUNK 簡單查詢語句| lookup使用

Here is offical document: http://docs.splunk.com/Documentation/SplunkCloud/7.0.2/Search/GetstartedwithSearch | inputlookup all_w  | search

MySQL的簡單查詢語句

排列 ike 查詢 having 模糊 價格 系列 語句 and 查詢：一：查詢所有數據select * from Info 查所有數據select Code,Name from Info 查特定列二：根據條件查select * from Info where Code=‘

oracle資料庫的簡單查詢語句

1、簡單的查詢語法 select [distinct] *| [as] [列別名],列名稱 [as] [列別名] from 表名稱 [表別名] [where 條件（s）] [order by 排序的欄位 | 列索引號 asc|desc,排序的欄位2 asc

常用的一些HQL查詢語句詳解(1)

最近學了HQL查詢語句，發現查詢內容比較瑣碎，現在整理一些比較常用的HQL語句分享給大家，查詢的表有一下三種：Category、Topic、Msg；其中 Category與Topic是一對多的關係，Topic與Msg是一對多的關係。解釋完畢，現在開始介紹常用的HQL語句：

一些hbase的shell查詢語句

探索 華為 lte efi name filter rac single ont 華為bids（不想吐槽）種種原因只能用hbase shell查詢，在此記錄下自己探索的hbase shell 免得下次要用還得去找 scan ‘ogg_sel_ioc_sv_product_n

Dapper入門教程（二）——執行非查詢語句

文本 resp -exec factor -h spa onf fec table 描述 你可以從任意實現IDbConnection的類對象中調用Dapper的擴展方法“Execute”。它能夠執行一條命令（Command）一次或者多次，並返回受影響的行數。這個方法通常用來

spring-data-jpa快速入門（二）——簡單查詢

ref spa data mail domain event cif open 寫實 一、方法名解析 　　1.引言 　　　　回顧HelloWorld項目中的dao接口 public interface GirlRepository extends JpaRepos

Oracle從入門到精通 關於簡單查詢的問題

oracle http 同時 操作 png mark sql rom mage 視頻課程：李興華 Oracle從入門到精通視頻課程 學習者：陽光羅諾 視頻來源：51CTO學院 如果要進行查詢，肯定使用的時DML中的查詢部分支持，相對於簡單查詢而言，通俗的理解，就是全部

SQL一些常用的查詢語句

--欄位查詢表 select a.name, b.name from syscolumns a, sysobjects b where lower(a.name) = '欄位名' and a.id = b.id and b.xtype = 'u' --知道表查儲存過程

JPQL一些簡單的查詢語法

JPQL --> JPA Query Language --> JPA的查詢語句    (另外HQL:Hibernate的查詢語句) JPQL本質：JPA通過antlr-2.7.7.jar將JPQL編譯成sql並且封裝執行的。   JPQL和S

ORACLE中查詢語句的執行順及where部分條件執行順序測試 Oracle中的一些查詢語句及其執行順序 Select 語句執行順序以及如何提高Oracle 基本查詢效率

Oracle中的一些查詢語句及其執行順序 原文地址：https://www.cnblogs.com/likeju/p/5039115.html 查詢條件：1)LIKE：模糊查詢，需要藉助兩個萬用字元，%：表示0到多個字元；_：標識單個字元。2)IN(list)：用來取出符合列表範圍中的資料。3)NOT I

Hive 不支援 where 子句中的子查詢， SQL 常用的 exist in 子句需要改寫。這一改寫相對簡單。考慮以下 SQL 查詢語句：

歡迎使用Markdown編輯器 你好！ 這是你第一次使用 Markdown編輯器 所展示的歡迎頁。如果你想學習如何使用Markdown編輯器, 可以仔細閱讀這篇文章，瞭解一下Markdown的基本語法知識。 新的改變 我們對Markdown編輯器進行了一些功能

mysql簡單的查詢語句（一)

1、 查詢資料庫的版本 : mysql –-version 或者為 –V 2、 啟動服務： net start mysql 3、 關閉服務： net stop mysql 4、 連線資料庫：mysql –h(localhost或ip) –P(埠預設為3306) –uroot –p(密碼) 可

mysql常用的一些查詢語句

一、  Like欄位模糊搜尋：   SELECT * FROM fs_performance_details WHERE dimension_name LIKE 'UI%’;          (或者%UI%，%UI來表示前後，前，有引數內容) 二、  order

Mysql命令使用大全（簡單、方便、好上手） ----查詢語句

select [all|distinct] select_expr from -> where -> group by [合計函式] -> having -> order by -> limit (1)、select_expr 1)計算公式、函式呼叫、欄位也是表示式