java 对Hbase的基本操作

Java对Hbase的各种操作都是通过HTable实现的，由于创建HTable是有消耗的，因此推荐只创建一个HTable的实例，如果必须使用多个HTable实例，可以使用HTablePool，本文不对HTablePool进行介绍。

创建表：

创建表是通过HBaseAdmin类实现的，通过HBaseAdmin 类主要是对于表的管理操作。

public static void createTable(String tableName, String[] cfs) throws IOException{
        HBaseAdmin admin = new HBaseAdmin(configuration);
        if (admin.tableExists(tableName)) {
            System.out.println("table already exists");
        }else {
            HTableDescriptor descriptor = new HTableDescriptor(tableName);
            for(int i = 0; i < cfs.length; ++i){
                descriptor.addFamily(new HColumnDescriptor(cfs[i]));
            }
            admin.createTable(descriptor);
        }
    }

HBaseAdmin还包含了各种操作表的API，包括删除表，删除列等，有兴趣的可以看他的官方API，这里就不再讨论了。

添加数据：

添加数据通过HTable的put操作，添加Put对象；

void put(Put put) throws IOException

对于Put类，包含了多个构造函数使用，在这里我们只是使用了他的第一个构造函数。

Put(byte[] row)
Put(byte[] row, RowLock rowLock)
Put(byte[] row, long ts)
Put(byte[] row, long ts, RowLock rowLock)

像Put对象添加数据使用add函数：

Put add(byte[] family, byte[] qualifier, byte[] value)
Put add(byte[] family, byte[] qualifier, long ts, byte[] value)
Put add(KeyValue kv) throws IOException

添加数据操作：

public static void putData(String tableName) throws IOException{
        HTable table = new HTable(configuration, tableName);
        Put put = new Put(Bytes.toBytes("row1"));
        put.add(Bytes.toBytes("cf"), Bytes.toBytes("a"), Bytes.toBytes("v1"));
        table.put(put);
        table.close();
    }

获取数据：

对于获取数据，需要喜欢使用HTable的get函数：

Result get(Get get) throws IOException

Get类的构造函数相对与Put少了ts

Get(byte[] row)
Get(byte[] row, RowLock rowLock)

获取数据的操作：

public static void getData(String tableName) throws IOException{
        HTable table = new HTable(configuration, tableName);
        Get get = new Get(Bytes.toBytes("row1"));
        Result result = table.get(get);
        String value = new String(result.getValue(Bytes.toBytes("cf"), Bytes.toBytes("a")));
        System.out.println(value);
        table.close();
    }

对于扫描全表则需要使用scanner了。

public static void scannerData(String tablename) throws IOException {
        HTable table = new HTable(configuration, tablename);
        Scan s = new Scan();
        ResultScanner rs = table.getScanner(s);
        for (Result r : rs) {
            KeyValue[] kv = r.raw();
            for (int i = 0; i < kv.length; i++) {
                System.out.print(new String(kv[i].getRow()) + "  ");
                System.out.print(new String(kv[i].getFamily()) + ":");
                System.out.print(new String(kv[i].getQualifier()) + "  ");
                System.out.print(kv[i].getTimestamp() + "  ");
                System.out.println(new String(kv[i].getValue()));
            }
        }
    }