hbase java编程实例
?
HBase提供了java api来对HBase进行一系列的管理涉及到对表的管理、数据的操作等。常用的API操作有：
1、 ?对表的创建、删除、显示以及修改等，可以用HBaseAdmin，一旦创建了表，那么可以通过HTable的实例来访问表，每次可以往表里增加数据。
2、 ?插入数据
创建一个Put对象，在这个Put对象里可以指定要给哪个列增加数据，以及当前的时间戳等值，然后通过调用HTable.put(Put)来提交操作，子猴在这里提请注意的是：在创建Put对象的时候，你必须指定一个行(Row)值，在构造Put对象的时候作为参数传入。
3、 ?获取数据
要获取数据，使用Get对象，Get对象同Put对象一样有好几个构造函数，通常在构造的时候传入行值，表示取第几行的数据，通过HTable.get(Get)来调用。
4、 ?浏览每一行
通过Scan可以对表中的行进行浏览，得到每一行的信息，比如列名，时间戳等，Scan相当于一个游标，通过next()来浏览下一个，通过调用HTable.getScanner(Scan)来返回一个ResultScanner对象。HTable.get(Get)和HTable.getScanner(Scan)都是返回一个Result。Result是一个
KeyValue的链表。
5、 ?删除
使用Delete来删除记录，通过调用HTable.delete(Delete)来执行删除操作。（注：删除这里有些特别，也就是删除并不是马上将数据从表中删除。）
6、 ?锁
新增、获取、删除在操作过程中会对所操作的行加一个锁，而浏览却不会。
7、 ?簇的访问
客户端代码通过ZooKeeper来访问找到簇，也就是说ZooKeeper quorum将被使用，那么相关的类（包）应该在客户端的类（classes）目录下，即客户端一定要找到文件hbase-site.xml。
以下是一个完整的代码示例，基于hbase-0.90.3编写（hbase的基本概念可参考我博客的前一篇文章）：
package gucas.xiaoxia;import java.io.IOException;import java.nio.charset.Charset;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.HColumnDescriptor;import org.apache.hadoop.hbase.HTableDescriptor;import org.apache.hadoop.hbase.client.Get;import org.apache.hadoop.hbase.client.HBaseAdmin;import org.apache.hadoop.hbase.client.HTable;import org.apache.hadoop.hbase.client.Put;import org.apache.hadoop.hbase.client.Result;import org.apache.hadoop.hbase.client.ResultScanner;import org.apache.hadoop.hbase.client.Scan;import org.apache.hadoop.hbase.util.Bytes;public class MyClient {public static void main(String[] args) throws IOException {// TODO Auto-generated method stub//read config-file hbase-site.xml, hbase-default.xml Configuration conf = HBaseConfiguration.create(); //create table client Admin HBaseAdmin admin = new HBaseAdmin(conf); HColumnDescriptor[] columns = new HColumnDescriptor[2]; columns[0] = new HColumnDescriptor("books"); columns[1] = new HColumnDescriptor("catalogs"); HTableDescriptor htd = new HTableDescriptor("mytable"); htd.addFamily(columns[0]); htd.addFamily(columns[1]); //create table mytable admin.createTable(htd); //Run some operations HTable table = new HTable(conf, htd.getNameAsString()); //Put opt Put p1 = new Put(Bytes.toBytes("row1")); //Byte p1.add(byte[] column family, byte[] qualifier, byte[] value) p1.add( Bytes.toBytes("books"), Bytes.toBytes("name"), Bytes.toBytes("west jury")); table.put(p1); p1 = new Put(Bytes.toBytes("row2")); p1.add( Bytes.toBytes("books"), Bytes.toBytes("author"), Bytes.toBytes("xiaoxia")); table.put(p1); p1 = new Put(Bytes.toBytes("row2")); p1.add( Bytes.toBytes("catalogs"), Bytes.toBytes("name"), Bytes.toBytes("xiaoxia-catalogs")); table.put(p1); //edit row2 books:author value p1 = new Put(Bytes.toBytes("row2")); p1.add( Bytes.toBytes("books"), Bytes.toBytes("author"), Bytes.toBytes("xiaoxia-books")); table.put(p1); Scan scan = new Scan(); ResultScanner scanner = table.getScanner(scan); for (Result result2 : scanner) {System.out.println("Scan : "+ result2); } scanner.close(); //get field value Get get = new Get("row1".getBytes()); Result result = table.get(get); System.out.println("get : "+ new String(result.getRow(),Charset.defaultCharset())+", "+new String(result.getValue("books".getBytes(), "name".getBytes()))); System.in.read(); //disable table first ,then delete the table System.out.println("disable table "); admin.disableTable("mytable".getBytes()); System.out.println("delete table "); admin.deleteTable("mytable".getBytes()); }}?