HBase1.0.1.1 API与原来有所不同

 1 package com.felix.hbaseapi_test;
 2 
 3 /*   
        这是旧版的 API操作
    */
16 public class hbaseapifelix {
17 
18     public static final String TABLE_NAME = "testapi";
19     public static final String COLUMNFAMILY_NAME = "cf";
20     public static final String ROW_KEY = "rowkey1";
21     
22     public static void main(String[] args) throws Exception {
23         Configuration conf = HBaseConfiguration.create();
24         HBaseAdmin admin=new HBaseAdmin(conf);
51         createtable(admin);
53         HTable htable=new HTable(conf, TABLE_NAME);
54         
55         put(htable,"age","25");
56         put(htable,"age","26");
57         put(htable,"age","27");
58         put(htable,"age","28");
59         
60         //Get
61         Get get=new Get(ROW_KEY.getBytes());
62         htable.get(get);
63         
64         //scan
65         Scan scan=new Scan();
66         ResultScanner scanner = htable.getScanner(scan);
67     }
68 
69     private static void put(HTable htable,String column,String value) throws IOException {
70         Put put=new Put(ROW_KEY.getBytes());
71         put.addColumn(COLUMNFAMILY_NAME.getBytes(), column.getBytes(), value.getBytes());
72         htable.put(put);
73     }
74 
75     private static void createtable(HBaseAdmin admin) throws IOException {
76         HTableDescriptor desc = new HTableDescriptor(TABLE_NAME);
77         HColumnDescriptor family = new HColumnDescriptor(COLUMNFAMILY_NAME);
78         desc.addFamily(family);
79        family.setMaxVersions(3);
80         if (!admin.tableExists(TABLE_NAME)) {
81             //该表不存在，直接创建
82             admin.createTable(desc);
83         }else{
84             //该表存在，删除后再创建
85             if(!admin.isTableAvailable(TABLE_NAME)){
86                 //该表disable，直接删除
87                 admin.deleteTable(TABLE_NAME);
88             }else{
89                 //该表enable,先disable,再删除
90                 admin.disableTable(TABLE_NAME);
91                 admin.deleteTable(TABLE_NAME);
92             }
93             admin.createTable(desc);
94         }
95     }
96 
97 }

  1 package com.felix.hbaseapi_test;
  2 
  3 
  4 import java.io.IOException;
  5 
  6 import org.apache.hadoop.conf.Configuration;
  7 import org.apache.hadoop.hbase.HBaseConfiguration;
  8 import org.apache.hadoop.hbase.HColumnDescriptor;
  9 import org.apache.hadoop.hbase.HTableDescriptor;
 10 import org.apache.hadoop.hbase.TableName;
 11 import org.apache.hadoop.hbase.client.Admin;
 12 import org.apache.hadoop.hbase.client.Connection;
 13 import org.apache.hadoop.hbase.client.ConnectionFactory;
 14 import org.apache.hadoop.hbase.client.Get;
 15 import org.apache.hadoop.hbase.client.Put;
 16 import org.apache.hadoop.hbase.client.Result;
 17 import org.apache.hadoop.hbase.client.ResultScanner;
 18 import org.apache.hadoop.hbase.client.Scan;
 19 import org.apache.hadoop.hbase.client.Table;
 20 
 21 
 22 public class hbaseapifelix {
 23 
 24     public static final String TABLE_NAME = "testapi";
 25     public static final String COLUMNFAMILY_NAME = "cf";
 26     public static final String ROW_KEY = "rowkey1";
 27     
 28     public static void main(String[] args) throws Exception {
 29         Configuration conf = HBaseConfiguration.create();
 30         //下面的配置，在configuration文件中都配置过了这里没必要配置，也不方便
 31         //conf.set("hbase.rootdir", "hdfs://centos:9000/hbase");
 32         //conf.set("hbase.zookeeper.quorum","centos");
 33         //conf.set("hbase.zookeeper.property.clientPort", "2181");
 34     
 35          Connection connection = ConnectionFactory.createConnection(conf);
 36          Admin admin = connection.getAdmin();
 37          Table table = connection.getTable(TableName.valueOf("user"));
 38          TableName name = table.getName();
 39          
 40          initBeforeCreate(admin, name);
 41          createTable(admin, table);
 42         
 43          try {
 44              Put put=new Put("rowkey".getBytes());
 45              put.addColumn(COLUMNFAMILY_NAME.getBytes(), "age".getBytes(), "25".getBytes());
 46              put.addColumn(COLUMNFAMILY_NAME.getBytes(), "age".getBytes(), "26".getBytes());
 47              put.addColumn(COLUMNFAMILY_NAME.getBytes(), "age".getBytes(), "27".getBytes());
 48              put.addColumn(COLUMNFAMILY_NAME.getBytes(), "age".getBytes(), "28".getBytes());
 49              table.put(put);
 50          } finally {
 51            table.close();
 52            connection.close();
 53          }
 54          
 55         
 56         Get get = new Get(ROW_KEY.getBytes());
 57         Result result = table.get(get);
 58         
 59         Scan scan=new Scan();
 60         ResultScanner scanner = table.getScanner(scan);
 61          
 62     /*    HBaseAdmin admin=new HBaseAdmin(conf);
 63         createtable(admin);
 64         
 65         HTable htable=new HTable(conf, TABLE_NAME);
 66         
 67         put(htable,"age","25");
 68         put(htable,"age","26");
 69         put(htable,"age","27");
 70         put(htable,"age","28");
 71         
 72         //Get
 73         Get get=new Get(ROW_KEY.getBytes());
 74         htable.get(get);
 75         
 76         //scan
 77         Scan scan=new Scan();
 78         ResultScanner scanner = htable.getScanner(scan);*/
 79     }
 80 
 81     private static void initBeforeCreate(Admin admin, TableName name)
 82             throws IOException {
 83         /*创建前存在就删除
 84          * */
 85         if(admin.tableExists(name)){
 86              if(admin.isTableEnabled(name)){
 87                  admin.disableTable(name);
 88              }
 89              admin.deleteTable(name);
 90          }
 91     }
 92 
 93     private static void createTable(Admin admin, Table table)
 94             throws IOException {
 95         HTableDescriptor desc=new HTableDescriptor(table.getName());
 96         HColumnDescriptor family=new HColumnDescriptor(COLUMNFAMILY_NAME);
 97         family.setMaxVersions(3);
 98         family.setMinVersions(0);
 99         desc.addFamily(family);
100         admin.createTable(desc);
101     }
102 
103     /*private static void put(HTable htable,String column,String value) throws IOException {
104         Put put=new Put(ROW_KEY.getBytes());
105         put.addColumn(COLUMNFAMILY_NAME.getBytes(), column.getBytes(), value.getBytes());
106         htable.put(put);
107     }
108 
109     private static void createtable(HBaseAdmin admin) throws IOException {
110         HTableDescriptor desc = new HTableDescriptor(TABLE_NAME);
111         HColumnDescriptor family = new HColumnDescriptor(COLUMNFAMILY_NAME);
112         desc.addFamily(family);
113        family.setMaxVersions(3);
114         if (!admin.tableExists(TABLE_NAME)) {
115             //该表不存在，直接创建
116             admin.createTable(desc);
117         }else{
118             //该表存在，删除后再创建
119             if(!admin.isTableAvailable(TABLE_NAME)){
120                 //该表disable，直接删除
121                 admin.deleteTable(TABLE_NAME);
122             }else{
123                 //该表enable,先disable,再删除
124                 admin.disableTable(TABLE_NAME);
125                 admin.deleteTable(TABLE_NAME);
126             }
127             admin.createTable(desc);
128         }
129     }*/
130 
131 }