1 package Hbase;
  2 
  3 import java.io.IOException;
  4 import org.apache.hadoop.conf.Configuration;
  5 import org.apache.hadoop.hbase.Cell;
  6 import org.apache.hadoop.hbase.CellUtil;
  7 import org.apache.hadoop.hbase.HBaseConfiguration;
  8 import org.apache.hadoop.hbase.client.Delete;
  9 import
 
 org.apache.hadoop.hbase.client.Get;
 10 import org.apache.hadoop.hbase.client.HTable;
 11 import org.apache.hadoop.hbase.client.Put;
 12 import org.apache.hadoop.hbase.client.Result;
 13 import org.apache.hadoop.hbase.client.ResultScanner;
 14 import org.apache.hadoop.hbase.client.Scan;
 15 import org.apache.hadoop.hbase.util.Bytes;
 
 16 import org.apache.hadoop.hdfs.protocol.proto.ClientNamenodeProtocolProtos.GetDataEncryptionKeyRequestProto;
 17 import org.apache.hadoop.io.IOUtils;
 18 
 19 public class HbaseOperation {
 20 
 21     public static HTable getHTableByTableName(String tableName) throws IOException {
 22         // get instance of default configuration
 

 23         Configuration configuration = HBaseConfiguration.create();
 24         // get table instance
 25         HTable table = new HTable(configuration, tableName);
 26         
 27         return table;
 28     }
 29     
 30     public static void getData(String tableName) throws IOException{
 31         //String tableName = "user";
 32         HTable table = getHTableByTableName(tableName);
 33         //create get with rowkey
 34         Get rowkey = new Get(Bytes.toBytes("10001"));
 35         //****************************************************
 36         //add column
 37         rowkey.addColumn(//
 38                 Bytes.toBytes("info"),//
 39                 Bytes.toBytes("name")
 40                 );
 41         
 42         rowkey.addColumn(//
 43                 Bytes.toBytes("info"),//
 44                 Bytes.toBytes("age")
 45                 );
 46         
 47         //get data
 48         Result result = table.get(rowkey);
 49         //key : rewkey + cf +c +version
 50         //value :value
 51         for(Cell cell:result.rawCells()){
 52             System.out.println(//
 53                Bytes.toString(CellUtil.cloneFamily(cell)) + ":" //
 54                + Bytes.toString(CellUtil.cloneQualifier(cell)) + "-->" //
 55                + Bytes.toString(CellUtil.cloneValue(cell))
 56             );
 57         }
 58         //table close
 59         table.close();
 60 
 61     }
 62     
 63     public static void putData(String tableName) throws IOException {
 64         //String tableName = "user";
 65         HTable table = getHTableByTableName(tableName);
 66         
 67         Put put = new Put(Bytes.toBytes("10003"));
 68         //add a column with value
 69         put.add(//
 70             Bytes.toBytes("info"),//
 71             Bytes.toBytes("name"),//
 72             Bytes.toBytes("wangwu")//
 73             );
 74         
 75         put.add(//
 76                 Bytes.toBytes("info"),//
 77                 Bytes.toBytes("age"),//
 78                 Bytes.toBytes("26")//
 79                 );
 80         
 81         put.add(//
 82                 Bytes.toBytes("info"),//
 83                 Bytes.toBytes("address"),//
 84                 Bytes.toBytes("tianjing")//
 85                 );
 86         
 87         table.put(put);
 88         
 89         table.close();
 90     }
 91     
 92     public static void deleteData(String tableName) throws IOException {
 93         HTable table = getHTableByTableName(tableName);
 94         Delete delete = new Delete(Bytes.toBytes("10003"));
 95         //delete a certain column 
 96 //        delete.deleteColumn(Bytes.toBytes("info"), //
 97 //                Bytes.toBytes("address"));
 98         
 99         //delete a familycolumn
100                 delete.deleteFamily(Bytes.toBytes("info"));
101                 
102         table.delete(delete);
103         table.close();
104     }
105 
106     public static void main(String[] args) throws IOException {
107         String tableName = "user";
108 //        HTable table = getHTableByTableName(tableName);
109 //        getData(tableName);
110 //        putData(tableName);
111 //        deleteData(tableName);
112         
113         HTable table = null;
114         ResultScanner resultScanner = null;
115         try{
116             table = getHTableByTableName(tableName);
117             
118             Scan scan = new Scan();
119             //the range of scan
120             scan.setStartRow(Bytes.toBytes("10001"));
121             scan.setStartRow(Bytes.toBytes("10004"));
122             
123             //scan the certain column or familycolumn
124 //            scan.addColumn(family, qualifier);
125 //            scan.addFamily(family);
126             
127             //another way to scan
128             //Scan scan2 = new Scan(startRow, stopRow);
129             
130             //PrefixFilter
131             //PageFilter
132 //            scan.setFilter(filter);
133             
134 //            scan.setCacheBlocks(cacheBlocks);
135 //            scan.setCaching(caching);
136             
137             resultScanner = table.getScanner(scan);
138             for (Result result:resultScanner) {
139                 System.out.println(Bytes.toString(result.getRow()));
140                 //System.out.println(result);
141                 
142                 for(Cell cell:result.rawCells()){
143                     System.out.println(//
144                        Bytes.toString(CellUtil.cloneFamily(cell)) + ":" //
145                        + Bytes.toString(CellUtil.cloneQualifier(cell)) + "-->" //
146                        + Bytes.toString(CellUtil.cloneValue(cell))
147                     );
148                 }
149                 System.out.println("------------------------------");
150             }
151         }catch(Exception e){
152             e.printStackTrace();
153         }finally{
154             IOUtils.closeStream(resultScanner);
155             IOUtils.closeStream(table);
156         }
157     }
158 }