概括

1. 创建、删除及启用禁用表、添加列等都需用到HBaseAdmin，另外需要注意删除，添加列等操作都需要禁用表

2. 表中添加数据，查询等都是和HTable相关，如果是多线程的情况下注意用HTablePool

3.  插入数据使用Put，可以单行添加也可批量添加

4. 查询数据需使用Get，Result，Scan、ResultScanner等

一、HBaseConfiguration

org.apache.hadoop.hbase.HBaseConfiguration 对HBase进行配置

eg：

    static Configuration cfg = HBaseConfiguration.create();
    static {
        
        cfg.set("hbase.zookeeper.quorum", "192.168.1.95");
        cfg.set("hbase.zookeeper.property.clientPort", "2181");
    }

二、HBaseAdmin

org.apache.hadoop.hbase.client.HBaseAdmin 提供了一个接口来管理HBase数据库的表信息。它提供的方法包括：创建表，删除表，列出表项，使表有效或无效，以及添加或删除表列族成员等。

eg：

判断表是否存在：

HBaseAdmin hBaseAdmin = new HBaseAdmin(cfg);
if (hBaseAdmin.tableExists(tableName)) {// 如果存在要创建的表，那么先删除，再创建
 　hBaseAdmin.disableTable(tableName);
　　hBaseAdmin.deleteTable(tableName);
　　System.out.println(tableName + " is exist");
}

创建表：

hBaseAdmin.createTable(tableDescriptor);

添加列：

hBaseAdmin = new HBaseAdmin(cfg);
hBaseAdmin.disableTable(tableName); 
HColumnDescriptor hd = new HColumnDescriptor(columnFamily);
hBaseAdmin.addColumn(tableName,hd);

三、HTableDescriptor

org.apache.hadoop.hbase.HTableDescriptor 包含了表的名字极其对应表的列族

eg：创建表时添加列

HTableDescriptor tableDescriptor = new HTableDescriptor(tableName);// 代表表的schema
tableDescriptor.addFamily(new HColumnDescriptor("name")); // 增加列簇
tableDescriptor.addFamily(new HColumnDescriptor("age"));
tableDescriptor.addFamily(new HColumnDescriptor("gender"));
hBaseAdmin.createTable(tableDescriptor);

四、HColumnDescriptor

关系：org.apache.hadoop.hbase.HColumnDescriptor

作用：维护着关于列族的信息，例如版本号，压缩设置等。它通常在创建表或者为表添加列族的时候使用。列族被创建后不能直接修改，只能通过删除然后重新创建的方式。列族被删除的时候，列族里面的数据也会同时被删除。

eg：见上面

五、HTable

org.apache.hadoop.hbase.client.HTable 可以用来和HBase表直接通信。此方法对于更新操作来说是非线程安全的。

eg：

    　　HTablePool pool = new HTablePool(cfg, 1000);
        // HTable table = (HTable) pool.getTable(tableName);

        Put put = new Put("*1111".getBytes());// 一个PUT代表一行数据，再NEW一个PUT表示第二行数据,每行一个唯一的ROWKEY，此处rowkey为put构造方法中传入的值
        put.add("name".getBytes(), null, "Chander".getBytes());// 本行数据的第一列
        put.add("age".getBytes(), null, "20".getBytes());// 本行数据的第三列
        put.add("gender".getBytes(), null, "male".getBytes());// 本行数据的第三列
        put.add("score".getBytes(), "Math".getBytes(), "99".getBytes());// 本行数据的第四列
        put.add("score".getBytes(), "English".getBytes(), "100".getBytes());// 本行数据的第四列
        put.add("score".getBytes(), "Chinese".getBytes(), "120".getBytes());// 本行数据的第四列   第二个参数对应qualifier
        try {
            pool.getTable(tableName).put(put);
        } catch (IOException e) {
            e.printStackTrace();
        }

六、Put

关系：org.apache.hadoop.hbase.client.Put

作用：用来对单个行执行添加操作

eg：见上例

七、Get

org.apache.hadoop.hbase.client.Get ：用来获取单个行的相关信息

eg：

 　　　　HTable table = new HTable(cfg, tablename);
        Get g = new Get(rowKey.getBytes());
        Result rs = table.get(g);

        for (KeyValue kv : rs.raw())
        {
            System.out.println("rowkey:        " + new String(kv.getRow()));
            System.out.println("Column Family: " + new String(kv.getFamily()));
            System.out.println("Column       : " + new String(kv.getQualifier()));
            System.out.println("value        : " + new String(kv.getValue()));
        }

八、Result

org.apache.hadoop.hbase.client.Result 存储Get或者Scan操作后获取表的单行值。使用此类提供的方法可以直接获取值或者各种Map结构（key-value对）

eg：

 　　　　HTable table = new HTable(cfg, tablename);
        Get g = new Get(rowKey.getBytes());
        Result rs = table.get(g);

        for (KeyValue kv : rs.raw())
        {
            System.out.println("rowkey:        " + new String(kv.getRow()));
            System.out.println("Column Family: " + new String(kv.getFamily()));
            System.out.println("Column       : " + new String(kv.getQualifier()));
            System.out.println("value        : " + new String(kv.getValue()));
        }

九、Scan

import org.apache.hadoop.hbase.client.Scan 扫描，类似于数据库中的cursor，使用和get类似，也类似于迭代器

可以使用new Scan() 也可以调用HTable的getScanner()方法次方法返回扫描器scanner

eg1：

Scan scan = new Scan();
ResultScanner scanner = htable.getScanner(scan);
for(Result rs: scanner){
   System.out.println(rs);  
}

eg2:

Scan scan = new Scan();
scan.addFamily(Bytes.toBytes("columnFamily1"));
ResultScanner scanner = htable.getScanner(scan);
for(Result rs: scanner){
   System.out.println(rs);  
}

eg3:

Scan scan = new Scan();
scan.addFamily(Bytes.toBytes("columnFamily1"),Bytes.toBytes("column1"));
ResultScanner scanner = htable.getScanner(scan);
for(Result rs: scanner){
   System.out.println(rs);  
}

eg4: 添加过滤器

    Scan scan = new Scan();
        scan.addColumn(Bytes.toBytes(columnFamily),Bytes.toBytes(column));
        
        Filter f = new RowFilter(CompareFilter.CompareOp.LESS_OR_EQUAL, new BinaryComparator(Bytes.toBytes(condition)));
        scan.setFilter(f);
        HTablePool pool = new HTablePool(cfg, 1000); 
        try {
            ResultScanner resultScanner = pool.getTable(tableName).getScanner(scan);
            Result rs = resultScanner.next();
                for (; rs != null; rs = resultScanner.next())
                {
                    for (KeyValue kv : rs.list())
                    {
                        System.out.println("-------------------------------");
                        System.out.println("rowkey:        " + new String(kv.getRow()));
                        System.out.println("Column Family: " + new String(kv.getFamily()));
                        System.out.println("Column       :" + new String(kv.getQualifier()));
                        System.out.println("value        : " + new String(kv.getValue()));
                    }
                }
            
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

十、ResultScanner

 见9中Scan

eg：

    Scan scan = new Scan();
        scan.addColumn(Bytes.toBytes(columnFamily),Bytes.toBytes(column));
        
        Filter f = new RowFilter(CompareFilter.CompareOp.LESS_OR_EQUAL, new BinaryComparator(Bytes.toBytes(condition)));
        scan.setFilter(f);
        HTablePool pool = new HTablePool(cfg, 1000); 
        try {
            ResultScanner resultScanner = pool.getTable(tableName).getScanner(scan);
            Result rs = resultScanner.next();
                for (; rs != null; rs = resultScanner.next())
                {
                    for (KeyValue kv : rs.list())
                    {
                        System.out.println("-------------------------------");
                        System.out.println("rowkey:        " + new String(kv.getRow()));
                        System.out.println("Column Family: " + new String(kv.getFamily()));
                        System.out.println("Column       :" + new String(kv.getQualifier()));
                        System.out.println("value        : " + new String(kv.getValue()));
                    }
                }
            
        } catch (IOException e) {
            // TODO Auto-generated catch block
            e.printStackTrace();
        }

参考：http://www.cnblogs.com/NicholasLee/archive/2012/09/13/2683432.html