hbase集群连接eclipse_如何使用Eclipse构建HBase开发环境

步骤如下&＃xff1a;

1&＃xff1a;从HBase集群中复制一份Hbase部署文件&＃xff0c;放置在开发端某一目录下(如在/app/hadoop/hbase096目录下)。　　2&＃xff1a;在eclipse里新建一个java项目HBase&＃xff0c;然后选择项目属性&＃xff0c;在Libraries->Add External JARs...,然后选择/app/hadoop/hbase096/lib下相关的JAR包&＃xff0c;如果只是测试用的话&＃xff0c;就简单一点&＃xff0c;将所有的JAR选上。

3&＃xff1a;在项目HBase下增加一个文件夹conf&＃xff0c;将Hbase集群的配置文件hbase-site.xml复制到该目录&＃xff0c;然后选择项目属性在Libraries->Add Class Folder&＃xff0c;将刚刚增加的conf目录选上。

4&＃xff1a;在HBase项目中增加一个chapter12的package&＃xff0c;然后增加一个HBaseTestCase的class&＃xff0c;然后将《Hadoop实战第2版》12章的代码复制进去&＃xff0c;做适当的修改&＃xff0c;代码如下&＃xff1a;

package chapter12;

import java.io.IOException;

import org.apache.hadoop.conf.Configuration;

import org.apache.hadoop.hbase.HBaseConfiguration;

import org.apache.hadoop.hbase.HColumnDescriptor;

import org.apache.hadoop.hbase.HTableDescriptor;

import org.apache.hadoop.hbase.client.Get;

import org.apache.hadoop.hbase.client.HBaseAdmin;

import org.apache.hadoop.hbase.client.HTable;

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.util.Bytes;

public class HBaseTestCase {

//声明静态配置 HBaseConfiguration

static Configuration cfg&＃61;HBaseConfiguration.create();

//创建一张表&＃xff0c;通过HBaseAdmin HTableDescriptor来创建

public static void creat(String tablename,String columnFamily) throws Exception {

HBaseAdmin admin &＃61; new HBaseAdmin(cfg);

if (admin.tableExists(tablename)) {

System.out.println("table Exists!");

System.exit(0);

}

else{

HTableDescriptor tableDesc &＃61; new HTableDescriptor(tablename);

tableDesc.addFamily(new HColumnDescriptor(columnFamily));

admin.createTable(tableDesc);

System.out.println("create table success!");

}

}

//添加一条数据&＃xff0c;通过HTable Put为已经存在的表来添加数据

public static void put(String tablename,String row, String columnFamily,String column,String data) throws Exception {

HTable table &＃61; new HTable(cfg, tablename);

Put p1&＃61;new Put(Bytes.toBytes(row));

p1.add(Bytes.toBytes(columnFamily), Bytes.toBytes(column), Bytes.toBytes(data));

table.put(p1);

System.out.println("put &＃39;"&＃43;row&＃43;"&＃39;,&＃39;"&＃43;columnFamily&＃43;":"&＃43;column&＃43;"&＃39;,&＃39;"&＃43;data&＃43;"&＃39;");

}

public static void get(String tablename,String row) throws IOException{

HTable table&＃61;new HTable(cfg,tablename);

Get g&＃61;new Get(Bytes.toBytes(row));

Result result&＃61;table.get(g);

System.out.println("Get: "&＃43;result);

}

//显示所有数据&＃xff0c;通过HTable Scan来获取已有表的信息

public static void scan(String tablename) throws Exception{

HTable table &＃61; new HTable(cfg, tablename);

Scan s &＃61; new Scan();

ResultScanner rs &＃61; table.getScanner(s);

for(Result r:rs){

System.out.println("Scan: "&＃43;r);

}

}

public static boolean delete(String tablename) throws IOException{

HBaseAdmin admin&＃61;new HBaseAdmin(cfg);

if(admin.tableExists(tablename)){

try

{

admin.disableTable(tablename);

admin.deleteTable(tablename);

}catch(Exception ex){

ex.printStackTrace();

return false;

}

}

return true;

}

public static void  main (String [] agrs) {

String tablename&＃61;"hbase_tb";

String columnFamily&＃61;"cf";

try {

HBaseTestCase.creat(tablename, columnFamily);

HBaseTestCase.put(tablename, "row1", columnFamily, "cl1", "data");

HBaseTestCase.get(tablename, "row1");

HBaseTestCase.scan(tablename);

/*           if(true&＃61;&＃61;HBaseTestCase.delete(tablename))

System.out.println("Delete table:"&＃43;tablename&＃43;"success!");

*/

}

catch (Exception e) {

e.printStackTrace();

}

}

}

5&＃xff1a;设置运行配置&＃xff0c;然后运行。运行前将Hbase集群先启动。

6&＃xff1a;检验&＃xff0c;使用hbase shell查看hbase&＃xff0c;发现已经建立表hbase_tb。