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"的值 -> 全表扫描
运行结果：
