学步园

近日查看了相关资料后，梳理了一下用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;</p> <p>import java.io.IOException;</p> <p>import org.apache.hadoop.conf.Configuration;<br /> import org.apache.hadoop.hbase.HBaseConfiguration;<br /> import org.apache.hadoop.hbase.HColumnDescriptor;<br /> import org.apache.hadoop.hbase.HTableDescriptor;<br /> import org.apache.hadoop.hbase.KeyValue;<br /> import org.apache.hadoop.hbase.client.HBaseAdmin;<br /> import org.apache.hadoop.hbase.client.HTable;<br /> import org.apache.hadoop.hbase.client.Result;<br /> import org.apache.hadoop.hbase.client.ResultScanner;<br /> import org.apache.hadoop.hbase.client.Scan;<br /> import org.apache.hadoop.hbase.io.BatchUpdate;</p> <p>public class HBaseBasic02 {<br /> static HBaseConfiguration hbaseConfig=null;<br /> static{<br /> Configuration config=new Configuration();<br /> config.set("hbase.zookeeper.quorum","192.168.10.149,192.168.10.44,192.168.10.49");<br /> config.set("hbase.zookeeper.property.clientPort", "2181");<br /> hbaseConfig=new HBaseConfiguration(config);<br /> }</p> <p> /**<br /> * 创建一张表<br /> * @throws IOException<br /> */<br /> public static void createTable(String tablename) throws IOException{<br /> HBaseAdmin admin = new HBaseAdmin(hbaseConfig);<br /> if(admin.tableExists(tablename)){<br /> System.out.println("table Exists!!!");<br /> }else{<br /> HTableDescriptor tableDesc = new HTableDescriptor(tablename);<br /> tableDesc.addFamily(new HColumnDescriptor("name:"));<br /> admin.createTable(tableDesc);<br /> System.out.println("create table ok.");<br /> }<br /> }</p> <p> /**<br /> * 删除一张表<br /> * @throws IOException<br /> */<br /> public static void dropTable(String tablename) throws IOException{<br /> HBaseAdmin admin = new HBaseAdmin(hbaseConfig);<br /> admin.disableTable(tablename);<br /> admin.deleteTable(tablename);<br /> System.out.println("drop table ok.");<br /> }</p> <p> /**<br /> * 添加一条数据<br /> * @throws IOException<br /> */<br /> public static void addData(String tablename) throws IOException{<br /> HTable table=new HTable(hbaseConfig,tablename);<br /> BatchUpdate update=new BatchUpdate("Huangyi");<br /> update.put("name:java","http://www.sun.com".getBytes());<br /> table.commit(update);<br /> System.out.println("add data ok.");<br /> }</p> <p> /**<br /> * 显示所有数据<br /> * @throws IOException<br /> */<br /> public static void getAllData(String tablename) throws IOException{<br /> HTable table=new HTable(hbaseConfig,tablename);<br /> Scan s=new Scan();<br /> ResultScanner rs=table.getScanner(s);<br /> for(Result r:rs){<br /> for(KeyValue kv:r.raw()){<br /> System.out.println("rowkey : "+new String(kv.getRow()));<br /> System.out.println(new String(kv.getColumn())+" = "+new String(kv.getValue()));<br /> }<br /> }<br /> }</p> <p> public static void main(String [] args) throws IOException{<br /> String tablename="table_1";<br /> HBaseBasic02.createTable(tablename);<br /> HBaseBasic02.addData(tablename);<br /> HBaseBasic02.getAllData(tablename);<br /> HBaseBasic02.dropTable(tablename);<br /> }</p> <p>}<br />