[大数据]HBase API

目录

1.DDL

1.1判断表是否存在

1.2创建表

1.3删除表

1.4创建命名空间

2.DML

2.1向表插入数据

2.2获取数据（get）

2.3获取数据（scan）

2.4删除数据

3.完整代码

1.DDL

1.1判断表是否存在

    //1.判断表是否存在
    public static boolean isTableExist(String tableName) throws IOException {
//        //1.获取配置文件信息
//        //过时的
//        //HBaseConfiguration configuration = new HBaseConfiguration();
//        Configuration configuration = HBaseConfiguration.create();
//        configuration.set("hbase.zookeeper.quorum","hadoop102,hadoop103,hadoop104");
//
//        //2.获取管理员对象
//        //过时的
//        //HBaseAdmin admin = new HBaseAdmin(configuration);
//        Connection connection = ConnectionFactory.createConnection(configuration);
//        Admin admin = connection.getAdmin();

        //3.判断表是否存在
        boolean exists = admin.tableExists(TableName.valueOf(tableName));

//        //4.关闭连接
//        admin.close();

        //5.返回结果
        return  exists;
    }

1.2创建表

从admin.createTable(hTableDescriptor)考虑需要什么，然后写什么

    //2.创建表
    public static void createTable(String tableName,String... cfs) throws IOException {
        //1.判断是否存在列族信息
        if(cfs.length <= 0){
            System.out.println("设置列族信息");
            return;
        }

        //2.判断表是否存在
        if(isTableExist(tableName)){
            System.out.println(tableName + "表已存在");
            return;
        }

        //3.创建表描述器
        HTableDescriptor hTableDescriptor = new HTableDescriptor(TableName.valueOf(tableName));

        //4.循环添加列族信息
        for (String cf : cfs) {
            //5.创建列族描述器
            HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(cf);

            //6.添加具体列族信息
            hTableDescriptor.addFamily(hColumnDescriptor);
        }

        //创建表
        admin.createTable(hTableDescriptor);
    }

1.3删除表

    //3.删除表
    public static void dropTable(String tableName) throws IOException {
        //1.判断表是否存在
        if(!isTableExist(tableName)){
            System.out.println(tableName + "表不存在");
            return;
        }

        //2.使表下线
        admin.disableTable(TableName.valueOf(tableName));

        //3.删除表
        admin.deleteTable(TableName.valueOf(tableName));
    }

1.4创建命名空间

   //4.创建命名空间
    public static void createNameSpace(String ns){
        //1.创建命名空间描述器
        NamespaceDescriptor namespaceDescriptor = NamespaceDescriptor.create(ns).build();

        //2.创建命名空间
        //官方没有提供命名空间是否存在的方式
        try {
            admin.createNamespace(namespaceDescriptor);
        } catch (NamespaceExistException e) {
            System.out.println("命名空间已存在");
        } catch (IOException e) {
            e.printStackTrace();
        }

        //后面可以继续执行
        //若命名空间存在，在提示命名空间存在后执行其他任务
        System.out.println("继续执行");
    }

2.DML

2.1向表插入数据

    //5.向表插入数据
    public static void putData(String tableName,String rowKey,String cf,String cn,String value) throws IOException {
        //1.获取表对象
        Table table = connection.getTable(TableName.valueOf(tableName));

        //2.创建Put对象
        Put put = new Put(Bytes.toBytes(rowKey));

        //3.给Put对象赋值
        put.addColumn(Bytes.toBytes(cf),Bytes.toBytes(cn),Bytes.toBytes(value));

        //4.插入数据
        table.put(put);

        //5.关闭表连接
        table.close();
    }

2.2获取数据（get）

    //6.获取数据（get）
    public static void getData(String tableName,String rowKey,String cf,String cn) throws IOException {
        //1.获取表对象
        Table table = connection.getTable(TableName.valueOf(tableName));

        //2.创建Get对象
        //这里只有rowKey，因此列族、列任意填其他的也没事
        Get get = new Get(Bytes.toBytes(rowKey));

//        //2.1指定获取的列族
//        get.addFamily(Bytes.toBytes(cf));

        //2.2指定列族和列
        //写列不能抛弃列族
        get.addColumn(Bytes.toBytes(cf),Bytes.toBytes(cn));

        //2.3设置获取数据的版本数
        //设置的版本数要<=配置的（describe可以查看版本数），超过则显示已配置的
        get.setMaxVersions(5);

        //3.获取数据
        Result result = table.get(get);

        //4.解析result并打印
        for (Cell cell : result.rawCells()) {
            //5.打印数据
            System.out.println("CF:" + Bytes.toString(CellUtil.cloneFamily(cell)) +
                    ",CN:" + Bytes.toString(CellUtil.cloneQualifier(cell)) +
                    ",Value:" + Bytes.toString(CellUtil.cloneValue(cell)));
        }

        //6.关闭表连接
        table.close();
    }

2.3获取数据（scan）

    //7.获取数据（scan）
    public static void scanTable(String tableName) throws IOException {
        //1.获取表对象
        Table table = connection.getTable(TableName.valueOf(tableName));

        //2.创建scan对象
//        //无参数扫描全表
//        Scan scan = new Scan();
        //有参数会过滤,左闭右开
        Scan scan = new Scan(Bytes.toBytes("1001"),Bytes.toBytes("1003"));

        //3.扫描表
        ResultScanner resultScanner = table.getScanner(scan);

        //4.解析resultScanner
        for (Result result : resultScanner) {
            //解析result并打印
            for (Cell cell : result.rawCells()) {
                //6.打印数据
                System.out.println("RK:" + Bytes.toString(CellUtil.cloneRow(cell)) + "CF:" + Bytes.toString(CellUtil.cloneFamily(cell)) +
                        ",CN:" + Bytes.toString(CellUtil.cloneQualifier(cell)) +
                        ",Value:" + Bytes.toString(CellUtil.cloneValue(cell)));
            }
        }

        //7.关闭连接
        close();
    }

2.4删除数据

    //8.删除数据
    public static void deleteData(String tableName,String rowKey,String cf,String cn) throws IOException {
        //1.获取表对象
        Table table = connection.getTable(TableName.valueOf(tableName));

        //2.创建删除对象
        //只传rowKey的时候相当于deleteall
        Delete delete = new Delete(Bytes.toBytes(rowKey));

//        //2.1设置删除的列
//        //尽量不用addColumn
//        //可以再加时间戳参数
//        delete.addColumns(Bytes.toBytes(cf),Bytes.toBytes(cn));

        //2.2设置删除的列族
        delete.addFamily(Bytes.toBytes(cf));

        //3.执行删除操作
        table.delete(delete);

        //4.关闭连接
        close();
    }

3.完整代码

package com.atguigu.test;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;

/**
 * DDL:
 * 1.判断表是否存在
 * 2.创建表
 * 3.创建命名空间
 * 4.删除表
 * ---
 * DML:
 * 5.插入数据
 * 6.查数据（get）
 * 7.查数据（scan）
 * 8.删除数据
 */
public class TestAPI {
    private static Connection connection = null;
    private static Admin admin = null;

    //静态代码块先执行
    static {
        try {
            //1.获取配置文件信息
            Configuration configuration = HBaseConfiguration.create();
            configuration.set("hbase.zookeeper.quorum","hadoop102,hadoop103,hadoop104");

            //2.创建连接对象
            connection = ConnectionFactory.createConnection(configuration);

            //3.创建Admin对象

            admin = connection.getAdmin();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    //1.判断表是否存在
    public static boolean isTableExist(String tableName) throws IOException {
//        //1.获取配置文件信息
//        //过时的
//        //HBaseConfiguration configuration = new HBaseConfiguration();
//        Configuration configuration = HBaseConfiguration.create();
//        configuration.set("hbase.zookeeper.quorum","hadoop102,hadoop103,hadoop104");
//
//        //2.获取管理员对象
//        //过时的
//        //HBaseAdmin admin = new HBaseAdmin(configuration);
//        Connection connection = ConnectionFactory.createConnection(configuration);
//        Admin admin = connection.getAdmin();

        //3.判断表是否存在
        boolean exists = admin.tableExists(TableName.valueOf(tableName));

//        //4.关闭连接
//        admin.close();

        //5.返回结果
        return  exists;
    }

    //2.创建表
    public static void createTable(String tableName,String... cfs) throws IOException {
        //1.判断是否存在列族信息
        if(cfs.length <= 0){
            System.out.println("设置列族信息");
            return;
        }

        //2.判断表是否存在
        if(isTableExist(tableName)){
            System.out.println(tableName + "表已存在");
            return;
        }

        //3.创建表描述器
        HTableDescriptor hTableDescriptor = new HTableDescriptor(TableName.valueOf(tableName));

        //4.循环添加列族信息
        for (String cf : cfs) {
            //5.创建列族描述器
            HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(cf);

            //6.添加具体列族信息
            hTableDescriptor.addFamily(hColumnDescriptor);
        }

        //创建表
        admin.createTable(hTableDescriptor);
    }

    //3.删除表
    public static void dropTable(String tableName) throws IOException {
        //1.判断表是否存在
        if(!isTableExist(tableName)){
            System.out.println(tableName + "表不存在");
            return;
        }

        //2.使表下线
        admin.disableTable(TableName.valueOf(tableName));

        //3.删除表
        admin.deleteTable(TableName.valueOf(tableName));
    }

    //4.创建命名空间
    public static void createNameSpace(String ns){
        //1.创建命名空间描述器
        NamespaceDescriptor namespaceDescriptor = NamespaceDescriptor.create(ns).build();

        //2.创建命名空间
        //官方没有提供命名空间是否存在的方式
        try {
            admin.createNamespace(namespaceDescriptor);
        } catch (NamespaceExistException e) {
            System.out.println("命名空间已存在");
        } catch (IOException e) {
            e.printStackTrace();
        }

        //后面可以继续执行
        //若命名空间存在，在提示命名空间存在后执行其他任务
        System.out.println("继续执行");
    }

    //5.向表插入数据
    public static void putData(String tableName,String rowKey,String cf,String cn,String value) throws IOException {
        //1.获取表对象
        Table table = connection.getTable(TableName.valueOf(tableName));

        //2.创建Put对象
        Put put = new Put(Bytes.toBytes(rowKey));

        //3.给Put对象赋值
        put.addColumn(Bytes.toBytes(cf),Bytes.toBytes(cn),Bytes.toBytes(value));

        //4.插入数据
        table.put(put);

        //5.关闭表连接
        table.close();
    }

    //6.获取数据（get）
    public static void getData(String tableName,String rowKey,String cf,String cn) throws IOException {
        //1.获取表对象
        Table table = connection.getTable(TableName.valueOf(tableName));

        //2.创建Get对象
        //这里只有rowKey，因此列族、列任意填其他的也没事
        Get get = new Get(Bytes.toBytes(rowKey));

//        //2.1指定获取的列族
//        get.addFamily(Bytes.toBytes(cf));

        //2.2指定列族和列
        //写列不能抛弃列族
        get.addColumn(Bytes.toBytes(cf),Bytes.toBytes(cn));

        //2.3设置获取数据的版本数
        //设置的版本数要<=配置的（describe可以查看版本数），超过则显示已配置的
        get.setMaxVersions(5);

        //3.获取数据
        Result result = table.get(get);

        //4.解析result并打印
        for (Cell cell : result.rawCells()) {
            //5.打印数据
            System.out.println("CF:" + Bytes.toString(CellUtil.cloneFamily(cell)) +
                    ",CN:" + Bytes.toString(CellUtil.cloneQualifier(cell)) +
                    ",Value:" + Bytes.toString(CellUtil.cloneValue(cell)));
        }

        //6.关闭表连接
        table.close();
    }

    //7.获取数据（scan）
    public static void scanTable(String tableName) throws IOException {
        //1.获取表对象
        Table table = connection.getTable(TableName.valueOf(tableName));

        //2.创建scan对象
//        //无参数扫描全表
//        Scan scan = new Scan();
        //有参数会过滤,左闭右开
        Scan scan = new Scan(Bytes.toBytes("1001"),Bytes.toBytes("1003"));

        //3.扫描表
        ResultScanner resultScanner = table.getScanner(scan);

        //4.解析resultScanner
        for (Result result : resultScanner) {
            //解析result并打印
            for (Cell cell : result.rawCells()) {
                //6.打印数据
                System.out.println("RK:" + Bytes.toString(CellUtil.cloneRow(cell)) + "CF:" + Bytes.toString(CellUtil.cloneFamily(cell)) +
                        ",CN:" + Bytes.toString(CellUtil.cloneQualifier(cell)) +
                        ",Value:" + Bytes.toString(CellUtil.cloneValue(cell)));
            }
        }

        //7.关闭连接
        close();
    }

    //8.删除数据
    public static void deleteData(String tableName,String rowKey,String cf,String cn) throws IOException {
        //1.获取表对象
        Table table = connection.getTable(TableName.valueOf(tableName));

        //2.创建删除对象
        //只传rowKey的时候相当于deleteall
        Delete delete = new Delete(Bytes.toBytes(rowKey));

//        //2.1设置删除的列
//        //尽量不用addColumn
//        //可以再加时间戳参数
//        delete.addColumns(Bytes.toBytes(cf),Bytes.toBytes(cn));

        //2.2设置删除的列族
        delete.addFamily(Bytes.toBytes(cf));

        //3.执行删除操作
        table.delete(delete);

        //4.关闭连接
        close();
    }

    public static void close(){
        if(admin!=null){
            try {
                admin.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
        if(connection!=null){
            try {
                connection.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }

    public static void main(String[] args) throws IOException {
//        //1.判断表是否存在
//        System.out.println(isTableExist("stu5"));
//
//        //2.创建表测试
//        createTable("stu5","info1","info2");
//        System.out.println(isTableExist("stu5"));
//
//        //3.删除表测试
//        dropTable("stu5");
//        System.out.println(isTableExist("stu5"));
//
//        //4.创建命名空间测试
//        createNameSpace("0408");

//        //5.创建数据测试
//        putData("stu","1001","info2","name","zhangsan");

//        //6.获取单行数据
//        getData("stu2","1001","info","name");

//        //7.测试扫描数据
//        scanTable("stu");

        //8.测试删除
        deleteData("stu","1006","info1","name");

        //关闭资源
        close();
    }
}