HBase Java API使用操作例子


通过对HBase API的使用，下面例子举例了常见对HBase的操作，如下所示：

  2. package net.bkjia.www;  
  4.   
  5. import org.apache.Hadoop.conf.Configuration;  
  6. import org.apache.hadoop.hbase.HBaseConfiguration;  
  7. import org.apache.hadoop.hbase.HColumnDescriptor;  
  8. import org.apache.hadoop.hbase.HTableDescriptor;  
  9. import org.apache.hadoop.hbase.KeyValue;  
  10. import org.apache.hadoop.hbase.client.HBaseAdmin;  
  11. import org.apache.hadoop.hbase.client.HTable;  
  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.io.BatchUpdate;  
  16.   
  17. public class HBaseDBDao {  
  18.       
  19.     //定义配置对象HBaseConfiguration   
  20.     static HBaseConfiguration cfg =null;  
  21.     static {  
  22.         Configuration configuration = new Configuration();  
  23.         cfg = new HBaseConfiguration(configuration);  
  24.     }  
  25.       
  26.     //创建一张表，指定表名，列族   
  27.     public static void createTable(String tableName,String columnFarily)throws Exception{  
  28.         HBaseAdmin admin = new HBaseAdmin(cfg);  
  29.         if(admin.tableExists(tableName)){  
  30.             System.out.println(tableName+"不存在！");  
  31.             System.exit(0);  
  32.         }else{  
  33.             HTableDescriptor  tableDesc = new HTableDescriptor(tableName);  
  34.             tableDesc.addFamily(new HColumnDescriptor(columnFarily+":"));  
  35.             System.out.println("创建表成功！");  
  36.         }  
  37.     }  
  38.       
  39.     //添加数据，通过HTable。和BatchUpdate为已经存在的表添加数据data   
  40.     public static void addData(String tableName,String row,String columnFamily,String column,String data)throws Exception{  
  41.         HTable table = new HTable(cfg,tableName);  
  42.         BatchUpdate update = new BatchUpdate(row);  
  43.         update.put(columnFamily+":"+column, data.getBytes());  
  44.         table.commit(update);  
  45.         System.out.println("添加成功！");  
  46.     }  
  47.       
  48.     //显示所有数据，通过HTable Scan类获取已有表的信息   
  49.     public static void getAllData(String tableName)throws Exception{  
  50.         HTable table = new HTable(cfg,tableName);  
  51.         Scan scan = new Scan();  
  52.         ResultScanner rs = table.getScanner(scan);  
  53.         for(Result r:rs){  
  54.             for(KeyValue kv:r.raw()){  
  55.                 System.out.println(new String(kv.getColumn())+new String(kv.getValue()));  
  56.             }  
  57.         }  
  58.     }  
  59.       
  60.     //测试函数   
  61.     public static void main(String[] args){  
  62.         try{  
  63.             String tableName = "student";  
  64.             HBaseDBDao.createTable(tableName, "c1");  
  65.             HBaseDBDao.addData(tableName, "row1", "c1", "1", "this is row 1 column c1:c1");  
  66.             HBaseDBDao.getAllData(tableName);  
  67.         }catch(Exception e){  
  68.             e.printStackTrace();  
  69.         }  
  70.     }  
  71. }  

相关内容