HBase入门系列(5)- HBase之JavaAPI操作详解

末蓝、 2023-10-10 12:27 22阅读 0赞

### 前言 ###

HBase 除了支持使用 Shell 客户端来操作，还提供了多种编程语言的接口，其中 Java API 是原生支持的，其它编程语言接口需要通过 Thrift 协议支持。

HBase 官方代码包里含有原生访问客户端，由 Java 语言实现，相关的类在 org.apache.hadoop.hbase.client 包中，都是与 HBase 数据存储管理相关的 API。

例如，若要管理 HBase，则用 Admin 接口来创建、删除、更改表；若要向表格添加数据或查询数据，则使用 Table 接口等。

### 环境配置 ###

1.  创建一个spring boot基础模块
2.  pom添加相关依赖

<dependencies>
            
            <dependency>
                <groupId>org.apache.hbase</groupId>
                <artifactId>hbase-server</artifactId>
                <version>1.6.0</version>
            </dependency>
            <dependency>
                <groupId>org.apache.hbase</groupId>
                <artifactId>hbase-client</artifactId>
                <version>1.6.0</version>
            </dependency>
        </dependencies>

1.  创建Java 客户端

public class TestHBase {
        
        public static Configuration conf;
        public static Connection connection;
    
        /**
         * 在分布式环境下，客户端访问 HBase 需要通过 ZooKeeper 的地址和端口来获取当前活跃的 Master 和所需的 RegionServer 地址。
         * 因此需要先用 HBaseCongifiguration 类配置 ZooKeeper 的地址和端口，然后再使用 Connection 类建立连接。
         * @throws IOException
         */
        public void getConnect() throws IOException {
        
            conf = HBaseConfiguration.create();
            conf.set("hbase.zookeeper.quorum", "hadoop001");
            conf.set("hbase.zookeeper.property.clientPort", "2181");
            try {
        
                connection = ConnectionFactory.createConnection(conf);
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
        static {
        
            try {
        
                getConnect();
            } catch (IOException e) {
        
                e.printStackTrace();
            }
        }
    }

### 表操作 ###

1.  查看表是否存在

/**
         * 查看表是否存在
         *
         * @param tableName
         * @return
         * @throws Exception
         */
        public static boolean tableExists(String tableName) throws Exception {
        
            TableName tn = TableName.valueOf(tableName);
            Admin admin = connection.getAdmin();
            boolean tableExists = admin.tableExists(tn);
            admin.close();
            return tableExists;
        }

1.  创建表

/**
         * 创建表
         * @param tableName
         * @param columnFamily
         * @throws Exception
         */
        public static void createTable(String tableName, String... columnFamily) throws Exception {
        
            if (tableExists(tableName)) {
        
                System.out.println("此表已存在：" + tableName);
            } else {
        
                TableName tn = TableName.valueOf(tableName);
                Admin admin = connection.getAdmin();
                // 添加数据库名
                HTableDescriptor descriptor=new HTableDescriptor(tn);
                // 添加列族
                for (String col : columnFamily) {
        
                    HColumnDescriptor hColumnDescriptor=new HColumnDescriptor(col);
                    descriptor.addFamily(hColumnDescriptor);
                }
                //创建
                admin.createTable(descriptor);
                admin.close();
            }
        }

1.  删除表

/**
         * 删除表
         * @param tableName
         * @throws Exception
         */
        public static void dropTable(String tableName) throws Exception {
        
            if (!tableExists(tableName)) {
        
                System.out.println("此表不存在，无需删除：" + tableName);
            } else {
        
                TableName tn = TableName.valueOf(tableName);
                Admin admin = connection.getAdmin();
                admin.disableTable(tn);
                admin.deleteTable(tn);
                System.out.println("成功删除表："+tableName);
                admin.close();
            }
        }

### 数据操作 ###

1.  插入数据

/**
         * 插入数据
         *
         * @param tableName 表名
         * @param rowKey 行键
         * @param columnFamily 列族
         * @param columnName 列名
         * @param value 列值
         * @throws Exception
         */
        public static void put(String tableName, String rowKey, String columnFamily, String columnName, String value) throws Exception {
        
            if (!tableExists(tableName)) {
        
                System.out.println("此表不存在，无法插入：" + tableName);
            } else {
        
                TableName tn = TableName.valueOf(tableName);
                Table table = connection.getTable(tn);
                Put put = new Put(rowKey.getBytes());
                put.addColumn(columnFamily.getBytes(), columnName.getBytes(), value.getBytes());
                table.put(put);
                table.close();
                System.out.println("插入数据成功");
            }
        }

1.  删除多行数据

/**
         * 删除多行数据
         * @param tableName 表名
         * @param rows 行键
         * @throws Exception
         */
        public static void deleteRows(String tableName, String... rows) throws Exception {
        
            if (!tableExists(tableName)) {
        
                System.out.println("此表不存在，无法删除数据：" + tableName);
            } else {
        
                TableName tn = TableName.valueOf(tableName);
                Table table = connection.getTable(tn);
                // 构建删除集合
                List<Delete> list = new ArrayList<>();
                for (String row : rows) {
        
                    Delete delete = new Delete(row.getBytes());
                    list.add(delete);
                }
                // 删除
                table.delete(list);
                System.out.println("删除数据成功");
                table.close();
            }
        }

1.  查询单条数据

/**
         * 查询单条数据
         *
         * @param tableName 表名
         * @param roeKey 行键
         * @throws Exception
         */
        public static void getRow(String tableName, String roeKey) throws Exception {
        
            if (!tableExists(tableName)) {
        
                System.out.println("此表不存在，无法查询数据：" + tableName);
            } else {
        
                TableName tn = TableName.valueOf(tableName);
                Table table = connection.getTable(tn);
                // 查询对象
                Get get = new Get(roeKey.getBytes());
                Result result = table.get(get);
                // 打印结果集
                Cell[] cells = result.rawCells();
                for (Cell cell : cells) {
        
                    System.out.println("行键：" + new String(CellUtil.cloneRow(cell)));
                    System.out.println("列族：" + new String(CellUtil.cloneFamily(cell)));
                    System.out.println("列名：" + new String(CellUtil.cloneQualifier(cell)));
                    System.out.println("值：" + new String(CellUtil.cloneValue(cell)));
                    System.out.println("时间戳:" + cell.getTimestamp());
                }
                table.close();
            }
        }

1.  查询全表数据

/**
         *  查询全表数据
          * @param tableName 表名
         * @throws Exception
         */ 
        public static void scanAll(String tableName) throws Exception {
        
            if (!tableExists(tableName)) {
        
                System.out.println("此表不存在，无法查询所有数据：" + tableName);
            } else {
        
                TableName tn = TableName.valueOf(tableName);
                Table table = connection.getTable(tn);
                Scan scan = new Scan();
                ResultScanner resultScanner = table.getScanner(scan);
                for (Result result : resultScanner) {
        
                    // 打印结果集
                    Cell[] cells = result.rawCells();
                    for (Cell cell : cells) {
        
                        System.out.println("行键：" + new String(CellUtil.cloneRow(cell)));
                        System.out.println("列族：" + new String(CellUtil.cloneFamily(cell)));
                        System.out.println("列名：" + new String(CellUtil.cloneQualifier(cell)));
                        System.out.println("值：" + new String(CellUtil.cloneValue(cell)));
                        System.out.println("时间戳:" + cell.getTimestamp());
                    }
                }
                table.close();
            }
        }

1.  获取某一行指定“列族:列”的数据

/**
         * 获取某一行指定“列族:列”的数据
         * @param tableName 表名
         * @param roeKey 行键
         * @param columnFamily 列族
         * @param columnName 列名
         * @throws Exception
         */
        public static void getValue(String tableName, String roeKey, String columnFamily, String columnName) throws Exception {
        
            if (!tableExists(tableName)) {
        
                System.out.println("此表不存在，无法查询数据：" + tableName);
            } else {
        
                TableName tn = TableName.valueOf(tableName);
                Table table = connection.getTable(tn);
                // 查询对象
                Get get = new Get(roeKey.getBytes());
                get.addColumn(Bytes.toBytes(columnFamily),Bytes.toBytes(columnName));
                Result result = table.get(get);
                // 打印结果集
                Cell[] cells = result.rawCells();
                for (Cell cell : cells) {
        
                    System.out.println("行键：" + new String(CellUtil.cloneRow(cell)));
                    System.out.println("列族：" + new String(CellUtil.cloneFamily(cell)));
                    System.out.println("列名：" + new String(CellUtil.cloneQualifier(cell)));
                    System.out.println("值：" + new String(CellUtil.cloneValue(cell)));
                    System.out.println("时间戳:" + cell.getTimestamp());
                }
                table.close();
            }
        }