hbase API操作范例

public class HbaseDemo {
	private Configuration conf = null;

	@Before
	public void init(){
		conf = HBaseConfiguration.create();
		conf.set("hbase.zookeeper.quorum", "lp5,lp6,lp7");
	}

	/*
	 * 新建表
	 */
	@Test
	public void create() throws Exception{
		//Provides an interface to manage HBase database table metadata + general administrative functions. Use HBaseAdmin to create, drop, list, enable and disable tables. Use it also to add and drop table column families.
		//See HTable to add, update, and delete data from an individual table.
		//Currently HBaseAdmin instances are not expected to be long-lived. For example, an HBaseAdmin instance will not ride over a Master restart.
		//操纵hbase的客户端
		HBaseAdmin client = new HBaseAdmin(conf);
		//表名
		TableName tableName = TableName.valueOf("production");
		//表描述
		HTableDescriptor htd = new HTableDescriptor(tableName);
		//列族描述
		HColumnDescriptor base_info = new HColumnDescriptor("base_info");
		base_info.setMaxVersions(5);
		HColumnDescriptor external_info = new HColumnDescriptor("external_info");
		external_info.setMaxVersions(5);

		//添加列族
		htd.addFamily(base_info);
		htd.addFamily(external_info);
		//建表
		client.createTable(htd);
		client.close();
	}

	/*
	 * 删除表结构
	 */
	@Test
	public void drop() throws Exception{
		HBaseAdmin client = new HBaseAdmin(conf);
		client.disableTable("production");
		client.deleteTable("production");
		client.close();
	}

	/*
	 * 向表中添加数据
	 */
	@Test
	public void insert() throws Exception{
		//1.这种方法线程不安全
		//得到表
		HTable table = new HTable(conf, "production");
		//指定一行
		Put put = new Put(Bytes.toBytes("p_computer_0001"));
		//插入值
		put.add("base_info".getBytes(),"name".getBytes(),"Hongji".getBytes());
		put.add("base_info".getBytes(),"price".getBytes(),"3890".getBytes());
		put.add("external_info".getBytes(),"image".getBytes(),"nothing".getBytes());
		table.put(put);
		table.close();

		/*HConnection conn = HConnectionManager.getConnection(conf);
		HTableInterface table = conn.getTable("production");
		Put put = new Put(Bytes.toBytes("p_computer_0001"));
		put.add("base_info".getBytes(),"name".getBytes(),"Apple".getBytes());
		table.put(put);
		table.close();*/
	}

	/*
	 * 删除表中数据
	 * 但是删除新版本的数据后,旧版本的就顶上来了,咋个办???、、、指定版本即可
	 */
	@Test
	public void delete() throws Exception{
		HTable table = new HTable(conf,"production");
		//单行删除
		Delete del = new Delete(Bytes.toBytes("p_computer_0001"));
		del.deleteColumn(Bytes.toBytes("base_info"), Bytes.toBytes("name"));
		table.delete(del);
		table.close();
	}

	/*
	 * 查找数据
	 */
	@Test
	public void get() throws IOException{
		HTable table = new HTable(conf,"production");
		Get get = new Get(Bytes.toBytes("p_computer_0001"));
		get.setMaxVersions(1);//设定要查几个版本的数据
		Result result = table.get(get);
		List<Cell> cells = result.listCells();

		for(KeyValue kv : result.list()){
			String family = new String(kv.getFamily());//获取列族
			System.out.println(family);
			String qualifier = new String(kv.getQualifier());
			System.out.println(qualifier);
			System.out.println(new String(kv.getValue()));
		}
		table.close();
	}

	/*
	 * 过滤查找数据
	 */
	@Test
	public void scan() throws IOException{
		HTable table = new HTable(conf,"production");
		Scan scan = new Scan(Bytes.toBytes("p_computer_0001"), Bytes.toBytes("p_computer_0003"));

		//前缀过滤器----针对行键
		Filter filter = new PrefixFilter(Bytes.toBytes("p"));

		//行过滤器
		ByteArrayComparable rowComparator = new BinaryComparator(Bytes.toBytes("p_computer_0001"));
		RowFilter rf = new RowFilter(CompareOp.LESS_OR_EQUAL, rowComparator);

		/**
         * 假设rowkey格式为:创建日期_发布日期_ID_TITLE
         * 目标:查找  发布日期  为  2014-12-21  的数据
         */
        rf = new RowFilter(CompareOp.EQUAL , new SubstringComparator("_2014-12-21_"));

		//单值过滤器 1 完整匹配字节数组
		new SingleColumnValueFilter("base_info".getBytes(), "name".getBytes(), CompareOp.EQUAL, "zhangsan".getBytes());
		//单值过滤器2 匹配正则表达式
		ByteArrayComparable comparator = new RegexStringComparator("zhang.");
		new SingleColumnValueFilter("info".getBytes(), "NAME".getBytes(), CompareOp.EQUAL, comparator);

		//单值过滤器2 匹配是否包含子串,大小写不敏感
		comparator = new SubstringComparator("wu");
		new SingleColumnValueFilter("info".getBytes(), "NAME".getBytes(), CompareOp.EQUAL, comparator);

		//键值对元数据过滤-----family过滤----字节数组完整匹配
        FamilyFilter ff = new FamilyFilter(
                CompareOp.EQUAL ,
                new BinaryComparator(Bytes.toBytes("base_info"))   //表中不存在inf列族,过滤结果为空
                );
        //键值对元数据过滤-----family过滤----字节数组前缀匹配
        ff = new FamilyFilter(
                CompareOp.EQUAL ,
                new BinaryPrefixComparator(Bytes.toBytes("inf"))   //表中存在以inf打头的列族info,过滤结果为该列族所有行
                );

       //键值对元数据过滤-----qualifier过滤----字节数组完整匹配

        filter = new QualifierFilter(
                CompareOp.EQUAL ,
                new BinaryComparator(Bytes.toBytes("na"))   //表中不存在na列,过滤结果为空
                );
        filter = new QualifierFilter(
                CompareOp.EQUAL ,
                new BinaryPrefixComparator(Bytes.toBytes("na"))   //表中存在以na打头的列name,过滤结果为所有行的该列数据
        		);

        //基于列名(即Qualifier)前缀过滤数据的ColumnPrefixFilter
        filter = new ColumnPrefixFilter("na".getBytes());

        //基于列名(即Qualifier)多个前缀过滤数据的MultipleColumnPrefixFilter
        byte[][] prefixes = new byte[][] {Bytes.toBytes("na"), Bytes.toBytes("me")};
        filter = new MultipleColumnPrefixFilter(prefixes);

        //为查询设置过滤条件
        scan.setFilter(filter);

		scan.addFamily(Bytes.toBytes("base_info"));
		ResultScanner scanner = table.getScanner(scan);
		for(Result r : scanner){
			/**
			for(KeyValue kv : r.list()){
				String family = new String(kv.getFamily());
				System.out.println(family);
				String qualifier = new String(kv.getQualifier());
				System.out.println(qualifier);
				System.out.println(new String(kv.getValue()));
			}
			*/
			//直接从result中取到某个特定的value
			byte[] value = r.getValue(Bytes.toBytes("base_info"), Bytes.toBytes("name"));
			System.out.println(new String(value));
		}
		table.close();
	}

}

时间: 2024-10-12 08:43:43

hbase API操作范例的相关文章

HBase API 操作范例

package com.test.hbase.api; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.*; import org.apache.hadoop.hbase.client.*; import org.apache.hadoop.hbase.util.Bytes; import java.io.IOException; import java.util.ArrayList; imp

HBase API操作

1. 命名空间NameSpace 在关系数据库系统中,命名空间NameSpace指的是一个表的逻辑分组 ,同一分组中的各个表有类似的用途.命名空间的概念为即将到来的多租户特性打下基础:配额管理(Quota Management (HBASE-8410)):限制一个NameSpace可以使用的资源,资源包括region和table等命名空间安全管理(Namespace Security Administration (HBASE-9206)):提供了另一个层面的多租户安全管理Region服务器组(

HBase 6、用Phoenix Java api操作HBase

开发环境准备:eclipse3.5.jdk1.7.window8.hadoop2.2.0.hbase0.98.0.2.phoenix4.3.0 1.从集群拷贝以下文件:core-site.xml.hbase-site.xml.hdfs-site.xml文件放到工程src下 2.把phoenix的phoenix-4.3.0-client.jar和phoenix-core-4.3.0.jar添加到工程classpath 3.配置集群中各节点的hosts文件,把客户端的hostname:IP添加进去

hbase简单操作

hbase有hbase shell以及hbase 客户端api两种方式进行hbase数据库操作: 首先,hbase shell是在linux命令行进行操作,输入hbase shell命令,进入shell命令行. 输入 help  可以看到命令分组 上面是hbase的一些操作,要查看具体某一个操作,例如scan的使用方法,在具体的某一个创建的实例后使用help参数 比如:create 't1' ,'ft:h1' scan 't1' help 后就可以显示相应的scan的操作,根据帮助提示信息即可查

2、通过HBase API进行开发

一.将HBase的jar包及hbase-site.xml添加到IDE 1.到安装HBase集群的任意一台机器上找到HBase的安装目录,到lib目录下下载HBase需要的jar包,然后再到conf目录下下载hbase-site.xml. 2.在ide中新建一个java项目,然后再右击"项目名",新建2个文件夹,分别是"lib"和"conf" 3.将1步骤中下载的jar包放到2步骤中的lib目录下,并且将hbase-site.xml放到conf目录

HBase Shell操作

Hbase 是一个分布式的.面向列的开源数据库,其实现是建立在google 的bigTable 理论之上,并基于hadoop HDFS文件系统.     Hbase不同于一般的关系型数据库(RDBMS).是一种适用于非结构化数据存储的数据库,且Hbase是基于列的数据库. 下面的内容基于我们已经安装好hadoop.hbase. 一.hbase shell 介绍 hbase shell是用户和hbase 交互的接口之一,当然还可以通过其它方式比如java api等 下表列出了 hbase 基本命令

【甘道夫】HBase基本数据操作详解【完整版,绝对精品】

引言 之前详细写了一篇HBase过滤器的文章,今天把基础的表和数据相关操作补上. 本文档参考最新(截止2014年7月16日)的官方Ref Guide.Developer API编写. 所有代码均基于"hbase 0.96.2-hadoop2"版本编写,均实测通过. 欢迎转载,请注明来源: http://blog.csdn.net/u010967382/article/details/37878701 概述 对于建表,和RDBMS类似,HBase也有namespace的概念,可以指定表空

linux中mysql,mongodb,redis,hbase数据库操作

1.实验内容与完成情况:(实验具体步骤和实验截图说明) (一) MySQL 数据库操作 学生表 Student Name English Math Computer zhangsan 69 86 77 lisi 55 100 88 根据上面给出的 Student 表,在 MySQL 数据库中完成如下操作: (1)在 MySQL 中创建 Student 表,并录入数据: (2)用 SQL 语句输出 Student 表中的所有记录: (3)查询 zhangsan 的 Computer 成绩: (4)

HBase API 操 作

第 6 章 HBase API 操 作 6.1 环境准备       新建项目后在pom.xml 中添加依赖: 6.2 HBaseAPI 6.2.1       获取 Configuration 对象 6.2.2 判断表是否存在 6.2.3       创建表 —————————————————————————————                           6.2.4       删除表 6.2.5 向表中插入数据 6.2.6       删除多行数据 6.2.7       获取