HBase学习笔记（三） HBase的API使用

总字数1.2k 预计阅读6分钟

1 环境准备

新建项目后在pom.xml中添加依赖

<dependency>
    <groupId>org.apache.hbase</groupId>
    <artifactId>hbase-server</artifactId>
    <version>2.0.5</version>
</dependency>

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

API官方手册：

https://hbase.apache.org/2.2/apidocs/index.html

2 DDL

创建HBase_DDL类

2.1 判断表是否存在和创建命名空间

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.NamespaceDescriptor;
import org.apache.hadoop.hbase.NamespaceExistException;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;

public class HBase_DDL &#123;

    //TODO 判断表是否存在
    public static boolean isTableExist(String tableName) throws IOException &#123;

        //1.创建配置信息并配置
        Configuration configuration = HBaseConfiguration.create();
        configuration.set("hbase.zookeeper.quorum", "hadoop102,hadoop103,hadoop104");

        //2.获取与HBase的连接
        Connection connection = ConnectionFactory.createConnection(configuration);

        //3.获取DDL操作对象
        Admin admin = connection.getAdmin();

        //4.1判断表是否存在操作
        boolean exists = admin.tableExists(TableName.valueOf(tableName));

        //4.2 创建命名空间
         //42.1创建命名空间描述器
        NamespaceDescriptor namespaceDescriptor = NamespaceDescriptor.create(ns).build();
        //4.2.2执行创建命名空间操作
        try &#123;
            admin.createNamespace(namespaceDescriptor);
        &#125; catch (NamespaceExistException e) &#123;
            System.out.println("命名空间已存在！");
        &#125; catch (Exception e) &#123;
            e.printStackTrace();
        &#125;

        //5.关闭连接
        admin.close();
        connection.close();

        //6.返回结果
        return exists;
    &#125;

&#125;

2.2 创建表

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.NamespaceDescriptor;
import org.apache.hadoop.hbase.NamespaceExistException;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;

public class HBase_DDL &#123;

    //TODO 创建表
    public static void createTable(String tableName, String... cfs) throws IOException &#123;

        //1.判断是否存在列族信息
        if (cfs.length <= 0) &#123;
            System.out.println("请设置列族信息！");
            return;
        &#125;

        //2.判断表是否存在
        if (isTableExist(tableName)) &#123;
            System.out.println("需要创建的表已存在！");
            return;
        &#125;

        //3.创建配置信息并配置
        Configuration configuration = HBaseConfiguration.create();
        configuration.set("hbase.zookeeper.quorum", "hadoop102,hadoop103,hadoop104");

        //4.获取与HBase的连接
        Connection connection = ConnectionFactory.createConnection(configuration);

        //5.获取DDL操作对象
        Admin admin = connection.getAdmin();

        //6.创建表描述器构造器
        TableDescriptorBuilder tableDescriptorBuilder = TableDescriptorBuilder.newBuilder(TableName.valueOf(tableName));

        //7.循环添加列族信息
        for (String cf : cfs) &#123;
            ColumnFamilyDescriptorBuilder columnFamilyDescriptorBuilder = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(cf));
            tableDescriptorBuilder.setColumnFamily(columnFamilyDescriptorBuilder.build());
        &#125;

        //8.执行创建表的操作
        admin.createTable(tableDescriptorBuilder.build());

        //9.关闭资源
        admin.close();
        connection.close();
    &#125;

&#125;

2.3 删除表

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.NamespaceDescriptor;
import org.apache.hadoop.hbase.NamespaceExistException;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;

public class HBase_DDL &#123;

    //TODO 删除表
    public static void dropTable(String tableName) throws IOException &#123;

        //1.判断表是否存在
        if (!isTableExist(tableName)) &#123;
            System.out.println("需要删除的表不存在！");
            return;
        &#125;

        //2.创建配置信息并配置
        Configuration configuration = HBaseConfiguration.create();
        configuration.set("hbase.zookeeper.quorum", "hadoop102,hadoop103,hadoop104");

        //3.获取与HBase的连接
        Connection connection = ConnectionFactory.createConnection(configuration);

        //4.获取DDL操作对象
        Admin admin = connection.getAdmin();

        //5.使表下线
        TableName name = TableName.valueOf(tableName);
        admin.disableTable(name);

        //6.执行删除表操作
        admin.deleteTable(name);

        //7.关闭资源
        admin.close();
        connection.close();
    &#125;

&#125;

3 DML

创建类HBase_DML

（1）插入数据

（2）单条数据查询

（3）扫描数据

（4）删除数据

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;

public class HBase_DML &#123;

    //TODO 插入数据
    public static void putData(String tableName, String rowKey, String cf, String cn, String value) throws IOException &#123;

        //1.获取配置信息并设置连接参数
        Configuration configuration = HBaseConfiguration.create();
        configuration.set("hbase.zookeeper.quorum", "hadoop102,hadoop103,hadoop104");

        //2.获取连接
        Connection connection = ConnectionFactory.createConnection(configuration);

        //3.获取表的连接
        Table table = connection.getTable(TableName.valueOf(tableName));
    //4.1 插入数据
        //4.1.1 创建Put对象
        Put put = new Put(Bytes.toBytes(rowKey));
        //4.1.2 放入数据
        put.addColumn(Bytes.toBytes(cf), Bytes.toBytes(cn), Bytes.toBytes(value));
        //4.1.3 执行插入数据操作
        table.put(put);
     //4.2 单条数据查询
          //4.2.1 创建Get对象
        Get get = new Get(Bytes.toBytes(rowKey));
        // 指定列族查询
        // get.addFamily(Bytes.toBytes(cf));
        // 指定列族:列查询
        // get.addColumn(Bytes.toBytes(cf), Bytes.toBytes(cn));
        //4.2.2查询数据
        Result result = table.get(get);
        //4.2.3解析result
        for (Cell cell : result.rawCells()) &#123;
            System.out.println("ROW:" + Bytes.toString(CellUtil.cloneRow(cell)) +
                        " CF:" + Bytes.toString(CellUtil.cloneFamily(cell))+
                        " CL:" + Bytes.toString(CellUtil.cloneQualifier(cell))+
                        " VALUE:" + Bytes.toString(CellUtil.cloneValue(cell)));
        &#125;

 //4.3 scan数据
        //4.3.1创建Scan对象
        Scan scan = new Scan();
        //4.3.2扫描数据
        ResultScanner results = table.getScanner(scan);

        //4.3.3 解析results
        for (Result result : results) &#123;
            for (Cell cell : result.rawCells()) &#123;
      System.out.println(                       Bytes.toString(CellUtil.cloneRow(cell))+":"+ Bytes.toString(CellUtil.cloneFamily(cell))+":" +  Bytes.toString(CellUtil.cloneQualifier(cell)) +":" +  Bytes.toString(CellUtil.cloneValue(cell))
                );
            &#125;
        &#125;
 //4.4 删除数据
         //4.4.1创建Delete对象
        Delete delete = new Delete(Bytes.toBytes(rowKey));

        // 指定列族删除数据
        // delete.addFamily(Bytes.toBytes(cf));
        // 指定列族:列删除数据(所有版本)
        // delete.addColumn(Bytes.toBytes(cf), Bytes.toBytes(cn));
        // 指定列族:列删除数据(指定版本)
        // delete.addColumns(Bytes.toBytes(cf), Bytes.toBytes(cn));
        //4.4.2执行删除数据操作
        table.delete(delete);

        //5.关闭连接
        table.close();
        connection.close();
    &#125;

&#125;

本文标题:HBase学习笔记（三） HBase的API使用

文章作者:m01ly

发布时间:2020-11-25, 11:22:51

最后更新:2021-11-25, 17:05:31

原始链接:https://m01ly.github.io/2020/11/25/bigdata-HBase3-API/

许可协议: "署名-非商用-相同方式共享 4.0" 转载请保留原文链接及作者。