图文精华

About云-梭伦科技»专题 › 技术学习(版主发帖区) › 大数据学习 › Hbase › 实操演练› 在集群中Java 通过调用API操作HBase 0.98
分享

在集群中Java 通过调用API操作HBase 0.98

sunshine_junge 2014-7-18 19:17:34 发表于 实操演练 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 0 8689


问题导读：
Java如何调用API操作HBase？













本文的内容是在集群中创建java项目调用api来操作hbase，主要涉及对hbase的创建表格，删除表格，插入数据，删除数据，查询一条数据，查询所有数据等操作。

具体流程如下：

1.创建项目
2.获取jar包到项目的lib目录下（这边试用的事hbase 0.98 lib目录下的所有jar包）
3.编写java程序
4.编写ant脚本



  1. package com.wan.hbase;

  2. import java.io.IOException;

  3. import org.apache.Hadoop.conf.Configuration;

  4. import org.apache.hadoop.hbase.Cell;

  5. import org.apache.hadoop.hbase.CellUtil;

  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.MasterNotRunningException;

  10. import org.apache.hadoop.hbase.TableName;

  11. import org.apache.hadoop.hbase.ZooKeeperConnectionException;

  12. import org.apache.hadoop.hbase.client.Delete;

  13. import org.apache.hadoop.hbase.client.Get;

  14. import org.apache.hadoop.hbase.client.HBaseAdmin;

  15. import org.apache.hadoop.hbase.client.HTable;

  16. import org.apache.hadoop.hbase.client.Put;

  17. import org.apache.hadoop.hbase.client.Result;

  18. import org.apache.hadoop.hbase.client.ResultScanner;

  19. import org.apache.hadoop.hbase.client.Scan;

  20. import org.apache.hadoop.hbase.util.Bytes;

  21.  

  22. public class SimpleHBase {

  23.  public static void main(String[] args) {

  24.   Configuration configuration=HBaseConfiguration.create();

  25.   String tableName="student";

  26.   createTable(configuration, tableName);

  27. //  addData(configuration, tableName);

  28. //  getData(configuration, tableName);

  29. //  getAllData(configuration, tableName);

  30. //  deleteDate(configuration, tableName);

  31. //  dropTable(configuration, tableName);

  32.   

  33.  }

  34.  

  35.  /**

  36.   * create a new Table

  37.   * @param configuration Configuration

  38.   * @param tableName String,the new Table's name

  39.   * */

  40.  public static void createTable(Configuration configuration,String tableName){

  41.   HBaseAdmin admin;

  42.   try {

  43.    admin = new HBaseAdmin(configuration);

  44.    if(admin.tableExists(tableName)){

  45.     admin.disableTable(tableName);

  46.     admin.deleteTable(tableName);

  47.     System.out.println(tableName+"is exist ,delete ......");

  48.    }

  49.    

  50.    

  51.    HTableDescriptor tableDescriptor=new HTableDescriptor(TableName.valueOf(tableName));

  52.    tableDescriptor.addFamily(new HColumnDescriptor("info"));

  53.    tableDescriptor.addFamily(new HColumnDescriptor("address"));

  54.    admin.createTable(tableDescriptor);

  55.    System.out.println("end create table");

  56.   } catch (MasterNotRunningException e) {

  57.    // TODO Auto-generated catch block

  58.    e.printStackTrace();

  59.   } catch (ZooKeeperConnectionException e) {

  60.    // TODO Auto-generated catch block

  61.    e.printStackTrace();

  62.   } catch (IOException e) {

  63.    // TODO Auto-generated catch block

  64.    e.printStackTrace();

  65.   }

  66.   

  67.  }

  68.  

  69.  /**

  70.   * Delete the existing table

  71.   * @param configuration Configuration

  72.   * @param tableName String,Table's name

  73.   * */

  74.  public static void dropTable(Configuration configuration,String tableName){

  75.   HBaseAdmin admin;

  76.   try {

  77.    admin = new HBaseAdmin(configuration);

  78.    if(admin.tableExists(tableName)){

  79.     admin.disableTable(tableName);

  80.     admin.deleteTable(tableName);

  81.     System.out.println(tableName+"delete success!");

  82.    }else{

  83.     System.out.println(tableName+"Table does not exist!");

  84.    }

  85.   } catch (MasterNotRunningException e) {

  86.    // TODO Auto-generated catch block

  87.    e.printStackTrace();

  88.   } catch (ZooKeeperConnectionException e) {

  89.    // TODO Auto-generated catch block

  90.    e.printStackTrace();

  91.   } catch (IOException e) {

  92.    // TODO Auto-generated catch block

  93.    e.printStackTrace();

  94.   }

  95.  }

  96.  

  97.  /**

  98.   * insert a data

  99.   * @param configuration Configuration

  100.   * @param tableName String,Table's name

  101.   * */

  102.  public static void addData(Configuration configuration,String tableName){

  103.   HBaseAdmin admin;

  104.   try {

  105.    admin = new HBaseAdmin(configuration);

  106.    if(admin.tableExists(tableName)){

  107.     HTable table=new HTable(configuration, tableName);

  108.     Put put=new Put(Bytes.toBytes("zhangsan"));

  109.     put.add(Bytes.toBytes("info"), Bytes.toBytes("age"), Bytes.toBytes("28"));

  110.     table.put(put);

  111.     System.out.println("add success!");

  112.    }else{

  113.     System.out.println(tableName+"Table does not exist!");

  114.    }

  115.   } catch (MasterNotRunningException e) {

  116.    // TODO Auto-generated catch block

  117.    e.printStackTrace();

  118.   } catch (ZooKeeperConnectionException e) {

  119.    // TODO Auto-generated catch block

  120.    e.printStackTrace();

  121.   } catch (IOException e) {

  122.    // TODO Auto-generated catch block

  123.    e.printStackTrace();

  124.   }

  125.  }

  126.  

  127.  /**

  128.   * Delete a data

  129.   * @param configuration Configuration

  130.   * @param tableName String,Table's name

  131.   * */

  132.  public static void deleteDate(Configuration configuration,String tableName){

  133.   HBaseAdmin admin;

  134.   try {

  135.    admin=new HBaseAdmin(configuration);

  136.    if(admin.tableExists(tableName)){

  137.     HTable table=new HTable(configuration, tableName);

  138.     Delete delete=new Delete(Bytes.toBytes("zhangsan"));

  139.     table.delete(delete);

  140.     System.out.println("delete success!");

  141.    }else{

  142.     System.out.println("Table does not exist!");

  143.    }

  144.   } catch (MasterNotRunningException e) {

  145.    // TODO Auto-generated catch block

  146.    e.printStackTrace();

  147.   } catch (ZooKeeperConnectionException e) {

  148.    // TODO Auto-generated catch block

  149.    e.printStackTrace();

  150.   } catch (IOException e) {

  151.    // TODO Auto-generated catch block

  152.    e.printStackTrace();

  153.   }

  154.  }

  155.  

  156.  /**

  157.   * get a data

  158.   * @param configuration Configuration

  159.   * @param tableName String,Table's name

  160.   * */

  161.  public static void getData(Configuration configuration,String tableName){

  162.   HTable table;

  163.   try {

  164.    table = new HTable(configuration, tableName);

  165.    Get get=new Get(Bytes.toBytes("zhangsan"));

  166.    Result result=table.get(get);

  167.  

  168.    for(Cell cell:result.rawCells()){   

  169.     System.out.println("RowName:"+new String(CellUtil.cloneRow(cell))+" ");

  170.     System.out.println("Timetamp:"+cell.getTimestamp()+" ");

  171.     System.out.println("column Family:"+new String(CellUtil.cloneFamily(cell))+" ");

  172.     System.out.println("row Name:"+new String(CellUtil.cloneQualifier(cell))+" ");

  173.     System.out.println("value:"+new String(CellUtil.cloneValue(cell))+" ");

  174.    }

  175.   } catch (IOException e) {

  176.    // TODO Auto-generated catch block

  177.    e.printStackTrace();

  178.   }

  179.  }

  180.  

  181.  /**

  182.   * insert all data

  183.   * @param configuration Configuration

  184.   * @param tableName String,Table's name

  185.   * */

  186.  public static void getAllData(Configuration configuration,String tableName){

  187.   HTable table;

  188.   try {

  189.    table=new HTable(configuration, tableName);

  190.    Scan scan=new Scan();

  191.    ResultScanner results=table.getScanner(scan);

  192.    for(Result result:results){

  193.     for(Cell cell:result.rawCells()){   

  194.      System.out.println("RowName:"+new String(CellUtil.cloneRow(cell))+" ");

  195.      System.out.println("Timetamp:"+cell.getTimestamp()+" ");

  196.      System.out.println("column Family:"+new String(CellUtil.cloneFamily(cell))+" ");

  197.      System.out.println("row Name:"+new String(CellUtil.cloneQualifier(cell))+" ");

  198.      System.out.println("value:"+new String(CellUtil.cloneValue(cell))+" ");

  199.     }

  200.    }

  201.   } catch (IOException e) {

  202.    // TODO Auto-generated catch block

  203.    e.printStackTrace();

  204.   }

  205.     

  206.  }

  207. }
复制代码





ant脚本

  1. <?xml version="1.0"?>  

  2. <project name="HBaseProject" default="run" basedir=".">  

  3. <!-- properies -->  

  4.     <property name="src.dir" value="src" />  

  5.     <property name="report.dir" value="report" />  

  6.     <property name="classes.dir" value="classes" />  

  7.     <property name="lib.dir" value="lib" />  

  8.     <property name="dist.dir" value="dist" />  

  9. <property name="doc.dir" value="doc"/>  

  10.     <!-- 定义classpath -->  

  11.     <path id="master-classpath">  

  12.      <!--这边指向的jar包就是hbase 0.98 lib目录下对应的jar包，当前项目是把这些jar包放在项目的lib目录下-->

  13.         <fileset file="${lib.dir}/*.jar" />  

  14.         <pathelement path="${classes.dir}"/>  

  15.     </path>  

  16.  

  17.  <path id="run.path">  

  18.   <path path="${classes.dir}"/>

  19.           <path refid="master-classpath" />

  20.       </path> 

  21.     <!-- 初始化任务 -->  

  22.     <target name="init" depends="clean">

  23.      <mkdir dir="${classes.dir}"/>

  24.      <mkdir dir="${dist.dir}"/>

  25.     </target>  

  26.     <!-- 编译 -->  

  27.     <target name="compile" depends="init" description="compile the source files">  

  28.           

  29.         <javac srcdir="${src.dir}" destdir="${classes.dir}" target="1.7" includeantruntime="false">  

  30.             <classpath refid="master-classpath"/>  

  31.         </javac>  

  32.     </target>  

  33.  

  34.  <target name="run" depends="compile">

  35.         <java classname="com.wan.hbase.SimpleHBase" classpathref="run.path" fork="true" >

  36.         </java>

  37.     </target>

  38.  

  39.     <!-- 打包成jar -->  

  40.     <target name="pack" depends="compile" description="make .jar file">  

  41.       <mkdir dir="${dist.dir}" />  

  42.         <jar destfile="${dist.dir}/hbaseproject.jar" basedir="${classes.dir}">  

  43.             <exclude name="**/*Test.*" />  

  44.             <exclude name="**/Test*.*" />  

  45.         </jar>  

  46.     </target> 

  47.  

  48.  <target name="clean" description="clean the project">

  49.   <delete dir="${classes.dir}"></delete>

  50.   <delete dir="${dist.dir}"></delete>

  51.  </target>

  52. </project>
复制代码


最后把项目放在集群中,进入项目的根目录,执行命令:ant run

即可运行！

完整项目（包含hbase中lib目录下的jar包）：
百度网盘免费下载地址：http://pan.baidu.com/s/1eQEG7jO




引用：http://www.linuxidc.com/Linux/2014-05/102028.htm

欢迎加入about云群90371779 、322273151、432264021 ，云计算爱好者群，亦可关注about云腾讯认证空间||关注本站微信
回复

使用道具 举报

自定义广告语

没找到任何评论，期待你打破沉寂

高级模式
B Color Image Link Quote Code Smilies
您需要登录后才可以回帖 登录 | 立即注册

本版积分规则

发表新帖
sunshine_junge

新手上路

关注

  • 80

    主题

  • 169

    帖子

  • 52

    粉丝

TA的主题
关闭

推荐上一条 /2 下一条

关于我们· 联系我们· 加入我们· 小黑屋· 合作伙伴   

Copyright © 2001-2024 About云-梭伦科技 Powered by Discuz! X3.4 Licensed Discuz Team.

简书 / Smrz 京ICP备2020039040号 Wxb 简书网举报电话：021-34700000