hbase使用JavaAPI

### 使用Java API操作HBase

为了使用Java API来操作HBase，开发者通常会依赖于`org.apache.hadoop.hbase.client`包中的类。下面是一些基本的操作实例。

#### 创建表并插入数据

创建一个名为`users`的新表格，并向其中添加一些记录：

Configuration config = HBaseConfiguration.create();
config.set("hbase.zookeeper.quorum", "localhost");
try (Connection connection = ConnectionFactory.createConnection(config);
     Admin admin = connection.getAdmin()) {

    TableName tableName = TableName.valueOf("users");

    if (!admin.tableExists(tableName)) {
        TableDescriptorBuilder tableDesc =
            TableDescriptorBuilder.newBuilder(tableName)
                .setColumnFamily(ColumnFamilyDescriptorBuilder.of("personal"))
                .setColumnFamily(ColumnFamilyDescriptorBuilder.of("contactinfo"));
        
        admin.createTable(tableDesc.build());
    }

    try (Table table = connection.getTable(tableName)) {
        Put put1 = new Put(Bytes.toBytes("row1"));
        put1.addColumn(Bytes.toBytes("personal"), Bytes.toBytes("name"),
                       Bytes.toBytes("John Doe"));
        put1.addColumn(Bytes.toBytes("contactinfo"), Bytes.toBytes("email"),
                       Bytes.toBytes("johndoe@example.com"));

        table.put(put1);

        System.out.println("Added row1 to the users table.");
    }
}

这段代码展示了如何配置连接到本地ZooKeeper集群[^1]，检查是否存在指定名称的表以及如果不存在则创建该表的过程。接着，在新创建或已存在的表中插入了一条带有两个列族的数据记录。

#### 查询特定行键的数据

通过给定的行键检索存储在表内的信息：

Get get = new Get(Bytes.toBytes("row1"));
Result result;
try (Table table = connection.getTable(TableName.valueOf("users"))) {
    result = table.get(get);
}

byte[] valueName = result.getValue(
    Bytes.toBytes("personal"), Bytes.toBytes("name"));
String name = Bytes.toString(valueName);

System.out.printf("Retrieved user's name: %s%n", name);

此部分说明了怎样利用`Get`对象获取单个单元格的内容，并将其转换成字符串形式输出至控制台。

#### 删除整张表

当不再需要某张表时可以执行删除动作：

try (Connection connection = ConnectionFactory.createConnection(config);
     Admin admin = connection.getAdmin()) {

    TableName tableName = TableName.valueOf("users");

    if (admin.tableExists(tableName)) {
        admin.disableTable(tableName); // 表必须先被禁用才能移除
        admin.deleteTable(tableName);
        System.out.println("Deleted 'users' table successfully.");
    } else {
        System.err.println("'users' table does not exist!");
    }
}

上述片段实现了关闭目标表之后再彻底清除它的功能。