基于Java的HBase客户端编程

本文以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中，如下所示为配置文件的一个示例：
    3.   
  
  
      
   
   
   
      2. 
   
   
   
      3. 
   
   
   
    3. hbase.rootdir
      4. 
   
   
   
    4. hdfs://hostname:9000/hbase
      5. 
   
   
   
    5. 
   
   
   
      7. 
   
   
   
    7. hbase.cluster.distributed
      8. 
   
   
   
    8. true
      9. 
   
   
   
    9. 
   
   
   
      11. 
   
   
   
    11. hbase.zookeeper.quorum
      12. 
   
   
   
    12. *.*.*.*, *.*.*.*, *.*.*.*
      13. 
   
   
   
    13. 
   
   
   
      15. 
   
   
   
    15. hbase.defaults.for.version
      16. 
   
   
   
    16. 0.90.2
      17. 
   
   
   
    17. 
   
   
   
    18.
  3. 下面可以在Eclipse环境下进行HBase编程了。

3. HBase基本操作代码示例

3.1 初始化配置

 
 
 
    
  
  
  
  1. private static Configuration conf = null;
    2. 
  
  
  
  2. /**
    3. 
  
  
  
  3.  * 初始化配置
    4. 
  
  
  
  4.  */
    5. 
  
  
  
  5. static {
    6. 
  
  
  
  6.     conf = HBaseConfiguration.create();
    7. 
  
  
  
  7. }
    8.

3.2 创建表

 
 
 
    
  
  
  
  1. /**
    2. 
  
  
  
  2.  * 创建表操作
    3. 
  
  
  
  3.  * @throws IOException
    4. 
  
  
  
  4.  */
    5. 
  
  
  
  5. public void createTable(String tablename, String[] cfs) throws IOException {
    6. 
  
  
  
  6.     HBaseAdmin admin = new HBaseAdmin(conf);
    7. 
  
  
  
  7.     if (admin.tableExists(tablename)) {
    8. 
  
  
  
  8.         System.out.println("表已经存在！");
    9. 
  
  
  
  9.     }
    10. 
  
  
  
  10.     else {
    11. 
  
  
  
  11.         HTableDescriptor tableDesc = new HTableDescriptor(tablename);
    12. 
  
  
  
  12.         for (int i = 0; i < cfs.length; i++) {
    13. 
  
  
  
  13.             tableDesc.addFamily(new HColumnDescriptor(cfs[i]));
    14. 
  
  
  
  14.         }
    15. 
  
  
  
  15.         admin.createTable(tableDesc);
    16. 
  
  
  
  16.         System.out.println("表创建成功！");
    17. 
  
  
  
  17.     }
    18. 
  
  
  
  18. }
    19.

3.3 删除表

 
 
 
    
  
  
  
  1. /**
    2. 
  
  
  
  2.  * 删除表操作
    3. 
  
  
  
  3.  * @param tablename
    4. 
  
  
  
  4.  * @throws IOException
    5. 
  
  
  
  5.  */
    6. 
  
  
  
  6. public void deleteTable(String tablename) throws IOException {
    7. 
  
  
  
  7.     try {
    8. 
  
  
  
  8.         HBaseAdmin admin = new HBaseAdmin(conf);
    9. 
  
  
  
  9.         admin.disableTable(tablename);
    10. 
  
  
  
  10.         admin.deleteTable(tablename);
    11. 
  
  
  
  11.         System.out.println("表删除成功！");
    12. 
  
  
  
  12.     } catch (MasterNotRunningException e) {
    13. 
  
  
  
  13.         e.printStackTrace();
    14. 
  
  
  
  14.     } catch (ZooKeeperConnectionException e) {
    15. 
  
  
  
  15.         e.printStackTrace();
    16. 
  
  
  
  16.     }
    17. 
  
  
  
  17. }
    18.

3.4 插入一行记录

 
 
 
    
  
  
  
  1. /**
    2. 
  
  
  
  2.  * 插入一行记录
    3. 
  
  
  
  3.  * @param tablename
    4. 
  
  
  
  4.  * @param cfs
    5. 
  
  
  
  5.  */
    6. 
  
  
  
  6. public void writeRow(String tablename, String[] cfs) {
    7. 
  
  
  
  7.     try {
    8. 
  
  
  
  8.         HTable table = new HTable(conf, tablename);
    9. 
  
  
  
  9.         Put put = new Put(Bytes.toBytes("rows1"));
    10. 
  
  
  
  10.         for (int j = 0; j < cfs.length; j++) {
    11. 
  
  
  
  11.             put.add(Bytes.toBytes(cfs[j]),
    12. 
  
  
  
  12.                     Bytes.toBytes(String.valueOf(1)),
    13. 
  
  
  
  13.                     Bytes.toBytes("value_1"));
    14. 
  
  
  
  14.             table.put(put);
    15. 
  
  
  
  15.         }
    16. 
  
  
  
  16.     } catch (IOException e) {
    17. 
  
  
  
  17.         e.printStackTrace();
    18. 
  
  
  
  18.     }
    19. 
  
  
  
  19. }
    20.

3.5 删除一行记录

 
 
 
    
  
  
  
  1. /**
    2. 
  
  
  
  2.  * 删除一行记录
    3. 
  
  
  
  3.  * @param tablename
    4. 
  
  
  
  4.  * @param rowkey
    5. 
  
  
  
  5.  * @throws IOException
    6. 
  
  
  
  6.  */
    7. 
  
  
  
  7. public void deleteRow(String tablename, String rowkey) throws IOException {
    8. 
  
  
  
  8.     HTable table = new HTable(conf, tablename);
    9. 
  
  
  
  9.     List list = new ArrayList();
    10. 
  
  
  
  10.     Delete d1 = new Delete(rowkey.getBytes());
    11. 
  
  
  
  11.     list.add(d1);
    12. 
  
  
  
  12.     table.delete(list);
    13. 
  
  
  
  13.     System.out.println("删除行成功！");
    14. 
  
  
  
  14. }
    15.

3.6 查找一行记录

 
 
 
    
  
  
  
  1. /**
    2. 
  
  
  
  2.  * 查找一行记录
    3. 
  
  
  
  3.  * @param tablename
    4. 
  
  
  
  4.  * @param rowkey
    5. 
  
  
  
  5.  */
    6. 
  
  
  
  6. public static void selectRow(String tablename, String rowKey)
    7. 
  
  
  
  7.         throws IOException {
    8. 
  
  
  
  8.     HTable table = new HTable(conf, tablename);
    9. 
  
  
  
  9.     Get g = new Get(rowKey.getBytes());
    10. 
  
  
  
  10.     Result rs = table.get(g);
    11. 
  
  
  
  11.     for (KeyValue kv : rs.raw()) {
    12. 
  
  
  
  12.         System.out.print(new String(kv.getRow()) + "  ");
    13. 
  
  
  
  13.         System.out.print(new String(kv.getFamily()) + ":");
    14. 
  
  
  
  14.         System.out.print(new String(kv.getQualifier()) + "  ");
    15. 
  
  
  
  15.         System.out.print(kv.getTimestamp() + "  ");
    16. 
  
  
  
  16.         System.out.println(new String(kv.getValue()));
    17. 
  
  
  
  17.     }
    18. 
  
  
  
  18. }
    19.

3.7 查询表中所有行

 
 
 
    
  
  
  
  1. /**
    2. 
  
  
  
  2.  * 查询表中所有行
    3. 
  
  
  
  3.  * @param tablename
    4. 
  
  
  
  4.  */
    5. 
  
  
  
  5. public void scaner(String tablename) {
    6. 
  
  
  
  6.     try {
    7. 
  
  
  
  7.         HTable table = new HTable(conf, tablename);
    8. 
  
  
  
  8.         Scan s = new Scan();
    9. 
  
  
  
  9.         ResultScanner rs = table.getScanner(s);
    10. 
  
  
  
  10.         for (Result r : rs) {
    11. 
  
  
  
  11.             KeyValue[] kv = r.raw();
    12. 
  
  
  
  12.             for (int i = 0; i < kv.length; i++) {
    13. 
  
  
  
  13.                 System.out.print(new String(kv[i].getRow()) + "  ");
    14. 
  
  
  
  14.                 System.out.print(new String(kv[i].getFamily()) + ":");
    15. 
  
  
  
  15.                 System.out.print(new String(kv[i].getQualifier()) + "  ");
    16. 
  
  
  
  16.                 System.out.print(kv[i].getTimestamp() + "  ");
    17. 
  
  
  
  17.                 System.out.println(new String(kv[i].getValue()));
    18. 
  
  
  
  18.             }
    19. 
  
  
  
  19.         }
    20. 
  
  
  
  20.     } catch (IOException e) {
    21. 
  
  
  
  21.         e.printStackTrace();
    22. 
  
  
  
  22.     }
    23. 
  
  
  
  23. }
    24.

文章标题：基于Java的HBase客户端编程
当前路径：http://www.shufengxianlan.com/qtweb/news35/50485.html

网站建设、网络推广公司-创新互联，是专注品牌与效果的网站制作，网络营销seo公司；服务项目有等

广告

声明：本网站发布的内容（图片、视频和文字）以用户投稿、用户转载内容为主，如果涉及侵权请尽快告知，我们将会在第一时间删除。文章观点不代表本网站立场，如需处理请联系客服。电话：028-86922220；邮箱：631063699@qq.com。内容未经允许不得转载，或转载时需注明来源： 创新互联

猜你还喜欢下面的内容

手机网站建设知识

分类信息网站

四川电信高防服务器托管　　 　网上商城开发　　 　响应式网站建设公司　　 　成都西信服务器托管　　 　营销网站定位　　 　成都网站建设公司　　 　成都网站推广公司　　 　虚拟主机　　 　seo优化排名　　 　云虚拟主机　　 　广东帝美豪门窗　　 　遂宁海缘科技　　 　绵阳服务器托管　　 　添翼二手车鉴定　　 　成都网络营销　　 　成都网站设计　　 　手机网站版本　　 　香港主机　　 　网站快速收录　　 　犀浦封阳台