HBASE（二）—— HBase 的 JavaAPI，

HBASE（二）—— HBase 的 JavaAPI，

在 Windows 平台运行的话，需要修改 C:\Windows\System32\drivers\etc 目录下的 hosts 文件，将 HMaster 的主机名与 ip 地址的映射关系配置到 hosts 文件里面：192.168.220.111 bigdata111。

一、创建表

/**
 * 创建表
 * @throws Exception
 */
private static void createTable() throws Exception {
    // 指定ZooKeeper地址，从zk中获取HMaster的地址
    // 注意：ZK返回的是HMaster的主机名, 不是IP地址 ---> 配置Windows的hosts文件
    // C:\Windows\System32\drivers\etc\hosts
    Configuration conf = new Configuration();
    conf.set("hbase.zookeeper.quorum", "192.168.220.111");

    // 创建一个 HBase 客户端
    HBaseAdmin client = new HBaseAdmin(conf);

    // 通过表的描述符来创建表
    HTableDescriptor htd = new HTableDescriptor(TableName.valueOf("student"));

    // 设置表的列族信息
    HColumnDescriptor h1 = new HColumnDescriptor("info");
    HColumnDescriptor h2 = new HColumnDescriptor("grade");

    // 将列族加入表
    htd.addFamily(h1);
    htd.addFamily(h2);

    // 创建表
    client.createTable(htd);
    client.close();
}

二、插入数据

/**
 * 插入数据
 * @throws Exception
 */
private static void put() throws Exception {
    Configuration conf = new Configuration();
    conf.set("hbase.zookeeper.quorum", "192.168.220.111");

    // 指定表的客户端
    HTable table = new HTable(conf, "student");

    // 构造一个put对象
    // 1.设置rowkey的值
    Put put = new Put(Bytes.toBytes("stu001"));

    // 2.设置列族的值，列的名字，列的值
    put.addColumn(Bytes.toBytes("info"), // 列族的名字
            Bytes.toBytes("name"), // 列的名字
            Bytes.toBytes("Tom")); //  列的值

    // 插入
    table.put(put);

    table.close();
}

三、查询数据

四、删除表

/**
 * 删除表
 * @throws Exception
 */
private static void dropTable() throws Exception {
    Configuration conf = new Configuration();
    conf.set("hbase.zookeeper.quorum", "192.168.220.111");

    // 创建一个HBase客户端
    HBaseAdmin client = new HBaseAdmin(conf);

    // 先禁用表，再删除表
    client.disableTable(Bytes.toBytes("student"));
    client.deleteTable(Bytes.toBytes("student"));

    client.close();
}