hbase jave编程

package hbase;

import java.util.ArrayList;
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.client.Delete;
import org.apache.hadoop.hbase.client.HBaseAdmin;
import org.apache.hadoop.hbase.client.HTable;
import org.apache.hadoop.hbase.client.HTableInterface;
import org.apache.hadoop.hbase.client.HTablePool;
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;


public class HbaseDemo {

	public static Configuration conf;
	static{
		conf = HBaseConfiguration.create();
	}
	public static void main(String[] args) throws Exception {
		createTable("test1");
	}
	/**
	 * 查询所有数据
	 * @param tableName
	 * @throws Exception
	 */
	public static void queryAll(String tableName) throws Exception{
		System.out.println("query all start....");
		HTablePool pool = new HTablePool(conf, 1000);
		HTableInterface table = pool.getTable(tableName);
		ResultScanner scanner = table.getScanner(new Scan());
		for (Result result : scanner) {
			System.out.println("rowkey:\t"+new String(result.getRow()));
			for (org.apache.hadoop.hbase.KeyValue kv : result.raw()) {
				System.out.println("column:\t"+new String(kv.getFamily())+":"+new String(kv.getValue()));
			}
		}
	}
	/**
	 * 删除行
	 * @param tableName
	 * @param rowkey
	 * @throws Exception
	 */
	public static void deleteRow(String tableName,String rowkey) throws Exception{
		HTable table = new HTable(conf, tableName);
		List list = new ArrayList();
		Delete d1 = new Delete(rowkey.getBytes());
		list.add(d1);
		table.delete(list);
		System.out.println("delete row end ....");
	}
	/**
	 * 删除表
	 * @param tableName
	 * @throws Exception
	 */
	public static void dropTable(String tableName) throws Exception{
		HBaseAdmin admin = new HBaseAdmin(conf);
		admin.disableTable(tableName);
		admin.deleteTable(tableName);
		admin.close();
	}
	/**
	 * 插入数据
	 * @param tableName
	 * @throws Exception
	 */
	public static void insertData(String tableName) throws Exception{
		System.out.println("insert data start.....");
		HTablePool pool = new HTablePool(conf, 1000);
		HTableInterface table = pool.getTable(tableName);
		Put put = new Put("row001".getBytes());
		put.add("tf1".getBytes(), null, "aaa".getBytes());
		put.add("tf2".getBytes(), null, "aaa".getBytes());
		put.add("tf3".getBytes(), null, "aaa".getBytes());
		table.put(put);
		System.out.println("insert data end.....");
	}
	/**
	 * 创建表
	 * @param tableName
	 * @throws Exception
	 */
	public static void createTable(String tableName) throws Exception{
		System.out.println("create table ....");
		HBaseAdmin admin = new HBaseAdmin(conf);
		// 如果存在要创建的表，那么先删除，再创建
		if(admin.tableExists(tableName)){
			admin.disableTable(tableName);
			admin.deleteTable(tableName);
			System.out.println(tableName+" table exists,delete ....");
		}
		HTableDescriptor descriptor = new HTableDescriptor(tableName);
		descriptor.addFamily(new HColumnDescriptor("tf1"));
		descriptor.addFamily(new HColumnDescriptor("tf2"));
		descriptor.addFamily(new HColumnDescriptor("tf3"));
		admin.createTable(descriptor);
		admin.close();
		System.out.println("create table finished....");
	}
}