Hbase的表查询操作_好了，ap_查询hbase表数据

网络投稿 02-07 6065

1.scan

2.get

1.filterBySingleColumnValueFilter(String tablename, String strF, String strC, String strClass)

1.1基本代码

1.2? ?过滤值的大小范围

RegexStringComparator

SubstringComparator

BinaryPrefixComparator

比较运算符

LESS <

LESS_OR_EQUAL <=

EQUAL =

NOT_EQUAL <>

GREATER_OR_EQUAL >=

GREATER >

NO_OP 排除所有

1.scan

可以不用输入rowkey,能按照一定的规则查出来对应的rowkey和值

public void scan(String tablename,String cf,String column) throws Exception{ HTable table=new HTable(conf,tablename); Scan s=new Scan(); s.setStartRow(Bytes.toBytes("0"));//可以限定rowkey的范围，字典序 s.setStopRow(Bytes.toBytes("g")); // s.addColumn(Bytes.toBytes("info"), Bytes.toBytes("name")); ResultScanner res=table.getScanner(s); for(Result r:res) { byte[] row=r.getRow(); byte[] val=r.getValue(Bytes.toBytes(cf), Bytes.toBytes(column)); System.out.println("Scan:"+Bytes.toString(row)+"的"+ column +" values is "+Bytes.toString(val)); } res.close(); table.close(); }

2.get

需要传入这4个字段，能找出对应的值

String tablename,String rowkey,String cf(列族),String cq(列限定符)

public void get(String tablename,String row,String info,String name) throws Exception{ HTable table=new HTable(conf,tablename); Get g=new Get(Bytes.toBytes(row)); Result result = table.get(g); byte[] val = result.getValue(Bytes.toBytes(info),Bytes.toBytes(name)); System.out.println(info+" "+name+" "+"Values =" + Bytes.toString(val)); }

?下面是一些过滤器的使用

1.filterBySingleColumnValueFilter(String tablename, String strF, String strC, String strClass) 1.1基本代码 public void filterBySingleColumnValueFilter(String tablename, String strF, String strC, String strClass) throws Exception { HTable table = new HTable(conf, tablename); Scan s = new Scan(); SingleColumnValueFilter sf = new SingleColumnValueFilter(Bytes.toBytes(strF), Bytes.toBytes(strC), CompareOp.NOT_EQUAL, Bytes.toBytes(strClass)); s.setFilter(sf); ResultScanner rs = table.getScanner(s); for (Result r : rs) { byte[] row = r.getRow(); byte[] value = r.getValue(Bytes.toBytes(strF), Bytes.toBytes(strC)); System.out.println("Filter: " + Bytes.toString(row) + "的 " + strC + " " + Bytes.toString(value)); } rs.close(); table.close(); }

?好像不能设置多个列族。。。

1.2? ?过滤值的大小范围 public void filterBySingleColumnValueFilter(String tablename, String strF, String strC,String dayu,String xiaoyu) throws Exception { HTable table = new HTable(conf, tablename); Scan s = new Scan(); FilterList filterList = new FilterList(FilterList.Operator.MUST_PASS_ALL); //组成区间过滤 SingleColumnValueFilter filter1 = new SingleColumnValueFilter(Bytes.toBytes(strF), Bytes.toBytes(strC), CompareOp.LESS_OR_EQUAL,Bytes.toBytes(xiaoyu)); SingleColumnValueFilter filter2 = new SingleColumnValueFilter(Bytes.toBytes(strF), Bytes.toBytes(strC), CompareOp.GREATER_OR_EQUAL,Bytes.toBytes(dayu)); filterList.addFilter(filter1); filterList.addFilter(filter2); s.setFilter(filterList); ResultScanner rs = table.getScanner(s); for (Result r : rs) { byte[] row = r.getRow(); byte[] value = r.getValue(Bytes.toBytes(strF), Bytes.toBytes(strC)); System.out.println("Filter: " + Bytes.toString(row) + "的 " + strC + " " + Bytes.toString(value)); } rs.close(); table.close(); }

?关键代码

SingleColumnValueFilter filter1 = ? ? ? ? ? ? new SingleColumnValueFilter(Bytes.toBytes(strF), Bytes.toBytes(strC), CompareOp.LESS_OR_EQUAL,Bytes.toBytes(xiaoyu)); ? ? ?SingleColumnValueFilter filter2 = ? ? ? ? ? ? new SingleColumnValueFilter(Bytes.toBytes(strF), Bytes.toBytes(strC), CompareOp.GREATER_OR_EQUAL,Bytes.toBytes(dayu));?

可设置rowkey的范围以及返回的条数

Filter filter = new PageFilter(2); // Hbase获取前2条记录,只能放到后面，在追加的列主前面无效 s.setFilter(filter); s.setStartRow(Bytes.toBytes("0")); s.setStopRow(Bytes.toBytes("3"));

?注意：追加列族，如果不写，就默认追加全部，如果写了，就默认查出来的数据就是你追加的数据限定，不会出现其他的

s.addColumn(Bytes.toBytes("info"), Bytes.toBytes(strC));//追加列族和列 s.addColumn(Bytes.toBytes("info"), Bytes.toBytes("sex"));//追加列族和列

下面我举个例子：

?这个是我的表，如果我只追加scoreinfo,

我想查询sex这一列就查不到

设置过滤器"scoreinfo:60-70的数据，RegexStringComparator匹配正则表达式?

RegexStringComparator RegexStringComparator comp =new RegexStringComparator("^[67][0-9]$"); SingleColumnValueFilter filter_zz = new SingleColumnValueFilter(Bytes.toBytes(strF), Bytes.toBytes(strC), CompareOp.EQUAL, comp); s.setFilter(filter_zz);

? 找出来scoreinfo中包含6的数字

SubstringComparator SubstringComparator comp_con = new SubstringComparator("6");//包含6 SingleColumnValueFilter filter_con = new SingleColumnValueFilter(Bytes.toBytes(strF), Bytes.toBytes(strC), CompareOp.EQUAL, comp_con); s.setFilter(filter_con); BinaryPrefixComparator

匹配开头，前缀二进制比较器，找出6开头的数据

BinaryPrefixComparator comp_pre =new BinaryPrefixComparator("8".getBytes());//以6开头的 SingleColumnValueFilter filter_pre = new SingleColumnValueFilter(Bytes.toBytes(strF), Bytes.toBytes(strC), CompareOp.EQUAL, comp_pre); // s.setFilter(filter_pre);

我想过滤60到70之间的数据，可以怎么写呢？

方法一：

直接在得到的结果里面加一个判断函数：

ResultScanner rs = table.getScanner(s); for (Result r : rs) { byte[] row = r.getRow(); byte[] value = r.getValue(Bytes.toBytes(strF), Bytes.toBytes(strC)); if(Integer.valueOf(Bytes.toString(value))>60&&Integer.valueOf(Bytes.toString(value))<70) { System.out.println("Filter: " + Bytes.toString(row) + "的 " +"列族是"+strF+" cq是"+ strC + " 值是 " + Integer.valueOf(Bytes.toString(value))); }

方法二，用正则表达式，过滤找出60到70的数据

RegexStringComparator comp =new RegexStringComparator("^[67][0-9]$"); SingleColumnValueFilter filter_zz = new SingleColumnValueFilter(Bytes.toBytes(strF), Bytes.toBytes(strC), CompareOp.EQUAL, comp); s.setFilter(filter_zz);

方法三，用比较器，但是有些许问题呢，比如我有个数据是666，它字典序。。。

FilterList filterList = new FilterList(FilterList.Operator.MUST_PASS_ALL); //组成区间过滤 SingleColumnValueFilter filter1 = new SingleColumnValueFilter(Bytes.toBytes(strF), Bytes.toBytes(strC), CompareOp.LESS_OR_EQUAL,Bytes.toBytes("70")); SingleColumnValueFilter filter2 = new SingleColumnValueFilter(Bytes.toBytes(strF), Bytes.toBytes(strC), CompareOp.GREATER_OR_EQUAL,Bytes.toBytes("60")); filterList.addFilter(filter1); filterList.addFilter(filter2); s.setFilter(filterList);