HBase之Java API

1.Configuration

在使用Java API時，Client端需要知道HBase的配置環境，如存儲地址，zookeeper等信息。這些信息通過Configuration對象來封裝，可通過如下代碼構建該對象

Configuration config=HBaseConfiguration.create();

在調用HBaseConfiguration.create()方法時，HBase首先會在classpath下查找hbase-site.xml文件，將裡面的信息解析出來封裝到Configuration對象中，如果hbase-site.xml文件不存在，則使用默認的hbase-core.xml文件。

除了將hbase-site.xml放到classpath下，開發人員還可通過config.set(name, value)方法來手工構建Configuration對象。

2.HBaseAdmin

HBaseAdmin用於創建數據庫表格，並管理表格的元數據信息，通過如下方法構建

HBaseAdmin admin=new HBaseAdmin(config);

常用方法：

addColumn(tableName,column):為表格添加欄位

deleteColumn(tableName,column):刪除指定欄位

balanceSwitch(boolean):是否啟用負載均衡

createTable(HTableDescriptor desc):創建表格

deleteTable(tableName):刪除表格

示例：創建test表格，並為其指定columnFamily為cf

[java]

1. HBaseAdmin admin=new HBaseAdmin(config);
2. If(!admin.tableExists(“test”)){
3. HTableDescriptor tableDesc=new HTableDescriptor(“test”);
4. HColumnDescriptor cf=new HColumnDescriptor(“cf”);
5. tableDesc.addFamily(cf);
6. admin.createTable(tableDesc);
7. }

3.HTable

在HBase中，HTable封裝表格對象，對表格的增刪改查操作主要通過它來完成，構造方法如下：

HTable table=new HTable(config,tableName);

在構建多個HTable對象時，HBase推薦所有的HTable使用同一個Configuration。這樣，HTable之間便可共享HConnection對象、zookeeper信息以及Region地址的緩存信息。

示例1：Get操作

[java]

1. Get get=new Get(rowKey);
2. Result res=table.get(get);

[java]

1. Put put=new Put(rowKey);
2. put.add(columnFamily,column,value);
3. table.put(put);

示例3：Delete操作

[java]

1. Delete delete=new Delete()；
2. table.delete(delete);

[java]

1. Scan scan=new Scan( );
2. scan.addColumn(columnFamily,column);//指定查詢要返回的column
3. SingleColumnValueFilter filter=new SingleColumnValueFilter(
4. columnFamily,column,//指定要過濾的column
5. CompareOp.EQUAL,value//指定過濾條件
6. );
7. //更多的過濾器信息請查看org.apache.Hadoop.hbase.filter包
8. scan.setFilter(filter);//為查詢指定過濾器
9. ResultScanner scanner=table.getScanner(scan);//執行掃描查找
10. Iterator<Result> res=scanner.iterator( );//返回查詢遍歷器