package?com.demo;

import?java.io.IOException;
import?java.util.ArrayList;
import?java.util.List;
?
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.KeyValue;
import?org.apache.hadoop.hbase.MasterNotRunningException;
import?org.apache.hadoop.hbase.ZooKeeperConnectionException;
import?org.apache.hadoop.hbase.client.Delete;
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.Result;
import?org.apache.hadoop.hbase.client.ResultScanner;
import?org.apache.hadoop.hbase.client.Scan;
import?org.apache.hadoop.hbase.client.Put;
import?org.apache.hadoop.hbase.util.Bytes;
?
public?class?HbaseTest?{
????
????private?static?Configuration?conf?=?null;
?????
????/**
?????*?初始化配置
?????*/
????static?{
????????Configuration?Hbase_CONFIG?=?new?Configuration（）;
????????//與hbase/conf/hbase-site.xml中hbase.zookeeper.quorum配置的值相同?
????????Hbase_CONFIG.set（“hbase.zookeeper.quorum“?“172.16.12.99“）;
????????//與hbase/conf/hbase-site.xml中hbase.zookeeper.property.clientPort配置的值相同
????????Hbase_CONFIG.set（“hbase.zookeeper.property.clientPort“?“2181“）;
????????conf?=?HbaseConfiguration.create（Hbase_CONFIG）;
????}
????
????/**
?????*?創(chuàng)建一張表
?????*/
????public?static?void?creatTable（String?tableName?String[]?familys）?throws?Exception?{
????????HbaseAdmin?admin?=?new?HbaseAdmin（conf）;
????????if?（admin.tableExists（tableName））?{
????????????System.out.println（“table?already?exists!“）;
????????}?else?{
????????????HTableDescriptor?tableDesc?=?new?HTableDescriptor（tableName）;
????????????for（int?i=0;?i????????????????tableDesc.addFamily（new?HColumnDescriptor（familys[i]））;
????????????}
????????????admin.createTable（tableDesc）;
????????????System.out.println（“create?table?“?+?tableName?+?“?ok.“）;
????????}?
????}
????
????/**
?????*?刪除表
?????*/
????public?static?void?deleteTable（String?tableName）?throws?Exception?{
???????try?{
???????????HbaseAdmin?admin?=?new?HbaseAdmin（conf）;
???????????admin.disableTable（tableName）;
???????????admin.deleteTable（tableName）;
???????????System.out.println（“delete?table?“?+?tableName?+?“?ok.“）;
???????}?catch?（MasterNotRunningException?e）?{
???????????e.printStackTrace（）;
???????}?catch?（ZooKeeperConnectionException?e）?{
???????????e.printStackTrace（）;
???????}
????}
?????
????/**
?????*?插入一行記錄
?????*/
????public?static?void?addRecord?（String?tableName?String?rowKey?String?family?String?qualifier?String?value）
????????????throws?Exception{
????????try?{
????????????HTable?table?=?new?HTable（conf?tableName）;
????????????Put?put?=?new?Put（Bytes.toBytes（rowKey））;
????????????put.add（Bytes.toBytes（family）Bytes.toBytes（qualifier）Bytes.toBytes（value））;