HBase的JavaAPI操作

package hbase;

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;

/**
 * 要先将HBase相关jar包添加进去！！！
 * 
 * 创建表、删除表 (使用HBaseAdmin)
 * 
 * 插入记录、查询一条记录、遍历所有记录 (使用HTable)
 * 
 * @author ahu_lichang
 * 
 */
public class HBaseApp {

    private static final String TABLE_NAME = "table1";
    private static final String FAMILY_NAME = "family1";
    private static final String ROW_KEY = "rowkey1";

    public static void main(String[] args) throws Exception {
        Configuration conf = HBaseConfiguration.create();
        /*
         * hbase操作必备
         */
        conf.set("hbase.rootdir", "hdfs://hadoop0:9000/hbase");
        // 使用eclipse时必须添加这个，否则无法定位
        conf.set("hbase.zookeeper.quorum", "hadoop0");
        /*
         * 创建表
         */
        HBaseAdmin hBaseAdmin = new HBaseAdmin(conf);
        /*
         * if (!hBaseAdmin.tableExists(TABLE_NAME)) { HTableDescriptor
         * hTableDescriptor = new HTableDescriptor(TABLE_NAME);
         * HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(
         * FAMILY_NAME); hTableDescriptor.addFamily(hColumnDescriptor);
         * hBaseAdmin.createTable(hTableDescriptor); }
         */

        /*
         * 添加一条记录
         */
        HTable hTable = new HTable(conf, TABLE_NAME);
        /*
         * Put put = new Put(ROW_KEY.getBytes());
         * put.add(FAMILY_NAME.getBytes(), "age".getBytes(), "25".getBytes());
         * hTable.put(put);
         */

        /*
         * 查询一条记录
         */

        /*
         * Get get = new Get(ROW_KEY.getBytes()); Result result =
         * hTable.get(get); byte[] value = result
         * .getValue(FAMILY_NAME.getBytes(), "age".getBytes()); //
         * keyvalues={rowkey1/family1:age/1491571143625/Put/vlen=2/ts=0} 25
         * System.out.println(result + "	" + new String(value));
         */

        /*
         * 遍历所有记录
         */
        Scan scan = new Scan();
        ResultScanner resultScanner = hTable.getScanner(scan);
        for (Result result : resultScanner) {
            byte[] value = result.getValue(FAMILY_NAME.getBytes(),
                    "age".getBytes());
            System.out.println(result + "	" + new String(value));
        }

        hTable.close();
        /*
         * 删除表
         */
        /*
         * hBaseAdmin.disableTable(TABLE_NAME);
         * hBaseAdmin.deleteTable(TABLE_NAME);
         */
    }

}