hbase java是什么，讓我們一起了解一下？

HBase是一個分布式的、面向列的開源數(shù)據(jù)庫，具有高可靠性、高性能、面向列、可伸縮的分布式存儲系統(tǒng)，利用HBase技術(shù)可在廉價PC Server上搭建起大規(guī)模結(jié)構(gòu)化存儲集群。

如何使用JAVA語言操作Hbase、整合Hbase？

可分為五步驟：

步驟1：新創(chuàng)建一個Java Project?。

步驟2：導入JAR包，在工程根目錄下新建一個“l(fā)ib”文件夾，將官方文檔中的lib目錄下的jar全部導入。

步驟3：修改開發(fā)機的hosts文件，在文件莫為增加一行虛擬機IP的映射信息。

步驟4：修改虛擬機的配置文件，修改虛擬機的設(shè)備名稱，名稱需要與之前兩個配置文件的映射名稱一致。

步驟5：實現(xiàn)查詢、新建、刪除等。

案例代碼展示如下：

package?hbase;
import?java.io.IOException;
import?java.util.ArrayList;
import?java.util.List;
import?org.apache.hadoop.conf.Configuration;
import?org.apache.hadoop.hbase.Cell;
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.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.exceptions.DeserializationException;
import?org.apache.hadoop.hbase.filter.Filter;
import?org.apache.hadoop.hbase.filter.SingleColumnValueFilter;
import?org.apache.hadoop.hbase.filter.CompareFilter.CompareOp;
import?org.apache.hadoop.hbase.util.Bytes;
import?org.junit.Before;
import?org.junit.Test;
public?class?HBaseDemo?{
//?與HBase數(shù)據(jù)庫的連接對象
Connection?connection;
//?數(shù)據(jù)庫元數(shù)據(jù)操作對象
Admin?admin;
@Before
public?void?setUp()?throws?Exception?{
//?取得一個數(shù)據(jù)庫連接的配置參數(shù)對象
Configuration?conf?=?HBaseConfiguration.create();
//?設(shè)置連接參數(shù)：HBase數(shù)據(jù)庫所在的主機IP
conf.set("hbase.zookeeper.quorum",?"192.168.137.13");
//?設(shè)置連接參數(shù)：HBase數(shù)據(jù)庫使用的端口
conf.set("hbase.zookeeper.property.clientPort",?"2181");
//?取得一個數(shù)據(jù)庫連接對象
connection?=?ConnectionFactory.createConnection(conf);
//?取得一個數(shù)據(jù)庫元數(shù)據(jù)操作對象
admin?=?connection.getAdmin();
}
/**
????*?創(chuàng)建表
????*/
public?void?createTable()?throws?IOException{
System.out.println("---------------創(chuàng)建表?START-----------------");
//?數(shù)據(jù)表表名
String?tableNameString?=?"t_book";
//?新建一個數(shù)據(jù)表表名對象
TableName?tableName?=?TableName.valueOf(tableNameString);
//?如果需要新建的表已經(jīng)存在
if(admin.tableExists(tableName)){
System.out.println("表已經(jīng)存在！");
}
//?如果需要新建的表不存在
else{
//?數(shù)據(jù)表描述對象
HTableDescriptor?hTableDescriptor?=?new?HTableDescriptor(tableName);
//?列族描述對象
HColumnDescriptor?family=?new?HColumnDescriptor("base");;
//?在數(shù)據(jù)表中新建一個列族
hTableDescriptor.addFamily(family);
//?新建數(shù)據(jù)表
admin.createTable(hTableDescriptor);
}
System.out.println("---------------創(chuàng)建表?END-----------------");
}
/**
????*?查詢整表數(shù)據(jù)
????*/
@Test
public?void?queryTable()?throws?IOException{
System.out.println("---------------查詢整表數(shù)據(jù)?START-----------------");
//?取得數(shù)據(jù)表對象
Table?table?=?connection.getTable(TableName.valueOf("t_book"));
//?取得表中所有數(shù)據(jù)
ResultScanner?scanner?=?table.getScanner(new?Scan());
//?循環(huán)輸出表中的數(shù)據(jù)
for?(Result?result?:?scanner)?{
byte[]?row?=?result.getRow();
System.out.println("row?key?is:"?+?new?String(row));
List?listCells?=?result.listCells();
for?(Cell?cell?:?listCells)?{
byte[]?familyArray?=?cell.getFamilyArray();
byte[]?qualifierArray?=?cell.getQualifierArray();
byte[]?valueArray?=?cell.getValueArray();
System.out.println("row?value?is:"?+?new?String(familyArray)?+?new?String(qualifierArray)
+?new?String(valueArray));
}
}
System.out.println("---------------查詢整表數(shù)據(jù)?END-----------------");
}
/**
????*?按行鍵查詢表數(shù)據(jù)
????*/
@Test
public?void?queryTableByRowKey()?throws?IOException{
System.out.println("---------------按行鍵查詢表數(shù)據(jù)?START-----------------");
//?取得數(shù)據(jù)表對象
Table?table?=?connection.getTable(TableName.valueOf("t_book"));
//?新建一個查詢對象作為查詢條件
Get?get?=?new?Get("row8".getBytes());
//?按行鍵查詢數(shù)據(jù)
Result?result?=?table.get(get);
byte[]?row?=?result.getRow();
System.out.println("row?key?is:"?+?new?String(row));
List?listCells?=?result.listCells();
for?(Cell?cell?:?listCells)?{
byte[]?familyArray?=?cell.getFamilyArray();
byte[]?qualifierArray?=?cell.getQualifierArray();
byte[]?valueArray?=?cell.getValueArray();
System.out.println("row?value?is:"?+?new?String(familyArray)?+?new?String(qualifierArray)
+?new?String(valueArray));
}
System.out.println("---------------按行鍵查詢表數(shù)據(jù)?END-----------------");
}
/**
????*?按條件查詢表數(shù)據(jù)
????*/
@Test
public?void?queryTableByCondition()?throws?IOException{
System.out.println("---------------按條件查詢表數(shù)據(jù)?START-----------------");
//?取得數(shù)據(jù)表對象
Table?table?=?connection.getTable(TableName.valueOf("t_book"));
//?創(chuàng)建一個查詢過濾器
Filter?filter?=?new?SingleColumnValueFilter(Bytes.toBytes("base"),?Bytes.toBytes("name"),
CompareOp.EQUAL,?Bytes.toBytes("bookName6"));
//?創(chuàng)建一個數(shù)據(jù)表掃描器
Scan?scan?=?new?Scan();
//?將查詢過濾器加入到數(shù)據(jù)表掃描器對象
scan.setFilter(filter);
//?執(zhí)行查詢操作，并取得查詢結(jié)果
ResultScanner?scanner?=?table.getScanner(scan);
//?循環(huán)輸出查詢結(jié)果
for?(Result?result?:?scanner)?{
byte[]?row?=?result.getRow();
System.out.println("row?key?is:"?+?new?String(row));
List?listCells?=?result.listCells();
for?(Cell?cell?:?listCells)?{
byte[]?familyArray?=?cell.getFamilyArray();
byte[]?qualifierArray?=?cell.getQualifierArray();
byte[]?valueArray?=?cell.getValueArray();
System.out.println("row?value?is:"?+?new?String(familyArray)?+?new?String(qualifierArray)
+?new?String(valueArray));
}
}
System.out.println("---------------按條件查詢表數(shù)據(jù)?END-----------------");
}
/**
????*?清空表
????*/
@Test
public?void?truncateTable()?throws?IOException{
System.out.println("---------------清空表?START-----------------");
//?取得目標數(shù)據(jù)表的表名對象
TableName?tableName?=?TableName.valueOf("t_book");
//?設(shè)置表狀態(tài)為無效
admin.disableTable(tableName);
//?清空指定表的數(shù)據(jù)
admin.truncateTable(tableName,?true);
System.out.println("---------------清空表?End-----------------");
}
/**
????*?刪除表
????*/
@Test
public?void?deleteTable()?throws?IOException{
System.out.println("---------------刪除表?START-----------------");
//?設(shè)置表狀態(tài)為無效
admin.disableTable(TableName.valueOf("t_book"));
//?刪除指定的數(shù)據(jù)表
admin.deleteTable(TableName.valueOf("t_book"));
System.out.println("---------------刪除表?End-----------------");
}
/**
????*?刪除行
????*/
@Test
public?void?deleteByRowKey()?throws?IOException{
System.out.println("---------------刪除行?START-----------------");
//?取得待操作的數(shù)據(jù)表對象
Table?table?=?connection.getTable(TableName.valueOf("t_book"));
//?創(chuàng)建刪除條件對象
Delete?delete?=?new?Delete(Bytes.toBytes("row2"));
//?執(zhí)行刪除操作
table.delete(delete);
System.out.println("---------------刪除行?End-----------------");
}
/**
????*?刪除行（按條件）
????*/
@Test
public?void?deleteByCondition()?throws?IOException,?DeserializationException{
System.out.println("---------------刪除行（按條件）?START-----------------");
//?步驟1：調(diào)用queryTableByCondition()方法取得需要刪除的數(shù)據(jù)列表
//?步驟2：循環(huán)步驟1的查詢結(jié)果，對每個結(jié)果調(diào)用deleteByRowKey()方法
System.out.println("---------------刪除行（按條件）?End-----------------");
}
/**
????*?新建列族
????*/
@Test
public?void?addColumnFamily()?throws?IOException{
System.out.println("---------------新建列族?START-----------------");
//?取得目標數(shù)據(jù)表的表名對象
TableName?tableName?=?TableName.valueOf("t_book");
//?創(chuàng)建列族對象
HColumnDescriptor?columnDescriptor?=?new?HColumnDescriptor("more");
//?將新創(chuàng)建的列族添加到指定的數(shù)據(jù)表
admin.addColumn(tableName,?columnDescriptor);
System.out.println("---------------新建列族?END-----------------");
}
/**
????*?刪除列族
????*/
@Test
public?void?deleteColumnFamily()?throws?IOException{
System.out.println("---------------刪除列族?START-----------------");
//?取得目標數(shù)據(jù)表的表名對象
TableName?tableName?=?TableName.valueOf("t_book");
//?刪除指定數(shù)據(jù)表中的指定列族
admin.deleteColumn(tableName,?"more".getBytes());
System.out.println("---------------刪除列族?END-----------------");
}
/**
????*?插入數(shù)據(jù)
????*/
@Test
public?void?insert()?throws?IOException{
System.out.println("---------------插入數(shù)據(jù)?START-----------------");
//?取得一個數(shù)據(jù)表對象
Table?table?=?connection.getTable(TableName.valueOf("t_book"));
//?需要插入數(shù)據(jù)庫的數(shù)據(jù)集合
List?putList?=?new?ArrayList();
Put?put;
//?生成數(shù)據(jù)集合
for(int?i?=?0;?i?
以上就是小編今天的分享了，希望可以幫助到大家。