图文精华

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

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

xioaxu790 2014-7-14 13:35:09 发表于 实操演练 [显示全部楼层] 回帖奖励 阅读模式 关闭右栏 0 14567
About云VIP帮助找工作和提升
本帖最后由 xioaxu790 于 2014-7-14 13:41 编辑
问题导读：
1、怎样在集群中创建Java项目？
2、如何在java项目中调用api来操作hbase？
3、具体流程是什么？



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


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

编写程序，代码如下所示
  1. package com.wan.hbase;

  2. 

  3. import java.io.IOException;

  4. 

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

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

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

  8. import org.apache.hadoop.hbase.HBaseConfiguration;

  9. import org.apache.hadoop.hbase.HColumnDescriptor;

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

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

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

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

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

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

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

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

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

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

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

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

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

  23. 

  24.  

  25. 

  26. public class SimpleHBase {

  27. 

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

  29.   Configuration configuration=HBaseConfiguration.create();

  30.   String tableName="student";

  31.   createTable(configuration, tableName);

  32. //  addData(configuration, tableName);

  33. //  getData(configuration, tableName);

  34. //  getAllData(configuration, tableName);

  35. //  deleteDate(configuration, tableName);

  36. //  dropTable(configuration, tableName);

  37.   

  38.  }

  39.  

  40.  /**

  41.   * create a new Table

  42.   * @param configuration Configuration

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

  44.   * */

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

  46.   HBaseAdmin admin;

  47.   try {

  48.    admin = new HBaseAdmin(configuration);

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

  50.     admin.disableTable(tableName);

  51.     admin.deleteTable(tableName);

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

  53.    }

  54.    

  55.    

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

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

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

  59.    admin.createTable(tableDescriptor);

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

  61.   } catch (MasterNotRunningException e) {

  62.    // TODO Auto-generated catch block

  63.    e.printStackTrace();

  64.   } catch (ZooKeeperConnectionException e) {

  65.    // TODO Auto-generated catch block

  66.    e.printStackTrace();

  67.   } catch (IOException e) {

  68.    // TODO Auto-generated catch block

  69.    e.printStackTrace();

  70.   }

  71.   

  72.  }

  73.  

  74.  /**

  75.   * Delete the existing table

  76.   * @param configuration Configuration

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

  78.   * */

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

  80.   HBaseAdmin admin;

  81.   try {

  82.    admin = new HBaseAdmin(configuration);

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

  84.     admin.disableTable(tableName);

  85.     admin.deleteTable(tableName);

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

  87.    }else{

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

  89.    }

  90.   } catch (MasterNotRunningException e) {

  91.    // TODO Auto-generated catch block

  92.    e.printStackTrace();

  93.   } catch (ZooKeeperConnectionException e) {

  94.    // TODO Auto-generated catch block

  95.    e.printStackTrace();

  96.   } catch (IOException e) {

  97.    // TODO Auto-generated catch block

  98.    e.printStackTrace();

  99.   }

  100.  }

  101.  

  102.  /**

  103.   * insert a data

  104.   * @param configuration Configuration

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

  106.   * */

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

  108.   HBaseAdmin admin;

  109.   try {

  110.    admin = new HBaseAdmin(configuration);

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

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

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

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

  115.     table.put(put);

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

  117.    }else{

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

  119.    }

  120.   } catch (MasterNotRunningException e) {

  121.    // TODO Auto-generated catch block

  122.    e.printStackTrace();

  123.   } catch (ZooKeeperConnectionException e) {

  124.    // TODO Auto-generated catch block

  125.    e.printStackTrace();

  126.   } catch (IOException e) {

  127.    // TODO Auto-generated catch block

  128.    e.printStackTrace();

  129.   }

  130.  }

  131.  

  132.  /**

  133.   * Delete a data

  134.   * @param configuration Configuration

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

  136.   * */

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

  138.   HBaseAdmin admin;

  139.   try {

  140.    admin=new HBaseAdmin(configuration);

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

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

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

  144.     table.delete(delete);

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

  146.    }else{

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

  148.    }

  149.   } catch (MasterNotRunningException e) {

  150.    // TODO Auto-generated catch block

  151.    e.printStackTrace();

  152.   } catch (ZooKeeperConnectionException e) {

  153.    // TODO Auto-generated catch block

  154.    e.printStackTrace();

  155.   } catch (IOException e) {

  156.    // TODO Auto-generated catch block

  157.    e.printStackTrace();

  158.   }

  159.  }

  160.  

  161. 

  162.  /**

  163.   * get a data

  164.   * @param configuration Configuration

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

  166.   * */

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

  168.   HTable table;

  169.   try {

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

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

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

  173.  

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

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

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

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

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

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

  180.    }

  181.   } catch (IOException e) {

  182.    // TODO Auto-generated catch block

  183.    e.printStackTrace();

  184.   }

  185.  }

  186.  

  187.  /**

  188.   * insert all data

  189.   * @param configuration Configuration

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

  191.   * */

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

  193.   HTable table;

  194.   try {

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

  196.    Scan scan=new Scan();

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

  198.    for(Result result:results){

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

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

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

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

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

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

  205.     }

  206.    }

  207.   } catch (IOException e) {

  208.    // TODO Auto-generated catch block

  209.    e.printStackTrace();

  210.   }

  211.     

  212.  }

  213. }

复制代码


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.  

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

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

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

  52.  </target>

  53. </project>
复制代码

最后把项目放在集群中,进入项目的根目录,执行命令:
  1. ant run
复制代码
即可运行！


完整项目（包含hbase中lib目录下的jar包）：
FTP资源免费下载：
FTP地址
用户名：ftp1.linuxidc.com
密码：www.linuxidc.com

下载方法请见：这里
关注公众号，获取大数据、人工智能20套、区块链资源5阶段等资源，随时更新，获取最新技术资源
回复

使用道具 举报

自定义广告语

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

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

本版积分规则

发表新帖
xioaxu790

金牌会员

关注

  • 851

    主题

  • 1000

    帖子

  • 108

    粉丝

TA的主题
关闭

推荐上一条 /2 下一条

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

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

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