基于Java的HBase客户端编程.doc

基于Java的HBase客户端编程本文以HBase 0.90.2为例，介绍如何在Windows系统，Eclipse IDE集成环境下，使用Java语言，进行HBase客户端编程，包含建立表、删除表、插入记录、删除记录、各种方式下的查询操作等。 AD： 本文以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中，如下所示为配置文件的一个示例： 1. 2. 3. hbase.rootdir4. hdfs:/hostname:9000/hbase5. 6. 7. hbase.cluster.distributed8. true9. 10. 11. hbase.zookeeper.quorum12. *.*.*.*,*.*.*.*,*.*.*.*13. 14. 15. hbase.defaults.for.version16. 0.90.217. 18. 3. 下面可以在Eclipse环境下进行HBase编程了。 3. HBase基本操作代码示例3.1 初始化配置1. privatestaticConfigurationconf=null;2. /*3. *初始化配置4. */5. static6. conf=HBaseConfiguration.create();7. 3.2 创建表1. /*2. *创建表操作3. *throwsIOException4. */5. publicvoidcreateTable(Stringtablename,Stringcfs)throwsIOException6. HBaseAdminadmin=newHBaseAdmin(conf);7. if(admin.tableExists(tablename)8. System.out.println(表已经存在！);9. 10. else11. HTableDescriptortableDesc=newHTableDescriptor(tablename);12. for(inti=0;icfs.length;i+)13. tableDesc.addFamily(newHColumnDescriptor(cfsi);14. 15. admin.createTable(tableDesc);16. System.out.println(表创建成功！);17. 18. 3.3 删除表1. /*2. *删除表操作3. *paramtablename4. *throwsIOException5. */6. publicvoiddeleteTable(Stringtablename)throwsIOException7. try8. HBaseAdminadmin=newHBaseAdmin(conf);9. admin.disableTable(tablename);10. admin.deleteTable(tablename);11. System.out.println(表删除成功！);12. catch(MasterNotRunningExceptione)13. e.printStackTrace();14. catch(ZooKeeperConnectionExceptione)15. e.printStackTrace();16. 17. 3.4 插入一行记录1. /*2. *插入一行记录3. *paramtablename4. *paramcfs5. */6. publicvoidwriteRow(Stringtablename,Stringcfs)7. try8. HTabletable=newHTable(conf,tablename);9. Putput=newPut(Bytes.toBytes(rows1);10. for(intj=0;jcfs.length;j+)11. put.add(Bytes.toBytes(cfsj),12. Bytes.toBytes(String.valueOf(1),13. Bytes.toBytes(value_1);14. table.put(put);15. 16. catch(IOExceptione)17. e.printStackTrace();18. 19. 3.5 删除一行记录1. /*2. *删除一行记录3. *paramtablename4. *paramrowkey5. *throwsIOException6. */7. publicvoiddeleteRow(Stringtablename,Stringrowkey)throwsIOException8. HTabletable=newHTable(conf,tablename);9. Listlist=newArrayList();10. Deleted1=newDelete(rowkey.getBytes();11. list.add(d1);12. table.delete(list);13. System.out.println(删除行成功！);14. 3.6 查找一行记录1. /*2. *查找一行记录3. *paramtablename4. *paramrowkey5. */6. publicstaticvoidselectRow(Stringtablename,StringrowKey)7. throwsIOException8. HTabletable=newHTable(conf,tablename);9. Getg=newGet(rowKey.getBytes();10. Resultrs=table.get(g);11. for(KeyValuekv:rs.raw()12. System.out.print(newString(kv.getRow()+);13. System.out.print(newString(kv.getFamily()+:);14. System.out.print(newString(kv.getQualifier()+);15. System.out.print(kv.getTimestamp()+);16. System.out.println(newString(kv.getValue();17. 18. 3.7 查询表中所有行1. /*2. *查询表中所有行3. *paramtablename4. */5. publicvoidscaner(Stringtablename)6. try7. HTabletable=newHTable(conf,tablename);8. Scans=newScan();9. ResultScannerrs=table.getScanner(s);10. for(Resultr:rs)11. KeyValuekv=r.raw();12. for(inti=0;ikv.length;i+)13. System.out.print(newString(kvi.getRow()+);14. System.out.print(newString(kvi.getFamily()+:);15. System.out.print