HBase常用的JAVA API操作
程序员文章站
2022-08-19 21:35:46
为了方便以后查看,总结了一些常用的java操作hbase的代码: ......
为了方便以后查看,总结了一些常用的java操作hbase的代码:
package com.mcq;
import static org.hamcrest.corematchers.describedas;
import static org.hamcrest.corematchers.nullvalue;
import java.io.ioexception;
import java.io.pushbackinputstream;
import org.apache.hadoop.conf.configuration;
import org.apache.hadoop.hbase.cell;
import org.apache.hadoop.hbase.cellscannable;
import org.apache.hadoop.hbase.cellutil;
import org.apache.hadoop.hbase.hbaseconfiguration;
import org.apache.hadoop.hbase.hcolumndescriptor;
import org.apache.hadoop.hbase.htabledescriptor;
import org.apache.hadoop.hbase.tablename;
import org.apache.hadoop.hbase.client.admin;
import org.apache.hadoop.hbase.client.connection;
import org.apache.hadoop.hbase.client.connectionfactory;
import org.apache.hadoop.hbase.client.delete;
import org.apache.hadoop.hbase.client.get;
import org.apache.hadoop.hbase.client.htable;
import org.apache.hadoop.hbase.client.put;
import org.apache.hadoop.hbase.client.result;
import org.apache.hadoop.hbase.client.resultscanner;
import org.apache.hadoop.hbase.client.scan;
import org.apache.hadoop.hbase.client.table;
import org.apache.hadoop.hbase.util.bytes;
public class testhbase {
private static admin admin = null;
private static connection connection = null;
private static configuration conf = null;
static {
// hbase配置文件
conf = hbaseconfiguration.create();
conf.set("hbase.zookeeper.quorum", "192.168.1.103");
// 获取连接对象
try {
connection = connectionfactory.createconnection(conf);
// 获取hbase管理员对象
admin = connection.getadmin();
} catch (ioexception e) {
// todo auto-generated catch block
e.printstacktrace();
}
}
private static void close(connection conn, admin admin) throws ioexception {
if (conn != null) {
conn.close();
}
if (admin != null) {
admin.close();
}
}
// 判断表是否存在
public static boolean tableexist(string tablename) throws ioexception {
boolean tableexists = admin.tableexists(tablename.valueof(tablename));
return tableexists;
}
// 创建表
public static void createtable(string tablename, string... cfs) throws ioexception {
if (tableexist(tablename)) {
system.out.println("表已存在");
return;
}
// cfs是列族,官方建议一个表一个,但可以有多个
// 创建表描述器
htabledescriptor htabledescriptor = new htabledescriptor(tablename.valueof(tablename));
for (string cf : cfs) {
// 创建列描述器
hcolumndescriptor hcolumndescriptor = new hcolumndescriptor(cf);
// hcolumndescriptor.setmaxversions(3);//设置版本数
htabledescriptor.addfamily(hcolumndescriptor);
}
// 创建表操作
admin.createtable(htabledescriptor);
}
// 删除表
public static void deletetable(string tablename) throws ioexception {
if (!tableexist(tablename)) {
system.out.println("表不存在");
return;
}
// 使表不可用(下线)
admin.disabletable(tablename.valueof(tablename));
// 执行删除操作
admin.deletetable(tablename.valueof(tablename));
system.out.println("表已删除");
}
// 增、改
public static void putdata(string tablename, string rowkey, string cf, string cn, string value) throws ioexception {
// 获取表对象
// htable table=new htable(conf,tablename.valueof(tablename)); 已过时
table table = connection.gettable(tablename.valueof(tablename));
// 创建put对象
put put = new put(bytes.tobytes(rowkey));
// 添加数据
put.addcolumn(bytes.tobytes(cf), bytes.tobytes(cn), bytes.tobytes(value));
// 执行添加操作
table.put(put);
}
// 删
public static void delete(string tablename, string rowkey, string cf, string cn) throws ioexception {
// 获取table对象
table table = connection.gettable(tablename.valueof(tablename));
// 创建delete对象
delete delete = new delete(bytes.tobytes(rowkey));// 删除整个列族
delete.addcolumns(bytes.tobytes(cf), bytes.tobytes(cn));// 删除所有版本
// delete.addcolumn(bytes.tobytes(cf), bytes.tobytes(cn));不推荐,只删除最新的版本
// 执行删除操作
table.delete(delete);
table.close();
}
// 查——全表扫描,只能获取最新版本
public static void scantable(string tablename) throws ioexception {
// 获取table对象
table table = connection.gettable(tablename.valueof(tablename));
// 构建扫描器
scan scan = new scan();
resultscanner resultscanner = table.getscanner(scan);
// 遍历数据并打印
for (result result : resultscanner) { // rowkey
cell[] cells = result.rawcells();
for (cell cell : cells) { // cell
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)));
}
}
table.close();
}
// 查——获取指定列族
public static void getdata(string tablename, string rowkey, string cf, string cn) throws ioexception {
table table = connection.gettable(tablename.valueof(tablename));
get get = new get(bytes.tobytes(rowkey));
get.addcolumn(bytes.tobytes(cf), bytes.tobytes(cn));
// get.addfamily(cf);
// get.setmaxversions();//不传参默认是表结构内的maxversions
get.setmaxversions(2);
result result = table.get(get);
cell[] cells = result.rawcells();
for (cell cell : cells) { // cell
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)));
}
}
public static void main(string[] args) throws ioexception {
// 判断表是否存在
// system.out.println(tableexist("student"));
// system.out.println(tableexist("staff"));
// 创建表
// createtable("staff", "info");
// system.out.println(tableexist("staff"));
// 删除表
// deletetable("staff");
// 增、改
// putdata("student", "1001", "info", "name", "mcq");
// 删
// delete("student", "1001", "info", "name");
// 查——全表扫描
// scantable("student");
//查——获取指定列族
getdata("student", "1001","info","name");
// 关闭资源
close(connection, admin);
}
}
推荐阅读
-
python使用phoenixdb操作hbase的方法示例
-
PHP开发中常用的字符串操作函数
-
HBase 系列(六)——HBase Java API 的基本使用
-
Java日期时间API系列5-----Jdk7及以前的日期时间类TimeUnit在并发编程中的应用
-
Java日期时间API系列12-----Jdk8中java.time包中的新的日期时间API类,日期格式化,常用日期格式大全
-
微信小程序异步API为Promise简化异步编程的操作方法
-
C#中一些字符串操作的常用用法
-
Linux中RPM文件操作的常用命令总结
-
Java开发中对Redis的基本操作
-
Java日期时间API系列8-----Jdk8中java.time包中的新的日期时间API类的LocalDate源码分析