Hbase API开发实例（Java版）

import java.io.IOException; import java.io.ByteArrayOutputStream; import java.io.DataOutputStream; import java.io.ByteArrayInputStream; import java.io.DataInputStream; import java.util.Map; import java.util.ArrayList; import java.util.List; import org.apache.hadoop.io.Writable; import org.apache.hadoop.io.IntWritable; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.HBaseConfiguration; import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.client.HTable; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.client.Delete; import org.apache.hadoop.hbase.util.*; import org.apache.hadoop.hbase.KeyValue; import org.apache.hadoop.hbase.util.Writables; 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.MasterNotRunningException; //import org.apache.hadoop.hbase.ZooKeeperConnectionException; public class HBaseHandler {     private static HBaseConfiguration conf = null;     /**      * 初始化配置      */     static {        //conf = HBaseConfiguration.create();          conf = new HBaseConfiguration();          conf.addResource("hbase-site.xml");     }     /**      * @param args      * @throws IOException      */     public static void main(String[] args) throws IOException {         // TODO Auto-generated method stub         System.out.println("Helloworld");         String[] cfs;         cfs = new String[1];         cfs[0] = "Hello";         createTable("Test",cfs);     }     /**      * 创建表操作      * @throws IOException      */     public static void createTable(String tablename, String[] cfs) throws IOException {         HBaseAdmin admin = new HBaseAdmin(conf);         if (admin.tableExists(tablename)) {             System.out.println("表已经存在！");         }         else {             HTableDescriptor tableDesc = new HTableDescriptor(tablename);             for (int i = 0; i < cfs.length; i++) {                 tableDesc.addFamily(new HColumnDescriptor(cfs[i]));             }             admin.createTable(tableDesc);             System.out.println("表创建成功！");         }     }         /**      * 删除表操作      * @param tablename      * @throws IOException      */     public static void deleteTable(String tablename) throws IOException     {         try {             HBaseAdmin admin = new HBaseAdmin(conf);             admin.disableTable(tablename);             admin.deleteTable(tablename);             System.out.println("表删除成功！");         }         catch (MasterNotRunningException e)         {             e.printStackTrace();         }     }     /**      * 插入一行记录      * @param tablename      * @param cfs      */     public static void writeRow(String tablename, String[] cfs) {         try {             HTable table = new HTable(conf, tablename);             Put put = new Put(Bytes.toBytes("rows1"));             for (int j = 0; j < cfs.length; j++) {                 put.add(Bytes.toBytes(cfs[j]),                         Bytes.toBytes(String.valueOf(1)),                         Bytes.toBytes("value_1"));                 table.put(put);             }         } catch (IOException e) {             e.printStackTrace();         }     }     /**      * 删除一行记录      * @param tablename      * @param rowkey      * @throws IOException      */     public static void deleteRow(String tablename, String rowkey) throws IOException {         HTable table = new HTable(conf, tablename);         List list = new ArrayList();         Delete d1 = new Delete(rowkey.getBytes());         list.add(d1);         table.delete(d1);         System.out.println("删除行成功！");     }     /**      * 查找一行记录      * @param tablename      * @param rowkey      */     public static void selectRow(String tablename, String rowKey)             throws IOException {         HTable table = new HTable(conf, tablename);         Get g = new Get(rowKey.getBytes());         Result rs = table.get(g);         for (KeyValue kv : rs.raw()) {             System.out.print(new String(kv.getRow()) + "  ");             System.out.print(new String(kv.getFamily()) + ":");             System.out.print(new String(kv.getQualifier()) + "  ");             System.out.print(kv.getTimestamp() + "  ");             System.out.println(new String(kv.getValue()));         }     }     /**      * 查询表中所有行      * @param tablename      */     public static void scaner(String tablename) {         try {             HTable table = new HTable(conf, tablename);             Scan s = new Scan();             ResultScanner rs = table.getScanner(s);             for (Result r : rs) {                 KeyValue[] kv = r.raw();                 for (int i = 0; i < kv.length; i++) {                     System.out.print(new String(kv[i].getRow()) + "  ");                     System.out.print(new String(kv[i].getFamily()) + ":");                     System.out.print(new String(kv[i].getQualifier()) + "  ");                     System.out.print(kv[i].getTimestamp() + "  ");                     System.out.println(new String(kv[i].getValue()));                 }             }         } catch (IOException e)         {             e.printStackTrace();         }     } }

说明： HBaseConfiguration: 用于告诉client如何连接，连接到哪个HBase的服务器上。 HTable：代表一个HBase表格。 BatchUpdate：用于表格中一行的更新。包括添加某个列，修改某列的值，删除某列等。 commit：table的一个方法。代表某个BatchUpdate操作可以生效了。类似于数据库中的commit操作。

Cell：table中对应某个（行key, 列值，时间戳）下的单元格值。 获取Cell的方法。For example: table.get("myRow", "myColumnFamily:columnQualifier1");

scanner：用于遍历表格。 rowResult：遍历过程当中保存某行信息。