HBase Java API 使用详解

落日映苍穹つ 2022-12-20 05:38 123阅读 0赞

HBase 主要包括 5 大类操作：HBase 的配置、HBase 表的管理、列族的管理、列的管理、数据操作等。

本节将从scan、put、get、delete操作HBase讲解HBase Java API。

第一步：将hbase中的hbase-site.xml拷贝到IDEA工具中。

第二步：添加pom文件，内容如下：

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

第三步：编写代码

package com.kfk.hbase;
    
    /** * @author : 蔡政洁 * @email :caizhengjie888@icloud.com * @date : 2020/11/10 * @time : 3:31 下午 */
    public class HBaseConstant { 
        public static String HBASE_TABLE = "stu";
        public static String HBASE_CF_INFO = "info";
    }

package com.kfk.hbase;
    
    import org.apache.hadoop.hbase.Cell;
    import org.apache.hadoop.hbase.CellScanner;
    import org.apache.hadoop.hbase.CellUtil;
    import org.apache.hadoop.hbase.TableName;
    import org.apache.hadoop.hbase.client.*;
    import org.apache.hadoop.hbase.filter.Filter;
    import org.apache.hadoop.hbase.filter.PrefixFilter;
    import org.apache.hadoop.hbase.util.Bytes;
    
    import java.io.IOException;
    import java.util.HashMap;
    import java.util.Map;
    
    /** * @author : 蔡政洁 * @email :caizhengjie888@icloud.com * @date : 2020/11/10 * @time : 11:09 上午 */
    public class HBaseAPP { 
    
        public static Table getTable(String str){ 
            Table table = null;
            try { 
                // 创建一个链接
                Connection connection = ConnectionFactory.createConnection();
                // 获取数据表
                table = connection.getTable(TableName.valueOf(str));
            } catch (Exception e){ 
                e.printStackTrace();
            }
            return table;
    
        }
    
        /** * 根据rowkey获取数据 * @param tablename * @param rowkey */
        public static void getDataRow(String tablename,String rowkey){ 
    
            Table table = null;
            try { 
                table = getTable(tablename);
                // get 'stu','001'
                Get get = new Get(Bytes.toBytes(rowkey));
                Result result = table.get(get);
    
                // 返回每一列的全集
                CellScanner cellScanner = result.cellScanner();
                // 获取每一列数据的信息
                while (cellScanner.advance()){ 
                    Cell cell = cellScanner.current();
    
                    System.out.println("rowkey="+Bytes.toString(CellUtil.cloneRow(cell)) // rowkey
                            + " " +Bytes.toString(CellUtil.cloneFamily(cell)) // 列簇名
                            + ":" +Bytes.toString(CellUtil.cloneQualifier(cell)) // 列名
                            + "=" +Bytes.toString(CellUtil.cloneValue(cell)) // 列值
                    );
                }
    
                // 获取每一列数据的信息(写法二)
                for (Cell cell:result.rawCells()){ 
                    System.out.println("rowkey="+Bytes.toString(CellUtil.cloneRow(cell)) // rowkey
                            + " " +Bytes.toString(CellUtil.cloneFamily(cell)) // 列簇名
                            + ":" +Bytes.toString(CellUtil.cloneQualifier(cell)) // 列名
                            + "=" +Bytes.toString(CellUtil.cloneValue(cell)) // 列值
                    );
                }
    
            } catch (Exception e){ 
                e.printStackTrace();
            } finally { 
                if (table != null){ 
                    try { 
                        table.close();
                    } catch (IOException e) { 
                        e.printStackTrace();
                    }
                }
            }
        }
    
        /** * HBase写入数据 * @param tablename * @param rowkey * @param value */
        public static void putData(String tablename,String rowkey,Map<String,Object> value){ 
            Table table = getTable(tablename);
    
            // put 'stu','002','info:username','ben'
            Put put = new Put(Bytes.toBytes(rowkey));
            for (String key: value.keySet()){ 
                put.addColumn(Bytes.toBytes(HBaseConstant.HBASE_CF_INFO), // 列簇名
                        Bytes.toBytes(key), // 列名
                        Bytes.toBytes(value.get(key).toString())); // 列值
            }
            try { 
                table.put(put);
            } catch (Exception e){ 
                e.printStackTrace();
            }
        }
    
        /** * HBase删除数据 * @param tablename * @param rowkey */
        public static void deleteData(String tablename,String rowkey){ 
            Table table = getTable(tablename);
    
            // delete 'stu','002','info:addres'
            Delete delete = new Delete(Bytes.toBytes(rowkey));
            delete.addColumn(Bytes.toBytes(HBaseConstant.HBASE_CF_INFO),Bytes.toBytes("addres"));
    
            try { 
                table.delete(delete);
            } catch (Exception e){ 
                e.printStackTrace();
            }
        }
    
        /** * HBase扫描数据 * @param tablename */
        public static void getScanData(String tablename){ 
            Table table = getTable(tablename);
    
            Scan scan = new Scan();
    
            //scan.setStartRow() : scan.setStopRow()
            //file过滤，前置匹配
            Filter filter = new PrefixFilter(Bytes.toBytes("001"));
            scan.setFilter(filter);
            //分页 new PageFilter();
    
            ResultScanner resultScanner = null;
            try { 
                resultScanner = table.getScanner(scan);
                // 获取每一行的数据
                for (Result result : resultScanner){ 
                    // 获取每一行中每一列数据的信息
                    for (Cell cell:result.rawCells()){ 
                        System.out.println("rowkey="+Bytes.toString(CellUtil.cloneRow(cell)) // rowkey
                                + " " +Bytes.toString(CellUtil.cloneFamily(cell)) // 列簇名
                                + ":" +Bytes.toString(CellUtil.cloneQualifier(cell)) // 列名
                                + "=" +Bytes.toString(CellUtil.cloneValue(cell)) // 列值
                        );
                    }
                }
    
            } catch (IOException e) { 
                e.printStackTrace();
            }
        }
    
        public static void main(String[] args) { 
    
            // 要写入HBase的数据
            Map<String,Object> map = new HashMap<String, Object>();
            map.put("addres","beijing");
            map.put("age","32");
            map.put("username","jack");
    
            // 根据rowkey获取数据
            getDataRow(HBaseConstant.HBASE_TABLE,"001");
            // HBase写入数据
            putData(HBaseConstant.HBASE_TABLE,"003",map);
            // HBase删除数据
            deleteData(HBaseConstant.HBASE_TABLE,"002");
            // HBase扫描数据
            getScanData(HBaseConstant.HBASE_TABLE);
    
        }
    }

运行流程：

获取rowkey为001的数据 -> 将rowkey为003的数据写入到HBase -> 删除rowkey为002的"addres"的值 -> 全表扫描

运行结果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTM2NjQ5OQ_size_16_color_FFFFFF_t_70_pic_center]

--------------------

以上内容仅供参考学习，如有侵权请联系我删除！  
如果这篇文章对您有帮助，左下角的大拇指就是对博主最大的鼓励。  
您的鼓励就是博主最大的动力！

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80NTM2NjQ5OQ_size_16_color_FFFFFF_t_70_pic_center]: /images/20221120/cc7f617a97f344388c72516bf2175474.png