在java中通过API调用HBase入门学习

在之前的文章hdfs API学习中，我们已经能够成功连接hdfs，并对文件进行读写。hbase数据库的操作也非常简单，但你需要先大致了解一下hbase的架构。

hbase架构

hbase是基于列存储的nosql数据库，hbase官方参考指南中有很详细的使用说明。个人理解列存储的意思就是物理数据存储不是按行划分，而是按列划分。例如一个成绩表，所有人的高等数据成绩信息在底层存放在一个文件中，所有人的计算机成绩信息存放在底层的另一个文件中，如果你想要获取某人的高等数据成绩信息，那么只用输入某人姓名+高等数学列，数据库就会扫描高等数据成绩信息文件，检索出某人的高等数学成绩，而不会扫描计算机成绩信息文件。

实际上hbase的列存储指的是列族存储，也就是说一堆列组成一个物理存储文件。例如个人信息表，成绩信息可以作为一个列族，其中包含高等数据成绩、计算机成绩信息等列，个人健康信息可以作为一个列族，其中包含身高、体重等列。

如果你想获取一个人的体重信息，那么获取方式key就是个人信息表+个人健康信息列族+体重列（版本概念暂且不提）。

hbase简单api调用

hbase的功能相当丰富，运维也相对比较复杂，下面是对hbase的简单调用，仅供参考学习。如果想了解更多深入的内容，可以参考上边提到的官方参考指南。

package com.gavinzh.learn.hbase;

import com.google.common.collect.Lists;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;

import java.io.IOException;
import java.util.List;
import java.util.stream.Collectors;

/**
 * @author jiangmitiao
 */
public class HBaseLearnMain {
    private Connection connection;
    private Admin admin;

    public void init(String baseRootaddr) throws IOException {
        Configuration configuration = HBaseConfiguration.create();
        configuration.set("base.rootaddr", baseRootaddr);
        configuration.set("hbase.zookeeper.quorum", "192.168.10.103:2181");
        connection = ConnectionFactory.createConnection(configuration);
        admin = connection.getAdmin();
    }

    public void createTable(String tableNameStr, List<String> colFamilyList) throws IOException {
        TableName tableName = TableName.valueOf(tableNameStr);
        if (admin.tableExists(tableName)) {
            System.err.println(tableNameStr + "已存在");
            return;
        }
        List<ColumnFamilyDescriptor> list = colFamilyList.stream()
            .map(family -> ColumnFamilyDescriptorBuilder.newBuilder(family.getBytes()).build())
            .collect(Collectors.toList());
        TableDescriptor tableDescriptor = TableDescriptorBuilder.newBuilder(tableName)
            .setColumnFamilies(list)
            .build();

        admin.createTable(tableDescriptor);
    }

    public void insertData(String tableNameStr, String rowKey, String colFamily, String col, String value)
        throws IOException {
        Table table = connection.getTable(TableName.valueOf(tableNameStr));
        Put put = new Put(rowKey.getBytes());
        put.addColumn(colFamily.getBytes(), col.getBytes(), value.getBytes());
        table.put(put);
    }

    public String getData(String tableNameStr, String rowKey, String colFamily, String col) throws IOException {
        Table table = connection.getTable(TableName.valueOf(tableNameStr));
        Get get = new Get(rowKey.getBytes());
        get.addColumn(colFamily.getBytes(), col.getBytes());
        Result result = table.get(get);
        return new String(result.getValue(colFamily.getBytes(), col.getBytes()));
    }

    public void dropTable(String tableNameStr) throws IOException {
        TableName tableName = TableName.valueOf(tableNameStr);
        if (!admin.tableExists(tableName)) {
            System.err.println(tableNameStr + "不存在");
            return;
        }
        if (!admin.isTableDisabled(tableName)) {
            admin.disableTable(tableName);
        }
        admin.deleteTable(tableName);
    }

    public void destroy() throws IOException {
        if (admin != null) {
            admin.close();
        }
        if (connection != null) {
            connection.close();
        }
    }

    public static void testXiaoming(HBaseLearnMain hBaseLearnMain) throws IOException {
        String tableNameStr = "tableTest1FromApi";
        String colFamily1 = "learn";
        String col = "English";
        String rowKey = "小明";
        hBaseLearnMain.insertData(tableNameStr, rowKey, colFamily1, col, "98");
        hBaseLearnMain.insertData(tableNameStr, rowKey, colFamily1, col, "65");

        String data = hBaseLearnMain.getData(tableNameStr, rowKey, colFamily1, col);
        System.out.println("小明英语成绩:" + data);
    }

    public static void testXiaohong(HBaseLearnMain hBaseLearnMain) throws IOException {
        String tableNameStr = "tableTest1FromApi";
        String colFamily1 = "body";
        String col = "height";
        String rowKey = "小红";
        hBaseLearnMain.insertData(tableNameStr, rowKey, colFamily1, col, "131");
        hBaseLearnMain.insertData(tableNameStr, rowKey, colFamily1, col, "165");

        String data = hBaseLearnMain.getData(tableNameStr, rowKey, colFamily1, col);
        System.out.println("小红身高:" + data);
    }

    public static void main(String[] args) throws IOException {

        HBaseLearnMain hBaseLearnMain = new HBaseLearnMain();
        hBaseLearnMain.init("hdfs://hadoop1/hbase");

        String tableNameStr = "tableTest1FromApi";
        List<String> colFamilyList = Lists.newArrayList("learn", "body");
        hBaseLearnMain.createTable(tableNameStr, colFamilyList);

        testXiaoming(hBaseLearnMain);
        testXiaohong(hBaseLearnMain);

        //hBaseLearnMain.dropTable(tableNameStr);

        hBaseLearnMain.destroy();
    }
}