HBase基本数据操作详解

水深无声 2022-08-08 03:24 381阅读 0赞

# HBase基本数据操作详解【完整版，绝对精品】 #

存储，学习，共享

引言

之前详细写了一篇HBase过滤器的文章，今天把基础的表和数据相关操作补上。

本文档 参考最新 （截止2014年7月16日）的 官方 Ref Guide、 Developer API编写。

所有代码均基于“hbase  0.96.2-hadoop2 ”版本编写，均实测通过。

--------------------

**欢迎转载，请注明来源：**

http://blog.csdn.net/u010967382/article/details/37878701

--------------------

概述

对于建表，和RDBMS类似，HBase也有namespace的概念，可以指定表空间创建表，也可以直接创建表，进入default表空间。

对于数据操作，HBase支持四类主要的数据操作，分别是：

*  Put ：增加一行，修改一行；
 *  Delete ：删除一行，删除指定列族，删除指定column的多个版本，删除指定column的制定版本等；
 *  **Get** ：获取指定行的所有信息，获取指定行和指定列族的所有colunm，获取指定column，获取指定column的几个版本， 获取指定column的指定版本等；   
    
 *  **Scan** ：获取所有行，获取指定行键范围的行，获取从某行开始的几行，获取满足过滤条件的行等。

这四个类都是 org.apache.hadoop.hbase.client的子类，可以到官网API去查看详细信息，本文仅总结常用方法，力争让读者用20%的时间掌握80%的常用功能。

--------------------

**目录**

1.命名空间Namespace

2.创建表

3.删除表

4.修改表

5.新增、更新数据Put

6.删除数据Delete

7.获取单行Get

8.获取多行Scan

--------------------

1. 命名空间Namespace

在关系数据库系统中，命名空间

namespace指的是一个 表的逻辑分组 ，同一组中的表有类似的用途。命名空间的概念为 即将到来 的多租户特性打下基础：

*  配额管理（ Quota Management (HBASE-8410)）：限制一个namespace可以使用的资源，资源包括region和table等；   
    
 *  命名空间安全管理（ Namespace Security Administration (HBASE-9206)）：提供了另一个层面的多租户安全管理；   
    
 *  Region服务器组（Region server groups (HBASE-6721)）：一个命名空间或一张表，可以被固定到一组 regionservers上，从而保证了数据隔离性。

--------------------

1.1.命名空间管理

命名空间可以被创建、移除、修改。

表和命名空间的隶属关系 在在创建表时决定，通过以下格式指定：

Example：hbase shell中创建命名空间、创建命名空间中的表、移除命名空间、修改命名空间

#Create a namespace
    create_namespace 'my_ns'
                
    #create my_table in my_ns namespace
    create 'my_ns:my_table', 'fam'
              
    #drop namespace
    drop_namespace 'my_ns'
              
    #alter namespace
    alter_namespace 'my_ns', {METHOD => 'set', 'PROPERTY_NAME' => 'PROPERTY_VALUE'}

--------------------

1.2. 预定义的命名空间

有两个系统内置的预定义命名空间：

*  **hbase **：系统命名空间，用于包含hbase的内部表   
    
 *  **default **： 所有未指定命名空间的表都自动进入该命名空间

Example：指定命名空间和默认命名空间

#namespace=foo and table qualifier=bar
    create 'foo:bar', 'fam'
    
    
    #namespace=default and table qualifier=bar
    create 'bar', 'fam'

--------------------

**2.创建表**

废话不多说，直接上样板代码，代码后再说明注意事项和知识点：

Configuration conf = HBaseConfiguration. create ();

HBaseAdmin admin =  new  HBaseAdmin(conf);

//create  namespace  named "my\_ns"

admin.createNamespace(NamespaceDescriptor. create ( "my\_ns" ).build());

//create tableDesc, with  namespace  name "my\_ns" and table name "mytable "

HTableDescriptor tableDesc =  new  HTableDescriptor(TableName. valueOf ("my\_ns:mytable" ));

tableDesc.setDurability(Durability. *SYNC\_WAL* );

//add a column family " mycf "

HColumnDescriptor hcd =  new  HColumnDescriptor( "mycf" );

tableDesc.addFamily(hcd);

admin.createTable(tableDesc);

admin.close();

关键知识点：

1.  必须将HBase集群的hbase-site.xml文件添加进工程的classpath中，否则Configuration conf = HBaseConfiguration. *create* () 代码获取不到需要的集群相关信息，也就无法找到集群，运行程序时会报错；   
    
2.  HTableDescriptor tableDesc =  **new**  HTableDescriptor(TableName. *valueOf* ("my\_ns:mytable" )) 代码是描述表mytable，并将mytable放到了my\_ns命名空间中，前提是该命名空间已存在，如果指定的是不存在命名空间，则会报 错org.apache.hadoop.hbase.NamespaceNotFoundException；
3.  命名空间一般在建模阶段通过命令行创建，在java代码中通过admin.createNamespace(NamespaceDescriptor. *create* ( "my\_ns" ).build()) 创建的机会不多；
4.  创建 HBaseAdmin 对象时就已经建立了客户端程序与HBase集群的connection ，所以在程序执行完成后，务必通过 admin.close() 关闭connection；
5.  可以通过 **HTableDescriptor **对象设置 表的特性 ，比如： 通过tableDesc.setMaxFileSize(512) 设置一个region中的store文件的最大size，当一个region中的最大store文件达到这个size时，region就开始分裂； 通过tableDesc.setMemStoreFlushSize(512) 设置region内存中的memstore的最大值，当memstore达到这个值时，开始往磁盘中刷数据。 更多特性请自行查阅官网API；
6.  可以通过 **HColumnDescriptor** 对象设置 列族的特性 ，比如：通过hcd.setTimeToLive(5184000) 设置数据保存的最长时间；通过 hcd.setInMemory(**true** ) 设置数据保存在内存中以提高响应速度；通过   hcd .setMaxVersions(10) 设置数据保存的最大版本数；通过 hcd.setMinVersions(5) 设置数据保存的最小版本数（配合TimeToLive使用）。更多特性请自行查阅官网API；   
    
7.  数据的版本数只能通过 HColumnDescriptor 对象设置，不能通过HTableDescriptor 对象设置；
8.  由于HBase的数据是先写入内存，数据累计达到内存阀值时才往磁盘中flush数据，所以，如果在数据还没有flush进硬盘时，regionserver down掉了，内存中的数据将丢失。要想解决这个场景的问题就需要用到WAL（Write-Ahead-Log），tableDesc.setDurability(Durability. *SYNC\_WAL* ) 就是设置写WAL日志的级别，示例中设置的是同步写WAL，该方式安全性较高，但无疑会一定程度影响性能，请根据具体场景选择使用；
9.  setDurability (Durability d)方法可以在相关的三个对象中使用，分别是：**HTableDescriptor， Delete， Put（其中Delete和Put的该方法都是继承自父类org.apache.hadoop.hbase.client.Mutation）** 。分别针对表、插入操作、删除操作设定WAL日志写入级别。需要注意的是， **Delete和Put并不会继承Table的Durability级别（已实测验证）** 。Durability是一个枚举变量，可选值参见4.2节。如果不通过该方法指定WAL日志级别，则为 **默认 USE\_DEFAULT** 级别。

--------------------

**3.删除表**

删除表没创建表那么多学问，直接上代码：

Configuration conf = HBaseConfiguration. create ();

HBaseAdmin admin =  new  HBaseAdmin(conf);

String tablename =  "my\_ns:mytable" ;

if (admin.tableExists(tablename)) \{

try  \{

admin.disableTable(tablename);

admin.deleteTable(tablename);

\}  catch  (Exception e) \{

//  TODO : handle exception

e.printStackTrace();

admin.close();

说明 ：删除表前必须先disable表。

--------------------

**4.修改表**

4.1.实例代码

（1）删除列族、新增列族

修改之前，四个列族：

hbase(main):014:0> describe 'rd\_ns:itable'

DESCRIPTION                                                                                                        ENABLED

'rd\_ns:itable', \{NAME => ' info ', DATA\_BLOCK\_ENCODING => 'NONE', BLOOMFILTER => 'ROW', REPLICATION\_SCOPE => '0', V true

ERSIONS => '10', COMPRESSION => 'NONE', MIN\_VERSIONS => '0', TTL => '2147483647', KEEP\_DELETED\_CELLS => 'false',

BLOCKSIZE => '65536', IN\_MEMORY => 'false', BLOCKCACHE => 'true'\}, \{NAME => ' newcf ', DATA\_BLOCK\_ENCODING => 'NONE

', BLOOMFILTER => 'ROW', REPLICATION\_SCOPE => '0', COMPRESSION => 'NONE', VERSIONS => '10', TTL => '2147483647',

MIN\_VERSIONS => '0', KEEP\_DELETED\_CELLS => 'false', BLOCKSIZE => '65536', IN\_MEMORY => 'false', BLOCKCACHE => 'tr

ue'\}, \{NAME => ' note ', DATA\_BLOCK\_ENCODING => 'NONE', BLOOMFILTER => 'ROW', REPLICATION\_SCOPE => '0', VERSIONS =>

'10', COMPRESSION => 'NONE', MIN\_VERSIONS => '0', TTL => '2147483647', KEEP\_DELETED\_CELLS => 'false', BLOCKSIZE

=> '65536', IN\_MEMORY => 'false', BLOCKCACHE => 'true'\}, \{NAME => ' sysinfo', DATA\_BLOCK\_ENCODING => 'NONE', BLOOM

FILTER => 'ROW', REPLICATION\_SCOPE => '0', COMPRESSION => 'NONE', VERSIONS => '10', TTL => '2147483647', MIN\_VERS

IONS => '0', KEEP\_DELETED\_CELLS => 'true', BLOCKSIZE => '65536', IN\_MEMORY => 'false', BLOCKCACHE => 'true'\}

1 row(s) in 0.0450 seconds

修改表，删除三个列族，新增一个列族，代码如下：

Configuration conf = HBaseConfiguration. create ();

HBaseAdmin admin =  new  HBaseAdmin(conf);

String tablename =  "rd\_ns:itable" ;

if (admin.tableExists(tablename)) \{

try  \{

admin.disableTable(tablename);

//get the TableDescriptor of target table

HTableDescriptor newtd =  admin.getTableDescriptor (Bytes. toBytes ("rd\_ns:itable" ));

//remove 3 useless column families

newtd.removeFamily(Bytes. toBytes ( "note" ));

newtd.removeFamily(Bytes. toBytes ( "newcf" ));

newtd.removeFamily(Bytes. toBytes ( "sysinfo" ));

//create HColumnDescriptor for new column family

HColumnDescriptor newhcd =  new  HColumnDescriptor( "action\_log" );

newhcd.setMaxVersions(10);

newhcd.setKeepDeletedCells( true );

//add the new column family(HColumnDescriptor) to HTableDescriptor

newtd.addFamily(newhcd);

//modify target table  struture

admin. modifyTable (Bytes. toBytes ( "rd\_ns:itable" ),newtd);

admin.enableTable(tablename);

\}  catch  (Exception e) \{

//  TODO : handle exception

e.printStackTrace();

admin.close();

修改之后：

hbase(main):015:0> describe 'rd\_ns:itable'

DESCRIPTION                                                                                                        ENABLED

'rd\_ns:itable', \{NAME => ' action\_log ', DATA\_BLOCK\_ENCODING => 'NONE', BLOOMFILTER => 'ROW', REPLICATION\_SCOPE =>  true

'0', COMPRESSION => 'NONE', VERSIONS => '10', TTL => '2147483647', MIN\_VERSIONS => '0', KEEP\_DELETED\_CELLS => 'tr

ue', BLOCKSIZE => '65536', IN\_MEMORY => 'false', BLOCKCACHE => 'true'\}, \{NAME => ' info ', DATA\_BLOCK\_ENCODING => '

NONE', BLOOMFILTER => 'ROW', REPLICATION\_SCOPE => '0', VERSIONS => '10', COMPRESSION => 'NONE', MIN\_VERSIONS => '

0', TTL => '2147483647', KEEP\_DELETED\_CELLS => 'false', BLOCKSIZE => '65536', IN\_MEMORY => 'false', BLOCKCACHE =>

'true'\}

1 row(s) in 0.0400 seconds

逻辑很简单：

1.  通过 **admin.getTableDescriptor** (Bytes. toBytes ( "rd\_ns:itable" )) 取得目标表的描述对象，应该就是取得指向该对象的指针了；   
    
2.  修改目标表描述对象；   
    
3.  通过 admin. **modifyTable** (Bytes. toBytes ( "rd\_ns:itable" ),newtd) 将修改后的描述对象应用到目标表。

（2）修改现有列族的属性（setMaxVersions）

Configuration conf = HBaseConfiguration. create ();

HBaseAdmin admin =  new  HBaseAdmin(conf);

String tablename =  "rd\_ns:itable" ;

if (admin.tableExists(tablename)) \{

try  \{

admin.disableTable(tablename);

//get the TableDescriptor of target table

HTableDescriptor htd = admin.getTableDescriptor(Bytes. toBytes ("rd\_ns:itable" ));

HColumnDescriptor infocf = htd.getFamily(Bytes. toBytes ( "info" ));

infocf.setMaxVersions(100);

//modify target table  struture

admin.modifyTable(Bytes. toBytes ( "rd\_ns:itable" ),htd);

admin.enableTable(tablename);

\}  catch  (Exception e) \{

//  TODO : handle exception

e.printStackTrace();

admin.close();

--------------------

5.新增、更新数据Put

5.1.常用构造函数：

（1）指定行键

public Put(byte\[\] row)

参数： row 行键

（2）指定行键和时间戳

public Put(byte\[\] row, long ts)

参数： row 行键， ts 时间戳

（3）从目标字符串中提取子串，作为行键

Put(byte\[\] rowArray, int rowOffset, int rowLength)

（4）从目标字符串中提取子串，作为行键，并加上时间戳

Put(byte\[\] rowArray, int rowOffset, int rowLength, long ts)

5.2.常用方法：

（1）指定 列族、限定符 ，添加值

add(byte\[\] family, byte\[\] qualifier, byte\[\] value)

（2）指定 列族、限定符、时间戳 ，添加值

add(byte\[\] family, byte\[\] qualifier, long ts, byte\[\] value)

（3） 设置写WAL （Write-Ahead-Log）的级别

public void setDurability(Durability d)

参数是一个枚举值，可以有以下几种选择：

*  ASYNC\_WAL ： 当数据变动时，异步写WAL日志
 *  SYNC\_WAL ： 当数据变动时，同步写WAL日志
 *  FSYNC\_WAL ： 当数据变动时，同步写WAL日志，并且，强制将数据写入磁盘
 *  SKIP\_WAL ： 不写WAL日志
 *  USE\_DEFAULT ： 使用HBase全局默认的WAL写入级别，即 SYNC\_WAL

5.3.实例代码

（1）插入行

Configuration conf = HBaseConfiguration. create ();

HTable table =  new  HTable(conf,  "rd\_ns:leetable" );

Put put =  new  Put(Bytes. toBytes ( "100001" ));

put.add(Bytes. toBytes ( "info" ), Bytes. toBytes ( "name" ), Bytes. toBytes ("lion" ));

put.add(Bytes. toBytes ( "info" ), Bytes. toBytes ( "address" ), Bytes. toBytes ("shangdi" ));

put.add(Bytes. toBytes ( "info" ), Bytes. toBytes ( "age" ), Bytes. toBytes ("30" ));

put.setDurability(Durability. *SYNC\_WAL* );

table.put(put);

table.close();

（2）更新行

Configuration conf = HBaseConfiguration. create ();

HTable table =  new  HTable(conf,  "rd\_ns:leetable" );

Put put =  new  Put(Bytes. toBytes ( "100001" ));

put.add(Bytes. toBytes ( "info" ), Bytes. toBytes ( "name" ), Bytes. toBytes ("lee" ));

put.add(Bytes. toBytes ( "info" ), Bytes. toBytes ( "address" ), Bytes. toBytes ("longze" ));

put.add(Bytes. toBytes ( "info" ), Bytes. toBytes ( "age" ), Bytes. toBytes ("31" ));

put.setDurability(Durability. *SYNC\_WAL* );

table.put(put);

table.close();

**注意：**

1.  Put的构造函数都需要指定行键，如果是全新的行键，则新增一行；如果是已有的行键，则更新现有行。
2.  创建Put对象及put.add过程都是在构建一行的数据，创建Put对象时相当于创建了行对象，add的过程就是往目标行里添加cell，直到table.put才将数据插入表格；
3.  以上代码创建Put对象用的是构造函数1，也可用构造函数2，第二个参数是时间戳；   
    
4.  Put还有别的构造函数，请查阅官网API。

（3） 从目标字符串中提取子串，作为行键，构建Put

Configuration conf = HBaseConfiguration. create ();

HTable table =  new  HTable(conf,  "rd\_ns:leetable" );

Put put =  new  Put(Bytes. toBytes ( "100001\_100002" ),7,6);

put.add(Bytes. toBytes ( "info" ), Bytes. toBytes ( "name" ), Bytes. toBytes ("show" ));

put.add(Bytes. toBytes ( "info" ), Bytes. toBytes ( "address" ), Bytes. toBytes ("caofang" ));

put.add(Bytes. toBytes ( "info" ), Bytes. toBytes ( "age" ), Bytes. toBytes ("30" ));

table.put(put);

table.close();

注意，关于： Put put =  new  Put(Bytes. *toBytes* ( "100001\_100002" ),7,6)

1.  第二个参数是偏移量，也就是行键从第一个参数的第几个字符开始截取；
2.  第三个参数是截取长度；
3.  这个代码实际是从 100001\_100002 中截取了100002子串作为目标行的行键。

--------------------

**6.删除数据Delete**

Delete类用于删除表中的一行数据，通过HTable.delete来执行该动作。

在执行Delete操作时，HBase并不会立即删除数据，而是对需要删除的数据打上一个“墓碑”标记，直到当Storefile合并时，再清除这些被标记上“墓碑”的数据。

如果希望删除整行，用行键来初始化一个Delete对象即可。如果希望进一步定义删除的具体内容，可以使用以下这些Delete对象的方法：

*  为了删除指定的列族，可以使用 deleteFamily
 *  为了删除指定列的多个版本，可以使用 deleteColumns
 *  为了删除指定列的 **指定版本** ，可以使用 deleteColumn，这样的话就只会删除版本号（时间戳）与指定版本相同的列。如果不指定时间戳，默认只删除最新的版本

下面详细说明构造函数和常用方法：

6.1.构造函数

（1）指定要删除的行键

Delete(byte\[\] row)

删除行键指定行的数据。

如果没有进一步的操作，使用该构造函数将删除行键指定的行中 所有列族中所有列的所有版本 ！

（2）指定要删除的行键和时间戳

Delete(byte\[\] row, long timestamp)

删除行键和时间戳共同确定行的数据。

如果没有进一步的操作，使用该构造函数将删除行键指定的行中，所有列族中所有列的 时间戳 小于等于 指定时间戳的数据版本 。

注意 ：该时间戳仅仅和删除行有关，如果需要进一步指定列族或者列，你必须分别为它们指定时间戳。

（3）给定一个字符串，目标行键的偏移，截取的长度

Delete(byte\[\] rowArray, int rowOffset, int rowLength)

（4）给定一个字符串，目标行键的偏移，截取的长度，时间戳

Delete(byte\[\] rowArray, int rowOffset, int rowLength, long ts)

6.2.常用方法

*  Delete   **deleteColumn** (byte\[\] family, byte\[\] qualifier)     删除指定列的 最新版本 的数据。

*  Delete   **deleteColumn s **(byte\[\] family, byte\[\] qualifier)     删除指定列的 所有版本的数据。

*  Delete   **deleteColumn** (byte\[\] family, byte\[\] qualifier, long  timestamp )     删除指定列的 指定版本 的数据。

*  Delete   **deleteColumn s **(byte\[\] family, byte\[\] qualifier, long  timestamp )     删除指定列的，时间戳 小于等于给定时间戳 的 所有 版本的数据。

*  Delete   **deleteFamily** (byte\[\] family)     删除指定列族的所有列的 **所有 **版本数据。

*  Delete   deleteFamily (byte\[\] family, long timestamp)     删除指定列族的所有列中时间戳 小于等于 指定时间戳 的所有数据。

*  Delete   deleteFamilyVersion (byte\[\] family, long timestamp)     删除指定列族中所有 **列的时间戳 等于 指定时间戳 **的版本数据。

*  void **setTimestamp** (long timestamp)     为Delete对象设置时间戳。

6.3.实例代码

（1）删除整行的所有列族、所有行、所有版本

Configuration conf = HBaseConfiguration. create ();

HTable table =  new  HTable(conf,  "rd\_ns:leetable" );

Delete delete =  new  Delete(Bytes. toBytes ( "000" ));

table.delete(delete);

table.close();

（2）删除 指定列的最新版本

以下是删除之前的数据，注意看100003行的info:address，这是该列最新版本的数据，值是caofang1，在这之前的版本值是caofang：

hbase(main):007:0> scan 'rd\_ns:leetable'

ROW                       COLUMN+CELL

100001                   column=info:address, timestamp=1405304843114, value=longze

100001                   column=info:age, timestamp=1405304843114, value=31

100001                   column=info:name, timestamp=1405304843114, value=leon

100002                   column=info:address, timestamp=1405305471343, value=caofang

100002                   column=info:age, timestamp=1405305471343, value=30

100002                   column=info:name, timestamp=1405305471343, value=show

100003                   column=info:address, timestamp=1405390959464, value=caofang1

100003                   column=info:age, timestamp=1405390959464, value=301

100003                   column=info:name, timestamp=1405390959464, value=show1

3 row(s) in 0.0270 seconds

执行以下代码：

Configuration conf = HBaseConfiguration. create ();

HTable table =  new  HTable(conf,  "rd\_ns:leetable" );

Delete delete =  new  Delete(Bytes. toBytes ( "100003" ));

delete.deleteColumn(Bytes. toBytes ( "info" ), Bytes. toBytes ( "address" ));

table.delete(delete);

table.close();

然后查看数据，发现100003列的info:address列的值显示为前一个版本的caofang了！其余值均不变：

hbase(main):008:0> scan 'rd\_ns:leetable'

ROW                       COLUMN+CELL

100001                   column=info:address, timestamp=1405304843114, value=longze

100001                   column=info:age, timestamp=1405304843114, value=31

100001                   column=info:name, timestamp=1405304843114, value=leon

100002                   column=info:address, timestamp=1405305471343, value=caofang

100002                   column=info:age, timestamp=1405305471343, value=30

100002                   column=info:name, timestamp=1405305471343, value=show

100003                   column=info:address, timestamp=1405390728175, value=caofang

100003                   column=info:age, timestamp=1405390959464, value=301

100003                   column=info:name, timestamp=1405390959464, value=show1

3 row(s) in 0.0560 seconds

（3）删除 指定列的所有版本

接以上场景，执行以下代码：

Configuration conf = HBaseConfiguration. create ();

HTable table =  new  HTable(conf,  "rd\_ns:leetable" );

Delete delete =  new  Delete(Bytes. toBytes ( "100003" ));

delete. deleteColumns (Bytes. *toBytes* ( "info" ), Bytes. *toBytes* ( "address"));

table.delete(delete);

table.close();

然后我们会发现，100003行的整个info:address列都没了：

hbase(main):009:0> scan 'rd\_ns:leetable'