1006-HBase操作实战（JAVA API状态）

/**
 * 封装HBase中存储单元cell对象
 * @author shenfl
 * @version:V1.0
 * @Date：2015-6-8
 */
public class CellBean {

	//行健
	private String rowKey;
	//列族
	private String columnFamilly;
	//列名
	private String columnName;
	//cell值
	private String columnValue;

	public String getRowKey() {
		return rowKey;
	}

	public void setRowKey(String rowKey) {
		this.rowKey = rowKey;
	}

	public String getColumnFamilly() {
		return columnFamilly;
	}

	public void setColumnFamilly(String columnFamilly) {
		this.columnFamilly = columnFamilly;
	}

	public String getColumnName() {
		return columnName;
	}

	public void setColumnName(String columnName) {
		this.columnName = columnName;
	}

	public String getColumnValue() {
		return columnValue;
	}

	public void setColumnValue(String columnValue) {
		this.columnValue = columnValue;
	}
}

/**
 * 使用HBase JAVA API操作
 * 
 * @author shenfl
 *
 */
public class HBaseTest {
	Configuration config = null;
	// 创建操作表對象
	HBaseAdmin admin = null;
	// hbase的连接
	HConnection conn = null;

	@Before
	public void init() {
		config = HBaseConfiguration.create();
		// HBase仅仅须要知道ZooKeeper。就能够操作RegionServer上的數據，设置HBase 连接ZooKeeper
		config.set("hbase.zookeeper.quorum", "192.168.2.35:2181,192.168.2.36:2181,192.168.2.37:2181");
		try {
			conn = HConnectionManager.createConnection(config);
			admin = new HBaseAdmin(config);
		} catch (Exception e) {
			e.printStackTrace();
		}
	}

	@After
	public void destory() {
		try {
			admin.close();
			conn.close();
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	@Test
	public void testCreate() {
		String tableName = "account";
		String[] columnFamilies = new String[] { "info", "other" };
		create(tableName, columnFamilies);
	}

	//@Test
	public void testDrop() {
		drop("account");
	}

	@Test
	public void testPut() {

		// 设置表对象列表
		List<CellBean> cbList = new ArrayList<CellBean>();
		// 设置表名account
		String tableName = "account";
		CellBean e = null;
		for(int i=0;i<3;i++){
			e = new CellBean();
			e.setRowKey("g20142500"+i);
			e.setColumnFamilly("info");
			e.setColumnName("username");
			e.setColumnValue("shenfl"+i);
			cbList.add(e);
			e = new CellBean();
			e.setRowKey("g20142500"+i);
			e.setColumnFamilly("other");
			e.setColumnName("career");
			e.setColumnValue("singer"+i);
			cbList.add(e);
		}
		put(tableName, cbList);
	}

	@Test
	public void testGetByRowKey() {
		
		String tableName = "account";
		String rowKey = "g201425001";
		List<Cell> cells = get(tableName, rowKey);
		StringBuffer info = new StringBuffer();
		for (Cell c : cells) {
			//使用CellUtil方法输出相应列。 hbase0.96 版本号使用CellUtil函数
			info.append(new String(CellUtil.cloneFamily(c))).append(":")
				.append(new String(CellUtil.cloneQualifier(c))).append("\t")
				.append(new String(CellUtil.cloneValue(c))).append("\n");
		}
		System.out.println(info);
	}
	@Test
	public void testScanSToEnd(){
		
		StringBuffer sb = new StringBuffer();
		String tableName = "account";
		String startRow = "g201425000";
		String stopRow = "g201425002";
		List<Result> rsList = scan(tableName, startRow, stopRow);
		byte[] rowKey = null;
		byte[] username = null;
		byte[] career = null;
		for(Result rs:rsList){
			rowKey = rs.getRow();
			username = rs.getValue(Bytes.toBytes("info"), Bytes.toBytes("username"));
			career = rs.getValue(Bytes.toBytes("other"), Bytes.toBytes("career"));
			sb.append(new String(rowKey)).append("\t")
			  .append(new String(username)).append("\t")
			  .append(new String(career)).append("\n");
		}
		System.out.println(sb.toString());
	}
	
	@Test
	public void testScanAll() {
		StringBuffer sb = new StringBuffer();
		List<Result> rsList = scan("account");
		for (Result rs : rsList) {

			List<Cell> listCells = rs.listCells();
			for (Cell c : listCells) {
				// 使用CellUtil方法输出相应列。 hbase0.96 版本号使用CellUtil函数
				sb.append(new String(CellUtil.cloneRow(c))).append("\t")
				  .append(new String(CellUtil.cloneFamily(c))).append(":")
				  .append(new String(CellUtil.cloneQualifier(c))).append("\t")
				  .append(new String(CellUtil.cloneValue(c))).append("\n");
			}
		}

		System.out.println(sb);
	}
	/**
	 * 通过rowKey插入表数据
	 * @param tableName 表名
	 * @param rowKey	行健
	 * @return
	 */
	public List<Cell> get(String tableName, String rowKey) {
		HTableInterface table = null;
		Get get = null;
		Result rs = null;
		List<Cell> listCells = new ArrayList<Cell>();
		try {
			table = conn.getTable(tableName);
			get = new Get(Bytes.toBytes(rowKey));
			rs = table.get(get);
			listCells = rs.listCells(); 
		} catch (IOException e) {
			e.printStackTrace();
		}finally{
			try {
				table.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return  listCells;
	}
	
	/**
	 * 查询全部行
	 * 
	 * @param tableName
	 * @return
	 */
	public List<Result> scan(String tableName) {
		HTableInterface table = null;
		List<Result> rsList = new ArrayList<Result>();
		try {
			table = conn.getTable(tableName);
			Scan scan = new Scan();
			ResultScanner scanner = table.getScanner(scan);
			Iterator<Result> iterator = scanner.iterator();
			Result rs = null;
			while (iterator.hasNext()) {
				rs = (Result) iterator.next();
				rsList.add(rs);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			try {
				table.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return rsList;
	}
	/**
	 * 查询范围行
	 * @param tableName 表名
	 * @param startRow  開始的行健
	 * @param stopRow   结束行健
	 * @return
	 */
	public List<Result> scan(String tableName,String startRow,String stopRow) {
		
		HTableInterface table = null;
		List<Result> rsList = new ArrayList<Result>();
		try {
			table = conn.getTable(tableName);
			Scan scan = new Scan();
			scan.setStartRow(Bytes.toBytes(startRow));
			scan.setStopRow(Bytes.toBytes(stopRow));
			ResultScanner rs = table.getScanner(scan);
			
			for(Result v:rs){
				rsList.add(v);
			}
		} catch (Exception e) {
			e.printStackTrace();
		}finally{
			try {
				table.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
		return  rsList;
	}
	/**
	 * 创建壁报
	 * 
	 * @param tableName
	 *            表名
	 * @param cfs
	 *            列族
	 */
	public void create(String tableName, String[] cfs) {

		if (cfs == null || cfs.length == 0) {
			return;
		}
		try {
			// 校验表是否存储
			if (admin.tableExists(tableName)) {
				return;
			}
			// 创建表
			HTableDescriptor desc = new HTableDescriptor(TableName.valueOf(tableName));
			// 创建列族
			for (String cf : cfs) {
				desc.addFamily(new HColumnDescriptor(cf));
			}
			// 创建表
			admin.createTable(desc);
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	/**
	 * 删除表
	 * 
	 * @param tableName
	 *            表名
	 */
	public void drop(String tableName) {
		try {
			if(admin.tableExists(tableName)){
				
				admin.disableTable(tableName);
				admin.deleteTable(tableName);
			}
		} catch (IOException e) {
			e.printStackTrace();
		}
	}

	/**
	 * 向指定表插入数据
	 * 
	 * @param tableName
	 *            表名
	 * @param values
	 *            数据
	 */
	public void put(String tableName, List<CellBean> values) {

		if (StringUtils.isBlank(tableName) || values == null || values.size() == 0) {
			return;
		}
		Put put = null;
		HTableInterface table = null;
		try {
			table = conn.getTable(tableName);
			for (CellBean v : values) {
				put = new Put(Bytes.toBytes(v.getRowKey()));
				put.add(Bytes.toBytes(v.getColumnFamilly()), Bytes.toBytes(v.getColumnName()),
						Bytes.toBytes(v.getColumnValue()));
				table.put(put);
			}
		} catch (Exception e) {
			// 实际生产环境要通过记录日志。比如： logger.warn("xxxxx",e);
			e.printStackTrace();
		}finally{
			try {
				table.close();
			} catch (IOException e) {
				e.printStackTrace();
			}
		}
	}
}