当前位置：主页 > 查看内容

Ubantu18.04 + Hbase 2.3.5 操作JavaAPI

发布时间：2021-06-29 00:00| 有位朋友查看

简介：文章目录前言 Ubantu18.04 安装Eclipse Ubantu18.04 安装 Maven Eclipse 新建 Maven 工程代码运行代码操作 Hbase-JavaAPI 总结前言这是一个比较简单的实验麻烦的地方在于需要在 Vmware Ubantu18.04 中安装好 Eclipse 和 Maven, 由于过于简单所以直接贴……

文章目录

前言
Ubantu18.04 安装Eclipse
Ubantu18.04 安装 Maven
Eclipse 新建 Maven 工程
代码
运行代码操作 Hbase-JavaAPI
总结

前言

这是一个比较简单的实验，麻烦的地方在于需要在 Vmware + Ubantu18.04 中安装好 Eclipse 和 Maven, 由于过于简单，所以直接贴出我完成这个实验的时候借鉴的实用博客！希望大家可以顺利完成该实验！💪

在这里插入图片描述

Ubantu18.04 安装Eclipse

Ubantu18.04 安装 Maven

Eclipse 新建 Maven 工程

按照下文方式配置和创建
Eclipse中配置Maven
配置 pom.xml 文件，导入 Hbase 的依赖包

<dependencies>
    <dependency>
        <groupId>org.apache.hbase</groupId>
        <artifactId>hbase-client</artifactId>
        <version>2.3.5</version>
    </dependency>
</dependencies>

代码

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.util.Scanner;
import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.HColumnDescriptor;
import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Admin;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Delete;
import org.apache.hadoop.hbase.client.Put;
import org.apache.hadoop.hbase.client.Result;
import org.apache.hadoop.hbase.client.ResultScanner;
import org.apache.hadoop.hbase.client.Scan;
import org.apache.hadoop.hbase.client.Table;
import org.apache.hadoop.hbase.util.Bytes;
public class HbaseJavaApi {
public static Configuration configuration;
public static Connection connection;
public static Admin admin;
 //建立连接
    public static void init(){
            configuration  = HBaseConfiguration.create();
            configuration.set("hbase.rootdir","hdfs://localhost:9000/hbase");
            try{
                connection = ConnectionFactory.createConnection(configuration);
                admin = connection.getAdmin();
            }catch (IOException e){
                e.printStackTrace();
            }
        }
    //关闭连接
    public static void close(){
        try{
            if(admin != null){
                admin.close();
            }
            if(null != connection){
                connection.close();
            }
        }catch (IOException e){
            e.printStackTrace();
        }
    }
    /**
     * 建表。参数tableName为表的名称，字符串数组fields为存储记录各个域名称的数组。
     * 要求当HBase已经存在名为tableName的表时，先删除原有的表，然后再
     * 创建新的表  field：列族
     * @param tableName 表名
     * @param fields 列族名
     * @throws IOException
     */
    public static void createTable(String tableName,String[] fields) throws IOException {
        init();
        TableName tablename = TableName.valueOf(tableName);
        if(admin.tableExists(tablename)){
            System.out.println("表已存在，将执行删除原表，重建新表!");
            admin.disableTable(tablename);
            admin.deleteTable(tablename);//删除原来的表
        }
            HTableDescriptor hTableDescriptor = new HTableDescriptor(TableName.valueOf(tableName));
            for(String str:fields){
                HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(str);
                hTableDescriptor.addFamily(hColumnDescriptor);
            }
            admin.createTable(hTableDescriptor);
            System.out.println("表已创建成功");
        close();
    }
    /**
     * 向表 tableName、行 row（用 S_Name 表示）和字符串数组 fields 指定的单元格中
     * 添加对应的数据 values。
     * 其中，fields 中每个元素如果对应的列族下还有相应的列限定符的话，
     * 用“columnFamily:column”表示。
     * 例如，同时向“Math”、“Computer Science”、“English”三列添加成绩时，
     * 字符串数组 fields 为{“Score:Math”, ”Score:Computer Science”, ”Score:English”}，
     * 数组values 存储这三门课的成绩。
     */
    public static void addRecord(String tableName,String rowKey,String []fields,String [] values) throws IOException {
        init();
        Table table = connection.getTable(TableName.valueOf(tableName));
        for (int i = 0; i < fields.length; i++) {
         Put put = new Put(rowKey.getBytes());
         String [] cols = fields[i].split(":");
         if(cols.length==1)
         {
         put.addColumn(cols[0].getBytes(), "".getBytes(), values[i].getBytes());//因为当输入的是单列族，split仅读出一个字符字符串，即cols仅有一个元素
         }
         else {
         put.addColumn(cols[0].getBytes(), cols[1].getBytes(), values[i].getBytes());
}
         table.put(put);
}
        table.close();
        close();
    }
    /**
     * 根据表名查找表信息
     */
    public static void getData(String tableName)throws  IOException{
        init();
        Table table = connection.getTable(TableName.valueOf(tableName));
        Scan scan = new Scan();
       ResultScanner scanner = table.getScanner(scan);
        for(Result result:scanner)
        {
        showCell((result));
        }
        close();
    }
    /**
     * 格式化输出
     * @param result
     */
    public static void showCell(Result result){
        Cell[] cells = result.rawCells();
        for(Cell cell:cells){
            System.out.println("RowName(行键):"+new String(CellUtil.cloneRow(cell))+" ");
            System.out.println("Timetamp(时间戳):"+cell.getTimestamp()+" ");
            System.out.println("column Family（列簇）:"+new String(CellUtil.cloneFamily(cell))+" ");
            System.out.println("column Name（列名）:"+new String(CellUtil.cloneQualifier(cell))+" ");
            System.out.println("value:（值）"+new String(CellUtil.cloneValue(cell))+" ");
            System.out.println();
        }
    }
    /**
     * 浏览表 tableName 某一列的数据，如果某一行记录中该列数据不存在，则返回 null。
     * 要求当参数 column 为某一列族名称时，如果底下有若干个列限定符，则要列出每个列限定符代表的列的数据；
     * 当参数 column 为某一列具体名称（例如“Score:Math”）时，只需要列出该列的数据。
     * @param tableName
     * @param column
     * @throws IOException
     */
    public static void scanColumn (String tableName,String column) throws IOException
    {
    init();
       Table table = connection.getTable(TableName.valueOf(tableName));
           Scan scan = new Scan();
           String [] cols = column.split(":");
       if(cols.length==1)
       {
       scan.addFamily(Bytes.toBytes(column));
       }
       else {
       scan.addColumn(Bytes.toBytes(cols[0]),Bytes.toBytes(cols[1]));
}
           ResultScanner scanner = table.getScanner(scan);
           for (Result result = scanner.next(); result !=null;result = scanner.next()) {

showCell(result);
}
           table.close();
           close();
    }
    /**
     * 修改表 tableName，行 row（可以用学生姓名 S_Name 表示），列 column 指定的单元格的数据。
     * @throws IOException
     */
    public static void modifyData(String tableName,String rowKey,String column,String value) throws IOException
    {
        init();
        Table table = connection.getTable(TableName.valueOf(tableName));
       Put put = new Put(rowKey.getBytes());
      String [] cols = column.split(":");
       if(cols.length==1)
       {
      put.addColumn(column.getBytes(),"".getBytes() , value.getBytes());//qualifier:列族下的列名
       }
       else {
      put.addColumn(cols[0].getBytes(),cols[1].getBytes() , value.getBytes());//qualifier:列族下的列名
    }
       table.put(put);
       table.close();
       close();
    }

    /**
     * 删除表 tableName 中 row 指定的行的记录。
     * @throws IOException
     */
    public static void deleteRow(String tableName,String rowKey) throws IOException
    {
        init();
         Table table = connection.getTable(TableName.valueOf(tableName));
       Delete delete = new Delete(rowKey.getBytes());
      table.delete(delete);
        table.close();
        close();
    }
/**
 * @param args
 * @throws IOException
 */
public static void main(String[] args) throws IOException {
// TODO Auto-generated method stub
        HbaseJavaApi hbaseJavaApi = new HbaseJavaApi();
    boolean flag =true;
while(flag)
{
        System.out.println("------------------------------------------------提供以下功能----------------------------------------------");
System.out.println("                       1- createTable（创建表  ,提供表名、列族名）                                      ");
System.out.println("                       2-addRecord （向已知表名、行键、列簇的表添加值）                       ");
System.out.println("                       3- ScanColumn（浏览表     某一列的数据）                                            ");
System.out.println("                       4- modifyData（修改某表   某行，某一列，指定的单元格的数据）    ");
System.out.println("                       5- deleteRow（删除 某表   某行的记录）                                                 ");
System.out.println("------------------------------------------------------------------------------------------------------------------");
Scanner scan = new Scanner(System.in);
String choose1=scan.nextLine();
switch (choose1) {
case "1":
{
System.out.println("请输入要创建的表名");
String tableName=scan.nextLine();
 System.out.println("请输入要创建的表的列族个数");
 int Num=scan.nextInt();
String [] fields = new String[Num];
 System.out.println("请输入要创建的表的列族");
/* Scanner scanner = new Scanner(System.in);     scanner.next 如不是全局，即会记得上一次输出。相同地址读入值时*/
for(int i=0;i< fields.length;i++)
{
/*BufferedReader in = new BufferedReader(new InputStreamReader(System.in));
fields[i] = in.readLine();*/
/*fields[i]=scan.next(); 因为之前没有输入过，所以可以读入新值*/
scan = new Scanner(System.in);
    fields[i]=scan.nextLine();
}
System.out.println("正在执行创建表的操作");
        hbaseJavaApi.createTable(tableName,fields);
break;
}
case "2":
{
System.out.println("请输入要添加数据的表名");
String tableName=scan.nextLine();
System.out.println("请输入要添加数据的表的行键");
String rowKey=scan.nextLine();
System.out.println("请输入要添加数据的表的列的个数");
int num =scan.nextInt();
String fields[]=new String[num];
System.out.println("请输入要添加数据的表的列信息 共"+num+"条信息");
for(int i=0;i< fields.length;i++)
{
BufferedReader in3= new BufferedReader(new InputStreamReader(System.in));
fields[i] = in3.readLine();
/*fields[i]=scan.next(); 因为之前没有输入过，所以可以读入新值*/
}
System.out.println("请输入要添加的数据信息 共"+num+"条信息");
String values[]=new String[num];
for(int i=0;i< values.length;i++)
{
BufferedReader in2 = new BufferedReader(new InputStreamReader(System.in));
values[i] = in2.readLine();
}
System.out.println("原表信息");
hbaseJavaApi.getData(tableName);
System.out.println("正在执行向表中添加数据的操作........\n");
        hbaseJavaApi.addRecord(tableName, rowKey, fields, values);
        System.out.println("\n添加后的表的信息........");
        hbaseJavaApi.getData(tableName);
break;
}
case "3":
{
System.out.println("请输入要查看数据的表名");
String tableName=scan.nextLine();
System.out.println("请输入要查看数据的列名");
String column=scan.nextLine();
System.out.println("查看的信息如下：........\n");
hbaseJavaApi.scanColumn(tableName, column);
break;
}
case "4":
{
System.out.println("请输入要修改数据的表名");
String tableName=scan.nextLine();
System.out.println("请输入要修改数据的表的行键");
String rowKey=scan.nextLine();
System.out.println("请输入要修改数据的列名");
String column=scan.nextLine();
System.out.println("请输入要修改的数据信息  ");
String value=scan.nextLine();
System.out.println("原表信息如下：........\n");
hbaseJavaApi.getData(tableName);
System.out.println("正在执行向表中修改数据的操作........\n");
hbaseJavaApi.modifyData(tableName, rowKey, column, value);
System.out.println("\n修改后的信息如下：........\n");
hbaseJavaApi.getData(tableName);
break;
}
case "5":
{
System.out.println("请输入要删除指定行的表名");
String tableName=scan.nextLine();
System.out.println("请输入要删除指定行的行键");
String rowKey=scan.nextLine();
System.out.println("原表信息如下：........\n");
hbaseJavaApi.getData(tableName);
System.out.println("正在执行向表中删除数据的操作........\n");
hbaseJavaApi.deleteRow(tableName, rowKey);
System.out.println("\n删除后的信息如下：........\n");
hbaseJavaApi.getData(tableName);
break;
}
default:
{
System.out.println("   你的操作有误 ！！！    ");
break;
}
}
        System.out.println(" 你要继续操作吗？ 是-true 否-false ");
flag=scan.nextBoolean();
}
System.out.println("   程序已退出！    ");
}
}

运行代码操作 Hbase-JavaAPI

如下图按照控制台打印输出提示进行相关操作即可

运行 main 方法
根据提示进行操作

在这里插入图片描述

总结

Hbase 的Java API 操作都相对简单，有点像操作JDBC，希望能够帮助到大家完成实验！学到的童鞋点个赞呀！👍👍！

坚持分享，坚持原创，喜欢博主的靓仔靓女们可以看看博主的首页博客！
您的点赞与收藏是我分享博客的最大赞赏！
博主博客地址: https://blog.csdn.net/weixin_43967679

；原文链接：https://blog.csdn.net/weixin_43967679/article/details/115644872
本站部分内容转载于网络，版权归原作者所有，转载之目的在于传播更多优秀技术内容，如有侵权请联系QQ/微信：153890879删除，谢谢！

上一篇：堆排序(JAVA) 下一篇：没有了

随机推荐

macOS部署Appium

一、准备工具 1. 使用bash作为SHELL 打开终端 Terminal输入下方命令之后不再赘...
小程序实现列表倒计时功能

本文实例为大家分享了小程序实现列表倒计时的具体代码，供大家参考，具体内容如...
ajax 返回值自动添加pre标签的解决方法

ajax返回，自动添加pre标签 ajax返回的内容，居然自动添加了pre标签在FF，ie，...
Vue 3 不再支持 IE11

近日尤雨溪宣布一个提案Vue 3 将不再支持 IE11。原定投入 Vue 3 IE11 支持的精...
DFS解决排列问题

dfs思想思想是从一个顶点开始沿着一条路一直走到底如果发现不能到达目标解那...
PHP number_format函数原理及实例解析

实例1 格式化数字： php echo number_format("1000000").""; echo number_format...
vuex的使用步骤

一、使用Vuex的目的实现多组件状态管理。多个组件之间需要数据共享时，Vuex是个...
一步一步带你入门MySQL中的索引和锁

索引索引常见的几种类型索引常见的类型有哈希索引，有序数组索引，二叉树索引...
2021显卡挖矿收益表，挖矿显卡算力表，显

AMD显卡挖以太坊(ETH)算力排行算力由低到高排名A卡无法挖CFX收益没有ETH高。 ? ...
AJAX和JSP混合使用方法实例

首先要知道AJAX 是一种在无需重新加载整个网页的情况下，能够更新部分网页的技术...

Ubantu18.04 + Hbase 2.3.5 操作JavaAPI

文章目录

前言

Ubantu18.04 安装Eclipse

Ubantu18.04 安装 Maven

Eclipse 新建 Maven 工程

代码

运行代码操作 Hbase-JavaAPI

总结

推荐图文

阻止Windows 10强制更新的四个方法

ElasticSearch的基本概念和集群分布式底层实现

学Linux到底学什么？在线Linux帮你低成本练习

线上MySQL千万级大表，如何优化？

iOS Predicate Format String Syntax 【NSPredicate

ASP.NET Core单文件和多文件上传并保存到服务端的方

随机推荐

macOS部署Appium

小程序实现列表倒计时功能

ajax 返回值自动添加pre标签的解决方法

Vue 3 不再支持 IE11

DFS解决排列问题

PHP number_format函数原理及实例解析

vuex的使用步骤

一步一步带你入门MySQL中的索引和锁

2021显卡挖矿收益表，挖矿显卡算力表，显

AJAX和JSP混合使用方法实例

关于我们