Hbase -- Java客戶端編程

本文以HBase 0.90.2為例，介紹如何在Windows系統，Eclipse IDE集成環境下，使用Java語言，進行HBase客戶端編程，包含建立表、刪除表、插入記錄、刪除記錄、各種方式下的查詢操作等。

1. 準備工作
   
   
   1、下載后安裝jdk包（這里使用的是jdk-6u10-rc2-bin-b32-windows-i586-p-12_sep_2008）；
   2、下載eclipse，解壓到本地（這里使用的是eclipse-java-helios-SR2-win32）；
   3、下載HBase包，解壓安裝包到本地（這里使用的是hbase-0.90.2）。
   
2. 搭建開發環境
   
   
   1、運行Eclipse，創建一個新的Java工程“HBaseClient”，右鍵項目根目錄，選擇 “Properties”->“Java Build Path”->“Library”->“Add External JARs”，將HBase解壓后根目錄下的hbase-0.90.2.jar、hbase-0.90.2-tests.jar和lib子目錄下所有jar 包添加到本工程的Classpath下。
   2、按照步驟1中的操作，將自己所連接的HBase的配置文件hbase-site.xml添加到本工程的Classpath中，如下所示為配置文件的一個示例：
   

    <configuration>
   <property>
   <name>hbase.rootdir</name>
   <value>hdfs://hostname:9000/hbase</value>
   </property>
   <property>
   <name>hbase.cluster.distributed</name>
   <value>true</value>
   </property>
   <property>
   <name>hbase.zookeeper.quorum</name>
   <value>*.*.*.*, *.*.*.*, *.*.*.*</value>
   </property>
   <property skipInDoc="true">
   <name>hbase.defaults.for.version</name>
   <value>0.90.2</value>
   </property>
   </configuration>

   
   
   3、下面可以在Eclipse環境下進行HBase編程了。
   
3. HBase基本操作代碼示例
   
   
   3.1 初始化配置
   
   

   privatestatic Configuration conf =null;
   /**
   
   初始化配置
   */
   static {
   conf = HBaseConfiguration.create();
   }
   
   

3.2 創建表

/**

• 創建表操作
• @throws IOException */ publicvoid 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("表創建成功！"); } }

3.3 刪除表

/**

• 刪除表操作
• @param tablename
• @throws IOException */ publicvoid 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(); } catch (ZooKeeperConnectionException e) { e.printStackTrace(); } }

3.4 插入一行記錄

/**

• 插入一行記錄
• @param tablename
• @param cfs */ publicvoid 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(); } }

3.5 刪除一行記錄

/**

• 刪除一行記錄
• @param tablename
• @param rowkey
• @throws IOException */ publicvoid 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(list); System.out.println("刪除行成功！"); }

3.6 查找一行記錄

/**

• 查找一行記錄
• @param tablename
• @param rowkey */ publicstaticvoid 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())); } }

3.7 查詢表中所有行

/**

• 查詢表中所有行
• @param tablename */ publicvoid 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(); } }</pre>