HBase的简单java操作

官方文档：http://hbase.apache.org/book.html

java简单操作hbase的表

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.filter.CompareFilter;
import org.apache.hadoop.hbase.filter.FilterList;
import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
import org.junit.Before;
import org.junit.Test;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Iterator;
import java.util.Random;

/**
 * Created by Edward on 2016/6/19.
 */
public class TestHbase {

    public static Configuration conf = null;
    public static TableName table = TableName.valueOf("phone");
    public static Random random = new Random();

    @Before
    public void setup()
    {
        //通过zookeeper集群，访问hbase
        conf = HBaseConfiguration.create();
        conf.set("hbase.zookeeper.quorum", "node1,node2,node3");
        System.out.println("setup");
    }

    @Test
    public void createTable() throws IOException {
        HBaseAdmin hBaseAdmin = new HBaseAdmin(conf);
       if(hBaseAdmin.tableExists(table)) {
            hBaseAdmin.disableTable(table);
            hBaseAdmin.deleteTable(table);
        }
        //表
        HTableDescriptor hTableDescriptor = new HTableDescriptor(table);
        //列族 cf1
        HColumnDescriptor hColumnDescriptor = new HColumnDescriptor("cf1");
        hColumnDescriptor.setBlockCacheEnabled(true);
        hColumnDescriptor.setBlocksize(128000);
        hColumnDescriptor.setMaxVersions(10);
        //表增加列族
        hTableDescriptor.addFamily(hColumnDescriptor);
        hBaseAdmin.createTable(hTableDescriptor);
    }


    @Test
    /**
     * 插入数据
     */
    public void insert() throws IOException {

        //创建htable对象
        HTable hTable = new HTable(conf, this.table);
        ArrayList<Put> list = new ArrayList<Put>();

        for(int i = 0; i<1000; i++)
        {
            //row_key
            Put put = new Put(String.valueOf(i).getBytes());
            //column,value
            put.add("cf1".getBytes(),"name".getBytes(),"ls".getBytes());
            put.add("cf1".getBytes(),"age".getBytes(), String.valueOf(i%100).getBytes());
            //把每个put对象放到列表中
            list.add(put);
        }
        //把信息放到表中
        hTable.put(list);
    }


    @Test
    /**
     * 查询
     */
    public void search() throws IOException
    {

        HTable hTable = new HTable(conf, this.table);
        // 创建row_key对应的get对象
        Get get = new Get("123".getBytes());
        // 获取get结果
        Result result = hTable.get(get);
        //获取 column latest cell
        Cell columnLatestCell = result.getColumnLatestCell("cf1".getBytes(), "name".getBytes());
        //使用 CellUtil 获取值
        byte[] bytes = CellUtil.cloneValue(columnLatestCell);
        System.out.println(new String(bytes));
    }


    @Test
    /**
     *  通过scan方法获取数据
     * **/
    public void search1() throws IOException
    {
        HTable hTable = new HTable(conf, this.table);
        //设置scan范围
        Scan scan = new Scan("400".getBytes(),"450".getBytes());
        //通过scan得到result scanner
        ResultScanner scanner = hTable.getScanner(scan);
        //使用迭代器
        Iterator<Result> iterator = scanner.iterator();

        while(iterator.hasNext())
        {
            Result result= iterator.next();
            Cell columnLatestCell = result.getColumnLatestCell("cf1".getBytes(), "age".getBytes());
            //获取列族中列对应的值
            byte[] bytes = CellUtil.cloneValue(columnLatestCell);
            //获取row_key
            byte[] bytes1 = CellUtil.cloneRow(columnLatestCell);
            System.out.println(new String(bytes)+" "+new String(bytes1));
        }
    }
}