HBase中的CRUD

        Table接口：负责表数据的基本操作。

       Admin类：负责管理建表、删表、该表等元数据操作的接口。

1、Put方法

1.1、了解put方法之前，必须知道的相关知识。

1. 在HBase中有一个理念：所有的数据皆为bytes。因此在HBase中所有的数据最终都会被序列化为bytes[ ]保存。
2. 最简单的将字符串转化为bytes[ ]的方法为：Bytes.toBytes()。

1.2、Put方法的构造函数

        Put（bytes[ ]  row）

        Put（ByteBuffer  row）

        Put（Put  putToCopy）

        Put（bytes[ ]  row , long  ts） 等等；

1.3、addColumn方法常用到调用方式

        addColumn（byte[ ]  family , byte[ ]  qualifier , byte[ ]  value）

        addColumn（byte[ ]  family , byte[ ]  qualifier , long  ts , byte[ ]  value）

        addColumn（byte[ ]  family , ByteBuffer  qualifier , long  ts , ByteBuffer  value）

        注：Put提供了一个语法糖，每一个addColumn返回的都是Put对象自己，因此可以把所有的列添加方法连接起来写。

以下为测试代码：

public static void main(String[] args) throws IOException {
    //1.实例化配置文件对象
    Configuration configuration = HBaseConfiguration.create();
    //2.设置连接接的数据库的IP地址
    configuration.set("hbase.zookeeper.quorum","master");
    //3.创建连接对象
    Connection connection = ConnectionFactory.createConnection(configuration);
    //4.创建Table接口对象
    Table table = connection.getTable(TableName.valueOf("user"));
    //实例化Put对象
    Put put = new Put(Bytes.toBytes("row1"));
    //5.准备新增的数据
    put.addColumn(Bytes.toBytes("info"),Bytes.toBytes("name"),666,Bytes.toBytes("jack"))
            .addColumn(Bytes.toBytes("info"),Bytes.toBytes("age"),Bytes.toBytes("23"))
            .addColumn(Bytes.toBytes("info"),Bytes.toBytes("address"),Bytes.toBytes("河南开封"));
    //6.执行新增操作
    table.put(put);
    //7.控制台打印运行完毕标识语句
    System.out.println("新增数据执行完毕~");
}

1.4、Put对象中其他方法

            append方法 用于追加字符；increment方法  用于数值增加或增减（前提：该数据为long格式的）

2、Get方法

2.1、Get的构造函数

Get  get = new Get（byte[ ]  row）

2.2、Get对象相关方法

        为了提高查询效率。

        addFamily（byte[ ]  family） 添加要取出来的列族

        addColumn（byte[ ]  family , byte[ ]  qualifier）添加要取出来的列族和列

        setTimeRange（long minStramp ， long maxStramp）设置要取出的版本范围

      setMaxVersions（）设置要取出的版本数，默认为1，不传入参数直接调用就是把MaxVersions设置为Integer.MAV_VEALUE。

2.3、Result类

        byte value（）把查询结果的第1列提取出来的快捷写法，用于你只查了一个列的情况。

        boolean isEmpty（）查询结果是否为空，可以用来判断是否查询到数据。

        Int size（）返回查找到的列数量，也可以提供size是否大于0判断是否查询到数据

        以下为测试代码案例：

public static void main(String[] args) throws IOException {
    Configuration configuration = HBaseConfiguration.create();
    configuration.set("hbase.zookeeper.quorum","master");
    Connection connection = ConnectionFactory.createConnection(configuration);
    Table table = connection.getTable(TableName.valueOf("user"));
    Get get = new Get(Bytes.toBytes ("row1"));
    Result result = table.get(get);
    System.out.println(Bytes.toString(result.value()));
    System.out.println("判断查询结果是否为空："+result.isEmpty());
    System.out.println("查找到的列数为："+result.size());
    System.exit(-1);
}

3、exists方法

Table接口提供的exists方法用来快速查询某一个数据是否存在的。

4、delet方法

4.1、Delete对象构造器

        Delete delete = new Delete（byte[ ]  row）；

4.2、Delete对象相关方法

        addFamily(byte[ ] family) 删除指定列族

        addFamily(byte[ ] family , long timestamp) 删除指定列族中所以版本号等于或小于给定的版本号的列

        addColumn(byte[ ] family , byte[ ] qualifiler) 删除指定列的最新版本

        addColumn(byte[ ] family , byte[ ] qualifiler , long timestamp) 删除指定列的特定版本

        addColumns(byte[ ] family , byte[ ] qualifiler) 删除指定列的所有版本

        addColumns(byte[ ] family , byte[ ] qualifiler , long timestamp) 删除指定列的等于或小于给定版本号的所有版本。

5、checkAndDelete方法

Table接口提供的，保证在一个原子操作内对数据完成修改和删除操作。

6、mutation方法

Table接口提供的，保证在任意两个操作放在他同一个原子操作内。

RowMutations类 用于整合相关操作 作为mutateRow方法的参数。

代码演示如下：

public static void main(String[] args) throws IOException {
    Configuration configuration = HBaseConfiguration.create();
    configuration.set("hbase.zookeeper.quorum","192.168.28.130");
    Connection connection = ConnectionFactory.createConnection(configuration);
    Table table = connection.getTable(TableName.valueOf("user"));
    //1.删除  行：row3 列: age
    Delete delete = new Delete(Bytes.toBytes("row3"));
    delete.addColumn(Bytes.toBytes("info"),Bytes.toBytes("age"));
    //2.修改  name值为chris
    Put put1 = new Put(Bytes.toBytes("row3"));
    put1.addColumn(Bytes.toBytes("info"),Bytes.toBytes("name"),Bytes.toBytes("chris"));
    //3.新增  info：job值为engineer
    Put put2 = new Put(Bytes.toBytes("row3"));
    put2.addColumn(Bytes.toBytes("info"),Bytes.toBytes("job"),Bytes.toBytes("engineer"));
    //新建RowMutations类  并且把以上操作对象添加进去
    RowMutations rowMutations = new RowMutations(Bytes.toBytes("row3"));
    rowMutations.add(delete);
    rowMutations.add(put1);
    rowMutations.add(put2);
    //执行删除/修改/新增操作
    table.mutateRow(rowMutations);
    System.out.println("执行完毕~");
}

7．批量操作  

        bath方法

public static void main(String[] args) throws IOException, InterruptedException {
    Configuration configuration = HBaseConfiguration.create();
    configuration.set("hbase.zookeeper.quorum","master");
    Connection connection = ConnectionFactory.createConnection(configuration);
    Table table = connection.getTable(TableName.valueOf("user"));
    //1.查询行row2数据
    Get get = new Get(Bytes.toBytes("row2"));
    //2.新增数据  row4 info：age  23
    Put put = new Put(Bytes.toBytes("row4"));
    put.addColumn(Bytes.toBytes("info"),Bytes.toBytes("age"),Bytes.toBytes(23));
    //3.删除行row1数据
    Delete delete = new Delete(Bytes.toBytes("row1"));
    //4.批量执行操作
    ArrayList<Row> list = new ArrayList<Row>();
    list.add(get);
    list.add(put);
    list.add(delete);
    Object[] results = new Object[list.size()];
    table.batch(list,results);
    byte[] value = ((Result) results[0]).getValue(Bytes.toBytes("info"), Bytes.toBytes("name"));
    System.out.println(Bytes.toString(value));
}

8、Scan扫描

public static void main(String[] args) throws IOException {
    Configuration configuration = HBaseConfiguration.create();
    configuration.set("hbase.zookeeper.quorum","master");
    Connection connection = ConnectionFactory.createConnection(configuration);
    Table table = connection.getTable(TableName.valueOf("user"));
    Scan scan = new Scan(Bytes.toBytes("row2"));
    ResultScanner results = table.getScanner(scan);
    Result result = results.next();
    byte[] value = result.getValue(Bytes.toBytes("info"), Bytes.toBytes("name"));
    System.out.println(Bytes.toString(value));
}