HBase的JAVA API操作详解

Alt+/   代码助手完成一些代码的插入，自动显示提示信息 

Alt+↓   当前行和下面一行交互位置(特别实用,可以省去先剪切,再粘贴了)

Alt+↑   当前行和上面一行交互位置(同上)

Alt+←   前一个编辑的页面 

Alt+→   下一个编辑的页面(当然是针对上面那条来说了)

Alt+Shift+M   抽取方法

Alt+Shift+L   抽取本地变量 

Ctrl+1        快速修复 

package Hbase;

import java.io.IOException;
import java.io.InterruptedIOException;
import java.util.List;

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.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.RetriesExhaustedWithDetailsException;
import org.apache.hadoop.hbase.client.Scan;

public class test {
	private static final String Table_NAME =  "table1";         //表名称
	private static final String FAMILY_NAME =  "family1"; //列族名称
	private static final String ROW_KEY = "rowkey1";     //创建行健

	//创建，插入，查询记录，遍历表，删除表
	public static void main(String[] args) throws Exception {
            Configuration conf=  HBaseConfiguration.create();
            conf.set("hbase.rootdir","hdfs://localhost:9000/hbase");  //设置hbase再hdfs中的目录
            conf.set("hbase.zookeeper.quorum", "localhost");        //使用zookeeper来进行定位
            //创建删除表使用HBaseAdmin
            HBaseAdmin hBaseAdmin = new HBaseAdmin(conf);
            createTable(hBaseAdmin);            //创建表
            
            //插入记录，查询一条记录，遍历所有的记录Table
             final HTable hTable = new HTable(conf, Table_NAME);
			 putRecord(hTable);         //插入一条记录
             getRecord(hTable);         //查询一条记录
             scanTable(hTable);             //遍历所有的表的记录
             hTable.close();          //关闭表
            //deleteTable(hBaseAdmin);              //删除表
            }

	private static void scanTable(final HTable hTable) throws IOException {
		Scan scan = new Scan();
		 final ResultScanner scanner = hTable.getScanner(scan);
		 for (Result result : scanner) {
			 final byte[] value = result.getValue(FAMILY_NAME.getBytes()	, "age".getBytes());
			 System.out.println(result+"\t" + new String(value));
		}
	}

	private static void getRecord(final HTable hTable) throws IOException {
		Get get = new Get(ROW_KEY.getBytes());
		 final Result result = hTable.get(get );
		 final byte[] value = result.getValue(FAMILY_NAME.getBytes()	, "age".getBytes());
		 System.out.println(result+"\t" + new String(value));
	}

	private static void putRecord(HTable hTable) throws InterruptedIOException,
			RetriesExhaustedWithDetailsException {
		Put put = new Put(ROW_KEY.getBytes());        //声明对象
		 put.add(FAMILY_NAME .getBytes(), "age".getBytes(),"	12".getBytes());   //添加记录
		 hTable.put(put );    //插入
	}

	private static void deleteTable(HBaseAdmin hBaseAdmin) throws IOException {
		hBaseAdmin.disableTable(Table_NAME);        //关闭表
		hBaseAdmin.deleteTable(Table_NAME);       //删除表
	}

	private static void createTable(HBaseAdmin hBaseAdmin) throws IOException {
		if (!hBaseAdmin.tableExists(Table_NAME)){
			HTableDescriptor tableDescriptor = new HTableDescriptor(Table_NAME);    //声明一个表
			HColumnDescriptor family = new HColumnDescriptor(FAMILY_NAME);       //声明一个列族
			tableDescriptor.addFamily(family );                                      //添加列族
			hBaseAdmin.createTable(tableDescriptor );                                 //创建表
		}
	}

}