/**
* 初始化 配置資訊
*/ @before
public void init(
)catch
(exception e)
}/**
* 關閉資源
*/ @after
public void close(
)catch
(ioexception e)}if
(connection != null)
catch
(ioexception e)
}}
/*
** 建立命名空間
*/ @test
public void createnamespace(
) throws exception
/*** 顯示所有的命名空間
** @throws exception
*/ @test
public void listnamespace(
) throws exception
// 關閉連線
admin.close();
connection.close();
}/**
* 檢視某個命名空間所有表
** @throws exception
*/ @test
public void listnamespacetablesbynamespace(
) throws exception
// 關閉資源
admin.close();
connection.close();
}/**
* 刪除命名空間 要求該命名空間沒有表,
* 有的話 先刪除所有的表,然後再刪除表
** @throws ioexception
*/ @test
public void dropnamespace(
) throws ioexception
// 刪除命名空間
admin.deletenamespace(
"bighbase5");
}
/**
* 建立表 create "命名空間:表名"
,"列族"
** @throws ioexception
*/ @test
public void createtable(
) throws ioexception
/*** 修改列族 需要注意的是:此修改會覆蓋原來的列族,所以需要把之前的列族也要重新設定一次
** @throws ioexception
*/ @test
public void altertable(
) throws ioexception
/*** 顯示所有的表
** @throws ioexception
*/ @test
public void listtable(
) throws ioexception
}/**
* 刪除表
** @throws ioexception
*/ @test
public void droptable(
) throws ioexception
/*** 插入資料
** @throws ioexception
*/ @test
public void put(
) throws ioexception
/*** 批量插入資料
** @throws ioexception
*/ @test
public void putlist(
) throws ioexception
// 關閉table物件
table.close();
}// 通過rowkey查詢整行資料
@test
public void getvaluebyrowkey(
) throws ioexception
else}/
/ 關閉table物件
table.close();
}/**
* 根據rowkey和列族獲取 cell
** @throws ioexception
*/ @test
public void getvaluebyrowkeyandqualifier(
) throws ioexception
else}/
/ 關閉table物件
table.close();
}/**
* 批量查詢
** @throws ioexception
*/ @test
public void getbatch(
) throws ioexception
// 多條資料
final result[
] results = table.get(list);/
/ 遍歷得到多條記錄
for(result result : results)
else}}
// 關閉資源
table.close();
}/**
* 指定rowkey刪除一行資料
* @throws ioexception
*/ @test
public void deletebyrowkey(
) throws ioexception
/*** 批量刪除資料
* @throws ioexception
*/ @test
public void deletebatch(
) throws ioexception
table.delete(list);/
/ table.close();
}
/*
** 使用scan全域性掃瞄
** @throws ioexception
*/ @test
public void getvaluebyscan(
) throws ioexception
else}}
// 4,關閉
table.close();
}/**
* 使用scan指定family查詢資料
* @throws ioexception
*/ @test
public void getvaluebyscanfamily(
) throws ioexception
else}}
// 4 關閉資源
table.close();
}
/**
* 根據值來查詢資料
* 例如 select
*from xx where age=25
*/ @test
public void filterbyvalue(
) throws ioexception
else}}
// 4 關閉資源
table.close();
}/**
* 實現模糊查詢
*select
* form xx where name like "%5%"
* @throws ioexception
*/ @test
public void filterbylike(
) throws ioexception
else}}
// 4 關閉資源
table.close();
}/**
* 關聯條件查詢
*select
*from xx where name like '%san%' and (age>20 and name='zhangsan-4'
)* @throws ioexception
*/ @test
public void filterbymuti(
) throws ioexception
else}}
// 關閉資源
table.close();
}/**
* 模組查詢,就是指定全域性查詢乙個欄位的資料
*/ @test
public void rangscan(
) throws ioexception
else}}
// 關閉資源
table.close();
}
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 ...
HBase 建表API使用
string table table configuration conf hbaseconfiguration.create connection conn connectionfactory.createconnection conf admin admin conn.getadmin 刪除指定...