HBase JavaAPI

操作步骤：

创建Maven工程，需要导入的Pom文件如下

将虚拟主机当中的hbase-site.xml和hdfs-site.xml文件复制到项目下的classpath下

Hbase-site.xml

/usr/bigdata/hbase/hbase-1.3.1/conf

Hdfs-site.xml

/usr/bigdata/hadoop/hadoop-2.8.0/etc/hadoop

复制到项目的src/main/resources/下

框架：

修改windows真机的hosts文件，添加三台机器的映射

创建表

public static void createTable() throws Exception {
        // 获取Configuration对象
        Configuration con = HBaseConfiguration.create();
        // 创建HBaseAdmin对象是用来对表进行操作：包括创建 删除
        HBaseAdmin admin = new HBaseAdmin(con);
        // 判断表是否存在
        if (admin.tableExists("hbase_demo_api")) {
            System.out.println("表已经存在");
        } else {
            // 表的描述
            HTableDescriptor htable = new HTableDescriptor("hbase_demo_api");
            htable.addFamily(new HColumnDescriptor("grand"));
            htable.addFamily(new HColumnDescriptor("course"));
            admin.createTable(htable);
            System.out.println("表创建成功");
        }
        admin.close();

    }

插入数据

public static void putData() throws IOException {
        Configuration con = HBaseConfiguration.create();
        // 创建HTable句柄
        HTable hTable = new HTable(con, "hbase_demo-api");
        // 创建Put对象
        Put put = new Put("dinghzongqiu".getBytes());
        put.addColumn("course".getBytes(), "java".getBytes(), "98".getBytes());
        put.addColumn("course".getBytes(), "sql".getBytes(), "80".getBytes());
        put.addColumn("grand".getBytes(), "".getBytes(), "Y2".getBytes());
        hTable.put(put);
        hTable.close();
    }

获取表中的数据

public static void scanData() throws IOException {
        Configuration con = HBaseConfiguration.create();
        // 创建HTable句柄
        HTable hTable = new HTable(con, "hbase_demo-api");
        ResultScanner scanner = hTable.getScanner(new Scan());
        for (Result result : scanner) {
            for (Cell cell : result.rawCells()) {
                System.out.println("Row KEY:" + Bytes.toString(result.getRow()));
                System.out.println("列族:" + Bytes.toString(CellUtil.cloneFamily(cell)));
                System.out.println("列:" + Bytes.toString(CellUtil.cloneQualifier(cell)));
                System.out.println("value:" + Bytes.toString(CellUtil.cloneValue(cell)));
            }
        }
        hTable.close();
    }

获取指定ROWKey的数据

private static void getDataByRowKey() throws Exception {
        // TODO Auto-generated method stub
        Configuration con = HBaseConfiguration.create();
        // 创建HTable句柄
        HTable hTable = new HTable(con, "hbase_demo-api");
        Get get = new Get(Bytes.toBytes("丁中秋"));
        Result result = hTable.get(get);
        for (Cell cell : result.rawCells()) {
            System.out.println("Row KEY:" + Bytes.toString(result.getRow()));
            System.out.println("列族:" + Bytes.toString(CellUtil.cloneFamily(cell)));
            System.out.println("列:" + Bytes.toString(CellUtil.cloneQualifier(cell)));
            System.out.println("value:" + Bytes.toString(CellUtil.cloneValue(cell)));
        }
        hTable.close();
    }

获取指定ROWKey的数据2

private static void getDataByRowKey2() throws Exception {
        // TODO Auto-generated method stub
        Configuration con = HBaseConfiguration.create();
        // 创建HTable句柄
        HTable hTable = new HTable(con, "hbase_demo-api");
        Get get = new Get(Bytes.toBytes("丁中秋"));
        get.addColumn(Bytes.toBytes("course"), Bytes.toBytes("java"));
        Result result = hTable.get(get);
        for (Cell cell : result.rawCells()) {
            System.out.println("Row KEY:" + Bytes.toString(result.getRow()));
            System.out.println("列族:" + Bytes.toString(CellUtil.cloneFamily(cell)));
            System.out.println("列:" + Bytes.toString(CellUtil.cloneQualifier(cell)));
            System.out.println("value:" + Bytes.toString(CellUtil.cloneValue(cell)));
        }
        hTable.close();
    }

删除数据

public static void deleteData() throws Exception {
        // 获取Configuration对象
        Configuration con = HBaseConfiguration.create();
        // 创建HTable句柄
        HTable hTable = new HTable(con, "hbase_demo-api");
        Delete delete = new Delete(Bytes.toBytes("dingzhongqiu"));
        delete.addColumn(Bytes.toBytes("course"), Bytes.toBytes("java"));
        hTable.delete(delete);
        hTable.close();
    }

删除表

public static void deleteTable() throws Exception {
        // 获取Configuration对象
        Configuration con = HBaseConfiguration.create();
        // 创建HBaseAdmin对象是用来对表进行操作：包括创建 删除
        HBaseAdmin admin = new HBaseAdmin(con);
        // 禁用表
        admin.disableTable("hbase_demo-api");
        // 删除表
        admin.deleteTable(Bytes.toBytes("hbase_demo-api"));
        admin.close();
    }