你的位置:
首页
>
软件开发 >
数据库 > 在Eclipse中运行JAVA代码远程操作HBase的示例
在Eclipse中运行JAVA代码远程操作HBase的示例
发布时间:2015-08-26 19:00:06
在Eclipse中运行JAVA代码远程操作HBase的示例 分类: 大数据 2014-03-04 13:47 3762人阅读 评论(2) 收藏 举报 下面是一个在Windows的Eclipse中通过JAVA操作一个Linux上运行的hbase的示例。Hbase的配置需要注意下面 ...
在Eclipse中运行JAVA代码远程操作HBase的示例
分类: 大数据 2014-03-04 13:47 3762人阅读 评论(2) 收藏 举报
// Hbase获取所有的表信息
public List getAllTables() {
List<String> tables = null;
if (admin != null) {
try {
HTableDescriptor[] allTable = admin.listTables();
if (allTable.length > 0)
tables = new ArrayList<String>();
for (HTableDescriptor hTableDescriptor : allTable) {
tables.add(hTableDescriptor.getNameAsString());
System.out.println(hTableDescriptor.getNameAsString());
}
} catch (IOException e) {
e.printStackTrace();
}
}
return tables;
}
// Hbase中往某个表中添加一条记录
public boolean addOneRecord(String table, String key, String family,
String col, byte[] dataIn) {
HTablePool tp = new HTablePool(cfg, 1000);
HTable tb = (HTable) tp.getTable(table);
Put put = new Put(key.getBytes());
put.add(family.getBytes(), col.getBytes(), dataIn);
try {
tb.put(put);
System.out.println("插入数据条" + key + "成功!!!");
return true;
} catch (IOException e) {
System.out.println("插入数据条" + key + "失败!!!");
return false;
}
}
// Hbase表中记录信息的查询
public void getValueFromKey(String table, String key) {
HTablePool tp = new HTablePool(cfg, 1000);
HTable tb = (HTable) tp.getTable(table);
Get get = new Get(key.getBytes());
try {
Result rs = tb.get(get);
if (rs.raw().length == 0) {
System.out.println("不存在关键字为" + key + "的行!!");
} else {
for (KeyValue kv : rs.raw()) {
System.out.println(new String(kv.getKey()) + " "
+ new String(kv.getValue()));
}
}
} catch (IOException e) {
e.printStackTrace();
}
}
// 显示所有数据,通过HTable Scan类获取已有表的信息
public void getAllData(String tableName) throws Exception {
HTable table = new HTable(cfg, tableName);
Scan scan = new Scan();
ResultScanner rs = table.getScanner(scan);
for (Result r : rs) {
for (KeyValue kv : r.raw()) {
System.out.println(new String(kv.getKey())
+ new String(kv.getValue()));
}
}
}
// Hbase表中记录信息的删除
public boolean deleteRecord(String table, String key) {
HTablePool tp = new HTablePool(cfg, 1000);
HTable tb = (HTable) tp.getTable(table);
Delete de = new Delete(key.getBytes());
try {
tb.delete(de);
return true;
} catch (IOException e) {
System.out.println("删除记录" + key + "异常!!!");
return false;
}
}
// Hbase中表的删除
public boolean deleteTable(String table) {
try {
if (admin.tableExists(table)) {
admin.disableTable(table);
admin.deleteTable(table);
System.out.println("删除表" + table + "!!!");
}
return true;
} catch (IOException e) {
System.out.println("删除表" + table + "异常!!!");
return false;
}
}
// 测试函数
public static void main(String[] args) {
try {
HbaseTest hbase = new HbaseTest();
// hbase.createTable("student", "fam1");
// hbase.getAllTables();
// hbase.addOneRecord("student","id1","fam1","name","Jack".getBytes());
// hbase.addOneRecord("student","id1","fam1","address","HZ".getBytes());
// hbase.getValueFromKey("student","id1");
// hbase.getAllData("student");
//hbase.deleteRecord("student", "id1");
hbase.deleteTable("student");
} catch (Exception e) {
e.printStackTrace();
}
}
}
原标题:在Eclipse中运行JAVA代码远程操作HBase的示例
关键词:JAVA
*特别声明:以上内容来自于网络收集,著作权属原作者所有,如有侵权,请联系我们:
admin#shaoqun.com
(#换成@)。