package com.mzb.hbase;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.;
import org.apache.hadoop.hbase.client.;
import org.apache.hadoop.hbase.util.Bytes;
import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
public class HbaseOperate {
public static void main(String[] args) throws IOException {
listTableNames();
createTable("student","info");
createTable("studentTest","base_info","extra_info");
listTableNames();
System.out.println("-------------------------------------");
deleteTable("studentTest");
listTableNames();
scanTable("student");
System.out.println("-------------------------------------");
System.out.println("插入数据-----------");
putData("student", "1001", "info", "name", "王大锤");
putData("student", "1001", "info", "age", "29");
putData("student", "1001", "info", "class", "一班");
putData("student", "1001", "info", "grade", "三年级");
putData("student", "1002", "info", "name", "李大锯");
putData("student", "1003", "info", "age", "16");
putData("student", "1003", "info", "class", "二班");
scanTable("student");
System.out.println("-------------------------------------");
System.out.println("获取rowKey为1001的学生数据--------");
getRowData("student", "1001");
System.out.println("-------------------------------------");
System.out.println("查询 rowKey为1001的学生的年级------");
getRowColumnData("student", "1001", "info", "grade");
System.out.println("-------------------------------------");
System.out.println("修改数据------------");
putData("student", "1001", "info", "name", "赵大钢");
putData("student", "1003", "info", "age", "10086");
scanTable("student");
System.out.println("-------------------------------------");
System.out.println("删除数据------------");
deleteTable("student", "1003", "1002");
deleteQualifierTable("student", "1001", "info", "age");
scanTable("student");
close(connection, admin);
}
//获取Configuration对象
public static Configuration configuration = null;
public static Connection connection = null;
public static Admin admin = null;
static {
configuration = HBaseConfiguration.create();
configuration.set("hbase.zookeeper.quorum", "hadoop01:2181,hadoop02:2181,hadoop03:2181,hadoop04:2181");
try {
connection = ConnectionFactory.createConnection(configuration);
} catch (IOException e) {
e.printStackTrace();
}
try {
admin = connection.getAdmin();
} catch (IOException e) {
e.printStackTrace();
}
}
//判断表是否存在
public static boolean tableIsExists(String tableName) throws IOException {
boolean isExists = admin.tableExists(TableName.valueOf(tableName));
if (isExists){
// System.out.println("表"+tableName+"存在！");
}else {
System.out.println("表"+tableName+"不存在！");
}
return isExists;
}
//打印所有表名
public static void listTableNames() throws IOException {
TableName[] tableNames = admin.listTableNames();
System.out.println("打印所有表名:");
for (TableName tableName : tableNames) {
System.out.println(tableName.toString());
}
System.out.println();
}
//1、创建表
public static void createTable(String tableName,String... columnFamily) throws IOException {
if (tableIsExists(tableName)){
return;
}
//创建表描述器
HTableDescriptor hTableDescriptor = new HTableDescriptor(TableName.valueOf(tableName));
//添加列簇
for (String s : columnFamily) {
//创建列描述器
HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(s);
// hColumnDescriptor.setVersions()
hTableDescriptor.addFamily(hColumnDescriptor);
}
//创建表
admin.createTable(hTableDescriptor);
System.out.println("表"+tableName+"创建成功！");
}
//2、Put：增加或更新一条数据
public static void putData(String tableName, String rowKey, String columnFamily, String column, String value) throws IOException {
if (tableIsExists(tableName)) {
//获取表对象
Table table = connection.getTable(TableName.valueOf(tableName));
//创建put对象
Put put = new Put(Bytes.toBytes(rowKey));
//添加数据
put.addColumn(Bytes.toBytes(columnFamily), Bytes.toBytes(column), Bytes.toBytes(value));
//执行添加操作
table.put(put);
}
}
//3、删除表
public static void deleteTable(String tableName) throws IOException {
if (tableIsExists(tableName)){
TableName tn = TableName.valueOf(tableName);
//删除表之前要先disable表（下线）
admin.disableTable(tn);
//删除表
admin.deleteTable(tn);
System.out.println("表"+tableName+"已删除！");
}
}
//4、Delete：删除一条数据
public static void deleteQualifierTable(String tableName, String rowKey, String columnFamily, String column) throws IOException {
if (tableIsExists(tableName)){
//获取表对象
Table table = connection.getTable(TableName.valueOf(tableName));
//创建delete对象
Delete delete = new Delete(Bytes.toBytes(rowKey));
//添加数据
delete.addColumn(Bytes.toBytes(columnFamily), Bytes.toBytes(column));
delete.addColumns(Bytes.toBytes(columnFamily), Bytes.toBytes(column));
//执行添加操作
table.delete(delete);
}
}
//5、删除单行或多行数据
public static void deleteTable(String tableName, String... rowKeys) throws IOException {
if (tableIsExists(tableName)){
//获取表对象
Table table = connection.getTable(TableName.valueOf(tableName));
List<Delete> list = new ArrayList<>();
for (String rowKey : rowKeys) {
//创建delete对象
Delete delete = new Delete(Bytes.toBytes(rowKey));
list.add(delete);
}
//执行删除操作
table.delete(list);
}
}
//6、全表扫描
public static void scanTable(String tableName) throws IOException {
if (tableIsExists(tableName)){
//获取表对象
Table table = connection.getTable(TableName.valueOf(tableName));
//得到用于扫描region的对象scan
//Scan： 封装查询信息，很get有一点不同，Scan可以设置Filter
Scan scan = new Scan();
// scan.setStartRow();
// scan.setStopRow();
//使用HTable得到resultcanner实现类的对象
ResultScanner resultScanner = table.getScanner(scan);
for(Result result : resultScanner){
//Cell：封装了Column的所有的信息：Rowkey、column qualifier、value、时间戳
Cell[] cells = result.rawCells();
for(Cell cell : cells){
printRowKeyAndCell(Bytes.toString(result.getRow()), cell);
}
}
}
}
//7、Get：查看 获取指定行
public static void getRowData(String tableName, String rowKey) throws IOException {
if (tableIsExists(tableName)){
//获取表对象
Table table = connection.getTable(TableName.valueOf(tableName));
//创建Get对象
Get get = new Get(Bytes.toBytes(rowKey));
//执行Get操作
Result result = table.get(get);
Cell[] cells = result.rawCells();
for(Cell cell : cells){
printRowKeyAndCell(Bytes.toString(result.getRow()), cell);
}
}
}
//8、获取某行指定的数据，比如指定某个列簇的某个列限定符
public static void getRowColumnData(String tableName, String rowKey, String columnFamily, String column) throws IOException{
if (tableIsExists(tableName)){
//获取表对象
Table table = connection.getTable(TableName.valueOf(tableName));
Get get = new Get(Bytes.toBytes(rowKey));
get.addColumn(Bytes.toBytes(columnFamily), Bytes.toBytes(column));
Result result = table.get(get);
//循环获取所有信息,也可以单独打印自己需要的字段即可，这个一般根据业务需求修改。
Cell[] cells = result.rawCells();
for(Cell cell : cells){
printRowKeyAndCell(Bytes.toString(result.getRow()), cell);
}
}
}
public static void printRowKeyAndCell(String rowKey, Cell cell){
System.out.println("RK: " + rowKey
+ " CF: " + Bytes.toString(CellUtil.cloneFamily(cell))
+ " CN: " + Bytes.toString(CellUtil.cloneQualifier(cell))
+ " V: " + Bytes.toString(CellUtil.cloneValue(cell))
+ " T: " + cell.getTimestamp());
}
private static void close(Connection connection, Admin admin) throws IOException {
if (connection != null){
connection.close();
}
if (admin != null){
admin.close();
}
}
}
网友评论