java实现hbase表创建、数据插入、删除表

近日查看了相关资料后，梳理了一下用java实现hbase的表创建、数据插入、删除表，代码如下：

1、需要的jar包：

commons-codec-1.4.jar

commons-logging-1.0.4.jar

hadoop-0.20.2-core.jar

hbase-0.20.6.jar

log4j-1.2.15.jar

zookeeper-3.2.2.jar

2、代码：

package org.myhbase;

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.KeyValue;

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

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

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.io.BatchUpdate;

public class HBaseBasic02 {

static HBaseConfiguration hbaseConfig=null;

static{

Configuration config=new Configuration();

config.set("hbase.zookeeper.quorum","192.168.10.149,192.168.10.44,192.168.10.49");

config.set("hbase.zookeeper.property.clientPort", "2181");

hbaseConfig=new HBaseConfiguration(config);

}

/**

* 创建一张表

* @throws IOException

*/

public static void createTable(String tablename) throws IOException{

HBaseAdmin admin = new HBaseAdmin(hbaseConfig);

if(admin.tableExists(tablename)){

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

}else{

HTableDescriptor tableDesc = new HTableDescriptor(tablename);

tableDesc.addFamily(new HColumnDescriptor("name:"));

admin.createTable(tableDesc);

System.out.println("create table ok.");

}

}

/**

* 删除一张表

* @throws IOException

*/

public static void dropTable(String tablename) throws IOException{

HBaseAdmin admin = new HBaseAdmin(hbaseConfig);

admin.disableTable(tablename);

admin.deleteTable(tablename);

System.out.println("drop table ok.");

}

/**

* 添加一条数据

* @throws IOException

*/

public static void addData(String tablename) throws IOException{

HTable table=new HTable(hbaseConfig,tablename);

BatchUpdate update=new BatchUpdate("Huangyi");

update.put("name:java","http://www.sun.com".getBytes());

table.commit(update);

System.out.println("add data ok.");

}

/**

* 显示所有数据

* @throws IOException

*/

public static void getAllData(String tablename) throws IOException{

HTable table=new HTable(hbaseConfig,tablename);

Scan s=new Scan();

ResultScanner rs=table.getScanner(s);

for(Result r:rs){

for(KeyValue kv:r.raw()){

System.out.println("rowkey : "+new String(kv.getRow()));

System.out.println(new String(kv.getColumn())+" = "+new String(kv.getValue()));

}

}

}

public static void main(String [] args) throws IOException{

String tablename="table_1";

HBaseBasic02.createTable(tablename);

HBaseBasic02.addData(tablename);

HBaseBasic02.getAllData(tablename);

HBaseBasic02.dropTable(tablename);

}

}

转自：http://blog.csdn.net/karen_wang/article/details/6283729