小记--------hbase数据库java API 常用方法及案例

Love The Way You Lie 2023-09-25 11:45 24阅读 0赞

HBaseAdmin类：管理hbase数据库的表信息，‘创建表、删除表、列出表选项、使表有效/无效、添加或删除列簇’；

![c47bb723bebdae607bfd4c9a6c740a7f.png][]

Eg：

//使用工厂模式创建connection

val conn: Connection= ConnectionFactory.createConnection(config)

//实例化hbase的管理者实例

val admin: Admin= conn.getAdmin

//删除表

admin.deleteTable(TableName.valueOf("t1"))

HbaseConfiguration类继承自Configuration类：将hbase配置文件添加到配置中

![0f231c92cf18264e45c65247eccac14a.png][]

//配置hbase资源配置

val config: Configuration=HBaseConfiguration.create()

config.set("hbase.zookeeper.quorum" , "df1:2181,df2:2181,df3:2181")

config.set("hbase.master" , "df1:60000")

config.set("hbase.zookeeper.property.clientPort" , "2181")

Table类：用于和hbase表直接通信；

在0.94版本之后就不推荐使用

val HTable=new HTable(conf, Bytes.toBytes(tablename))

而是使用

val table=Connection.getTable(TableName.valueOf(“driver\_info”))

![e8068fa3b81a5a307ec40a2bcfea23df.png][]

Eg：

def tableoperation(): Unit = \{

//获取表的实例

val tab=conn.getTable(TableName.valueOf("citycode"))

//查看rowkey的值为99手否在表中存在

val q: Boolean=tab.exists(new Get(Bytes.toBytes("99")))

//检查row/family/qualifier是否与数据库匹配。如果是，则提交put操作到服务端

val sss=tab.checkAndPut(Bytes.toBytes("99") , Bytes.toBytes("MM") , Bytes.toBytes("citycode") , Bytes.toBytes("3213") , put())

//释放所有资源或挂起内部缓冲区的更新

tab.close()

// 获取rowkey的列族MM的列名id的value值

val get=new Get(Bytes.toBytes("rowKey"))

val result: Result =tab.get(get)

val bytes =result.getValue(Bytes.toBytes("MM"),Bytes.toBytes("id"))

println(Bytes.toString(bytes))

//获取MM的scanner实例

val scanner:ResultScanner=tab.getScanner(Bytes.toBytes("MM"))

// 获取该表的HTableDescriptor实例

val tableDescriptor: HTableDescriptor= tab.getTableDescriptor()

//将put实例中的数据放入表中

tab.put(put())

HTableDescriptor类：hbase表的详细信息

![d0e9257f2b13bb53738657f7f4235329.png][]

Eg:

//创建HTableDescriptor table表描述

val tabledescriptor=new HTableDescriptor(TableName.valueOf("order\_info"))

//给表添加列簇

tabledescriptor.addFamily(new HColumnDescriptor("CC"))

//删除CC 列簇

tabledescriptor.removeFamily(Bytes.toBytes("CC"))

//获取表名

val tablename= tabledescriptor.getTableName

HColumnDescriptor类：列簇描述

![4d6a93887f2bfb498e857cb3d8fb2f48.png][]

Eg：

val columndescriptor =new HColumnDescriptor(Bytes.toBytes("MM"))

val columnName = columndescriptor.getName()

val c =columndescriptor.getValue("id")

Put类：对单行执行put操作

![a9f5b8d8ddba63c83a4c4de4d716e982.png][]

Eg：

val put =new Put(Bytes.toBytes("rowkey"))

//添加列id和值123 到MM列簇

put.addColumn(Bytes.toBytes("MM"),Bytes.toBytes("id"),Bytes.toBytes("123"))

val rowname = put.getRow()

val time = put.getTimeStamp()

val s:Boolean =put.isEmpty()

Get类：用于对单行执行get操作

![d5923b226951e3fe3e3f0626646e1759.png][]

Scan类：用于执行扫描操作；通过不同的构造方法扫描整张表、整个列簇、整个列、一段时间戳范围内的数据

Eg：

val table: Table =conn.getTable(TableName.valueOf("driver\_info"))

// scan 全表

val scan=new Scan()

//给scan加条件获取列簇MM中的列id

scan.addColumn(Bytes.toBytes("MM"),Bytes.toBytes("id"))

//获取列簇MM中所有的列

scan.addFamily(Bytes.toBytes("MM"))

// 获取时间戳在11111-22222之间的所有数据

scan.setTimeRange(11111,22222)

//scan从rowkey20190101 开始到结束

val scan1=new Scan(Bytes.toBytes("20190101"))

//scan从rowkey20190101开始到20200101结束

val scan2=new Scan(Bytes.toBytes("20190101"),Bytes.toBytes("20200101"))

//通过扫描器scan控制查询到的结果

val rs: ResultScanner=table.getScanner(scan)

Filter配合Scan工作

//1.实例化filter RowFilter 按行过滤 行键小于等于20190101的所有数据

//CompareFilter.CompareOp.LESS\_OR\_EQUAL 比较符 LESS\_OR\_EQUAL 小于等于、LESS小于、EQUAL等于、NOT\_EQUAL不等于、GREATER\_OR\_EQUAL大于等于、GREATER大于、NO\_OP 无操作

val rowfilter=new RowFilter(CompareFilter.CompareOp.LESS\_OR\_EQUAL,new BinaryComparator(Bytes.toBytes( "20190101")))

//实例化scan

val scan4=new Scan()

//添加 行过滤器

scan.setFilter(rowfilter)

// 获取数据

val scanner: ResultScanner= table.getScanner(scan4)

import scala.collection.JavaConverters.\_

//遍历数据

for(sca

println(sca)

//2. 实例化 QualifierFilter 扫描出所有的列名为id 的列数据

val liefilter=new QualifierFilter(CompareFilter.CompareOp.EQUAL,new BinaryComparator(Bytes.toBytes("id")))

//3. 实例化FamilyFilter 扫描出所有的列簇为'MM'的列簇数据

val familyfilter=new FamilyFilter(CompareFilter.CompareOp.EQUAL,new BinaryComparator(Bytes.toBytes("MM")))

// 4.扫描出行键前缀为2019 的所有行数据

val prefilter=new PrefixFilter(Bytes.toBytes("2019"))

// 5.只返回每行数据的 行键-列簇-列；不返回值。

// 所以适用于 不需要值的应用场景， 减少值的传递

val keyonlyfilter=new KeyOnlyFilter()

// 6.扫描出所有列的值为100 的 列

val valuefilter=new ValueFilter(CompareFilter.CompareOp.EQUAL, new BinaryComparator(Bytes.toBytes("100")))

[c47bb723bebdae607bfd4c9a6c740a7f.png]: https://img-blog.csdnimg.cn/img_convert/c47bb723bebdae607bfd4c9a6c740a7f.png
[0f231c92cf18264e45c65247eccac14a.png]: https://img-blog.csdnimg.cn/img_convert/0f231c92cf18264e45c65247eccac14a.png
[e8068fa3b81a5a307ec40a2bcfea23df.png]: https://img-blog.csdnimg.cn/img_convert/e8068fa3b81a5a307ec40a2bcfea23df.png
[d0e9257f2b13bb53738657f7f4235329.png]: https://img-blog.csdnimg.cn/img_convert/d0e9257f2b13bb53738657f7f4235329.png
[4d6a93887f2bfb498e857cb3d8fb2f48.png]: https://img-blog.csdnimg.cn/img_convert/4d6a93887f2bfb498e857cb3d8fb2f48.png
[a9f5b8d8ddba63c83a4c4de4d716e982.png]: https://img-blog.csdnimg.cn/img_convert/a9f5b8d8ddba63c83a4c4de4d716e982.png
[d5923b226951e3fe3e3f0626646e1759.png]: https://img-blog.csdnimg.cn/img_convert/d5923b226951e3fe3e3f0626646e1759.png