hbase-0.90.2简单查询数据java编程，hbase-0.90.2java,所需软件包：common

hbase-0.90.2简单查询数据java编程，hbase-0.90.2java,所需软件包：common

所需软件包：

commons-codec-1.4.jar

commons-logging-1.1.1.jar

hadoop-0.20.2-core.jar

hbase-0.90.2.jar

log4j-1.2.16.jar

zookeeper-3.3.2.jar

import java.io.IOException;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.KeyValue;import org.apache.hadoop.hbase.client.Get;import org.apache.hadoop.hbase.client.HTable;import org.apache.hadoop.hbase.client.Result;import org.apache.hadoop.hbase.client.ResultScanner;import org.apache.hadoop.hbase.client.Scan;import org.apache.hadoop.hbase.filter.CompareFilter.CompareOp;import org.apache.hadoop.hbase.filter.FilterList;import org.apache.hadoop.hbase.filter.SingleColumnValueFilter;import org.apache.hadoop.hbase.util.Bytes;public class mHbaseSelectd{    public static Configuration configuration = null;    static    {        configuration = HBaseConfiguration.create();        configuration.set("hbase.master", "192.168.0.201:60000");        configuration.set("hbase.zookeeper.quorum", "192.168.0.201,192.168.0.202,192.168.0.203");        configuration.set("hbase.zookeeper.property.clientPort", "2181");    }    public static void selectRowKey(String tablename, String rowKey) throws IOException    {        HTable table = new HTable(configuration, tablename);        Get g = new Get(rowKey.getBytes());        Result rs = table.get(g);        for (KeyValue kv : rs.raw())        {            System.out.println("--------------------" + new String(kv.getRow()) + "----------------------------");            System.out.println("Column Family: " + new String(kv.getFamily()));            System.out.println("Column       :" + new String(kv.getQualifier()) + "t");            System.out.println("value        : " + new String(kv.getValue()));        }    }    public static void selectRowKeyFamily(String tablename, String rowKey, String family) throws IOException    {        HTable table = new HTable(configuration, tablename);        Get g = new Get(rowKey.getBytes());        g.addFamily(Bytes.toBytes(family));        Result rs = table.get(g);        for (KeyValue kv : rs.raw())        {            System.out.println("--------------------" + new String(kv.getRow()) + "----------------------------");            System.out.println("Column Family: " + new String(kv.getFamily()));            System.out.println("Column       :" + new String(kv.getQualifier()) + "t");            System.out.println("value        : " + new String(kv.getValue()));        }    }    public static void selectRowKeyFamilyColumn(String tablename, String rowKey, String family, String column)            throws IOException    {        HTable table = new HTable(configuration, tablename);        Get g = new Get(rowKey.getBytes());        g.addColumn(family.getBytes(), column.getBytes());        Result rs = table.get(g);        for (KeyValue kv : rs.raw())        {            System.out.println("--------------------" + new String(kv.getRow()) + "----------------------------");            System.out.println("Column Family: " + new String(kv.getFamily()));            System.out.println("Column       :" + new String(kv.getQualifier()) + "t");            System.out.println("value        : " + new String(kv.getValue()));        }    }    public static void selectFilter(String tablename, List<String> arr) throws IOException    {        HTable table = new HTable(configuration, tablename);        Scan scan = new Scan();// 实例化一个遍历器        FilterList filterList = new FilterList(); // 过滤器List        for (String v : arr)        { // 下标0为列簇，1为列名，3为条件            String[] wheres = v.split(",");            filterList.addFilter(new SingleColumnValueFilter(// 过滤器                    wheres[0].getBytes(), wheres[1].getBytes(),                    CompareOp.EQUAL,// 各个条件之间是" and "的关系                    wheres[2].getBytes()));        }        scan.setFilter(filterList);        ResultScanner ResultScannerFilterList = table.getScanner(scan);        for (Result rs = ResultScannerFilterList.next(); rs != null; rs = ResultScannerFilterList.next())        {            for (KeyValue kv : rs.list())            {                System.out.println("--------------------" + new String(kv.getRow()) + "----------------------------");                System.out.println("Column Family: " + new String(kv.getFamily()));                System.out.println("Column       :" + new String(kv.getQualifier()) + "t");                System.out.println("value        : " + new String(kv.getValue()));            }        }    }    public static void main(String[] args) throws Exception    {        System.out.println("------------------------行键  查询----------------------------------");        selectRowKey("riapguh", "用户A");        selectRowKey("riapguh", "用户B");        System.out.println("------------------------行键+列簇 查询----------------------------------");        selectRowKeyFamily("riapguh", "用户A", "user");        selectRowKeyFamily("riapguh", "用户B", "user");        System.out.println("------------------------行键+列簇+列名 查询----------------------------------");        selectRowKeyFamilyColumn("riapguh", "用户A", "user", "user_code");        selectRowKeyFamilyColumn("riapguh", "用户B", "user", "user_code");        System.out.println("------------------------条件 查询----------------------------------");        List<String> arr = new ArrayList<String>();        arr.add("dpt,dpt_code,d_001");        arr.add("user,user_code,u_0001");        selectFilter("riapguh", arr);    }}//该片段来自于http://byrx.net