Hbase學習02 API操作

重要的部分

1.建立hbase連線以及admin管理物件

要操作hbase也需要建立hbase的連線，此處我們仍然使用testng來進行測試，使用@beforetest初始化hbase的連線，然後建立admin的物件，@aftertest來關閉連線

實現步驟:「

1.1使用hbaseconfiguration.create（）建立hbase配置~

1.2使用connectionfactory.createconnection（）建立hbase連線

1.3要建立表，需要基於hbase連線獲取admin管理物件

1.4使用admin.close.connection.close關閉連線

其中重要的before和after操作：

//

開始前都要執行的
@beforetest
public
void
beforetest() throws ioexception 
//結束之前都要執行的
@aftertest
public
void
aftertest() throws ioexception 

@test

public
void
createtable() throws ioexception 
//構建表
//2、使用tabledescriptorbuilder.newbuilder構建表描述構造器
//tabledescriptorbuilder:表描述器他是用來描述這個表有幾個列蔟和其他屬性
tabledescriptorbuilder tabledescriptorbuilder =tabledescriptorbuilder.newbuilder(tablename);
//3、使用columnfamilydescriptorbuilder.newbuilder()構建列蔟描述構造器
//建立列蔟也需要有列蔟的描述器，需要用乙個構建器來構建columnfamilydescriptor
//經常會使用到乙個工具類:bytes (hbase包下的bytes工具類）
//這個工具類可以將字串、long.double型別轉換成byte陣列
//也可以將byte陣列轉換為指定型別
columnfamilydescriptorbuilder columnfamilydescriptorbuilder = columnfamilydescriptorbuilder.newbuilder(bytes.tobytes("c1"
)); 
//4、構建列蔟描述，構建表描述
columnfamilydescriptor cfdes =columnfamilydescriptorbuilder.build();
//建立表和列蔟的關聯
tabledescriptorbuilder.setcolumnfamily(cfdes);
tabledescriptor tabledescriptor =tabledescriptorbuilder.build();
//5、建立表
admin.createtable(tabledescriptor);
}

//

寫入資料
@test
public
void
puttest() throws ioexception 
//7.關閉表~
5、根據rowkey進行資料的刪除
//

刪除資料
@test
public
void
deletetest() throws ioexception 
6、給定乙個日期區間。查詢這個區間的所有資料並輸出；

//

檢視日期下的資訊給定乙個日期區間
@test
public
void
scanfiltertest() throws ioexception 
else
system.
out.println(cf+"
: "+columnname+"
-> 
"+value);}}
//7...關閉resultscanner《這玩意把轉換成乙個個的類似get的操作注意要關閉釋放資源2
resultscanner.close();
//8..關閉表.
node學習筆記 02 API詳解
一.知識點 url.parse方法 方法說明 講乙個url字串轉換成物件並返回。語法 url.parse urlstr,parsequerystring slashesdenotehost 接收引數 urlstr url字串 parsequerystring 為true時將使用查詢模組分析查詢字串，...
Hbase常用api操作
連線資料庫 configuration conf new configuration conf.set hbase.zookeeper.quorum node01 2181,node02 2181,node03 2181 connection connection connectionfactory...
HBase 詳細API操作
新建專案後在pom.xml中新增依賴 org.apache.hbasegroupid hbase serverartifactid 1.3.1version dependency org.apache.hbasegroupid hbase clientartifactid 1.3.1version ...