hbase版本升级的api对比

时间：2021-06-28 06:18:03

前言

今天来介绍一下，hbase的2.1.0版本升级之后和1.2.6版本的api方法的一些不同之处。

hbase的工具类

在介绍hbase的相关的java api之前，这里先介绍一下hbase的工具类，这边我打算将这个demo写成工具类形式，具体的方法，后面可能会介绍，但是不可能面面俱到，具体的还是需要移步apache官网。

步骤一

构建maven工程，添加相关的maven依赖如下：

<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

    <modelVersion>4.0.0</modelVersion>

    <groupId>com.linewell</groupId>
    <artifactId>hbase-test</artifactId>
    <packaging>jar</packaging>
    <version>1.0-SNAPSHOT</version>

    <name>A Camel Route</name>

    <properties>
        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    </properties>

    <dependencyManagement>
        <dependencies>
            <!-- Camel BOM -->
            <dependency>
                <groupId>org.apache.camel</groupId>
                <artifactId>camel-parent</artifactId>
                <version>2.22.1</version>
                <scope>import</scope>
                <type>pom</type>
            </dependency>
        </dependencies>
    </dependencyManagement>

    <dependencies>
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-core</artifactId>
        </dependency>

        <!-- logging -->
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-api</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-core</artifactId>
            <scope>runtime</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.logging.log4j</groupId>
            <artifactId>log4j-slf4j-impl</artifactId>
            <scope>runtime</scope>
        </dependency>

        <!-- testing -->
        <dependency>
            <groupId>org.apache.camel</groupId>
            <artifactId>camel-test</artifactId>
            <scope>test</scope>
        </dependency>
        <dependency>
            <groupId>org.apache.hadoop</groupId>
            <artifactId>hadoop-common</artifactId>
            <version>2.7.3</version>
            <exclusions>
                <exclusion>
                    <artifactId>guava</artifactId>
                    <groupId>com.google.guava</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>xz</artifactId>
                    <groupId>org.tukaani</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>commons-compress</artifactId>
                    <groupId>org.apache.commons</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>jackson-core-asl</artifactId>
                    <groupId>org.codehaus.jackson</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>commons-lang</artifactId>
                    <groupId>commons-lang</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>jackson-jaxrs</artifactId>
                    <groupId>org.codehaus.jackson</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>jackson-mapper-asl</artifactId>
                    <groupId>org.codehaus.jackson</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase-server -->
        <dependency>
            <groupId>org.apache.hbase</groupId>
            <artifactId>hbase-server</artifactId>
            <version>1.2.6</version>
            <exclusions>
                <exclusion>
                    <artifactId>jackson-xc</artifactId>
                    <groupId>org.codehaus.jackson</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>hadoop-annotations</artifactId>
                    <groupId>org.apache.hadoop</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>hadoop-auth</artifactId>
                    <groupId>org.apache.hadoop</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>guava</artifactId>
                    <groupId>com.google.guava</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>hadoop-common</artifactId>
                    <groupId>org.apache.hadoop</groupId>
                </exclusion>
            </exclusions>
        </dependency>
        <!-- https://mvnrepository.com/artifact/org.apache.hbase/hbase-client -->
        <dependency>
            <groupId>org.apache.hbase</groupId>
            <artifactId>hbase-client</artifactId>
            <version>1.2.6</version>
            <exclusions>
                <exclusion>
                    <artifactId>hadoop-common</artifactId>
                    <groupId>org.apache.hadoop</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>guava</artifactId>
                    <groupId>com.google.guava</groupId>
                </exclusion>
                <exclusion>
                    <artifactId>hadoop-auth</artifactId>
                    <groupId>org.apache.hadoop</groupId>
                </exclusion>
                <!--
                <exclusion>
                    <artifactId>hadoop-auth</artifactId>
                    <groupId>org.apache.hadoop</groupId>
                </exclusion>
                -->
            </exclusions>
        </dependency>
        <!-- https://mvnrepository.com/artifact/com.google.guava/guava -->
        <dependency>
            <groupId>com.google.guava</groupId>
            <artifactId>guava</artifactId>
            <version>14.0.1</version>
            <exclusions>
                <exclusion>
                    <artifactId>jsr305</artifactId>
                    <groupId>com.google.code.findbugs</groupId>
                </exclusion>
            </exclusions>
        </dependency>
    </dependencies>

    <build>
        <defaultGoal>install</defaultGoal>

        <plugins>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-compiler-plugin</artifactId>
                <version>3.7.0</version>
                <configuration>
                    <source>1.8</source>
                    <target>1.8</target>
                </configuration>
            </plugin>
            <plugin>
                <groupId>org.apache.maven.plugins</groupId>
                <artifactId>maven-resources-plugin</artifactId>
                <version>3.0.2</version>
                <configuration>
                    <encoding>UTF-8</encoding>
                </configuration>
            </plugin>

            <!-- Allows the example to be run via 'mvn compile exec:java' -->
            <plugin>
                <groupId>org.codehaus.mojo</groupId>
                <artifactId>exec-maven-plugin</artifactId>
                <version>1.6.0</version>
                <configuration>
                    <mainClass>com.linewell.MainApp</mainClass>
                    <includePluginDependencies>false</includePluginDependencies>
                </configuration>
            </plugin>

        </plugins>
    </build>

</project>

步骤二

编写工具类，下面的工具类主要对表的创建和列的添加等等进行了封装，如果有更多的想法，可以在此基础上进行添加：

/**
 * Copyright (C), 2015-2018, hzhiping@linewell.com
 * Title:HbaseUtil
 * Author:hzhiping
 * Date:2018/9/19 10:01
 * Description: 编写HbaseUtil工具类，可执行常规的增删改查操作
 */
package com.linewell.util;

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

import java.io.IOException;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;

public class HbaseUtil {
    private static Configuration configuration = null;
    private static Connection connection = null;
    // 设置集群的连接
    private static final String HBASE_ZOOKEEPER_QUORUM = "master.org.cn,slave01.org.cn,slave03.org.cn";
    // 可以在IP:16010端口所在的web页面查看相关的配置
    private static final String ZOOKEEPER_ZNODE_PARENT = "/hbase";
    private static final String HBASE_ZOOKEEPER_PROPERTY_CLIENTPORT = "2181";

    // 创建hbase连接
    static {
        configuration = HBaseConfiguration.create();
        // 设置hbase连接配置
        configuration.set("hbase.zookeeper.quorum", HBASE_ZOOKEEPER_QUORUM);
        configuration.set("zookeeper.znode.parent", ZOOKEEPER_ZNODE_PARENT);
        configuration.set("hbase.zookeeper.property.clientPort", HBASE_ZOOKEEPER_PROPERTY_CLIENTPORT);
        try {
            connection = ConnectionFactory.createConnection(configuration);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    /**
     * @title:createTable
     * @description:创建表，表名称以参数的形式传递进来
     * @param:tableName 表名
     * @param:column 创建一个列，因为hbase在创建表的同时至少需要创建一个列
     */
    public static void createTable(String column, String tableName) throws IOException {
        /* 1.2.6
        TableName table = TableName.valueOf(tableName);
        Admin admin = connection.getAdmin();
        // 判断表是否存在
        if (admin.tableExists(table)) {
            admin.disableTable(table);// disable
            admin.deleteTable(table);// delete
        }
        HTableDescriptor hTableDescriptor = new HTableDescriptor(table);
        // 创建一个新的列
        HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(column);
        // 设置列的相关属性
        hColumnDescriptor.setMaxVersions(5);
        hColumnDescriptor.setBlockCacheEnabled(true);
        hColumnDescriptor.setBlocksize(1800000);
        // 添加列
        hTableDescriptor.addFamily(hColumnDescriptor);
        // 表创建
        admin.createTable(hTableDescriptor);
        System.out.println("---------表创建完成---------");
        admin.close();
        */
        TableName table = TableName.valueOf(tableName);
        Admin admin = connection.getAdmin();
        TableDescriptorBuilder tableDescriptor = TableDescriptorBuilder.newBuilder(table);
        // 判断表是否存在
        if (admin.tableExists(table)) {
            admin.disableTable(table);// disable
            admin.deleteTable(table);// delete
        }
        // 创建一个新的列族
        ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor columnFamilyDescriptor = new ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor(Bytes.toBytes(column));
        columnFamilyDescriptor.setMaxVersions(5);
        columnFamilyDescriptor.setBlockCacheEnabled(true);
        columnFamilyDescriptor.setBlocksize(1800000);
        // 将列族添加到表中
        TableDescriptorBuilder tableDescriptorBuilder =
                tableDescriptor.setColumnFamily(columnFamilyDescriptor);
        // 创建表
        admin.createTable(tableDescriptorBuilder.build());
    }

    /**
     * @title:deleteTable
     * @description:将表名以参数的形式传入，然后删除表
     * @param:tablename 表名
     */
    public static void deleteTable(String tablename) throws IOException {
        TableName tableName = TableName.valueOf(tablename);
        Admin admin = connection.getAdmin();
        // 判断表是否存在
        if (admin.tableExists(tableName)) {
            admin.disableTable(tableName);
            admin.deleteTable(tableName);
            System.out.println("---------删除表完成---------");
        }
    }

    /**
     * @title:getTable
     * @description:查询该集群中存在的表名
     * @return:TableName 表名
     */
    public static TableName[] getTable() throws IOException {
        /* 1.2.6和2.1.0版本一致*/
        Admin admin = connection.getAdmin();
        TableName[] listTableName = admin.listTableNames();
        System.out.println("---------查询表---------");
        for (TableName tableName : listTableName) {
            System.out.println(tableName.toString());
        }
        return listTableName;
    }

    /**
     * @title:addColumn
     * @description:往指定表中添加列
     * @param:columns 添加的列名
     * @param:tableName 表名
     */
    public static void addColume(String[] columns, String tableName) throws IOException {
        /* 1.2.6
        Admin admin = connection.getAdmin();
        // 列的大小
        int size = columns.length;
        // 遍历数组索引，添加列
        for (int i = 0; i < size; i++) {
            HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(columns[i]);
            admin.addColumn(TableName.valueOf(tableName), hColumnDescriptor);
            System.out.println("inserted " + columns[i] + "...");
        }
        */
        Admin admin = connection.getAdmin();
        // 列的大小
        int size = columns.length;
        for (int i = 0; i < size; i++) {
            ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor columnFamilyDescriptor = new ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor(Bytes.toBytes(columns[i]));
            admin.addColumnFamily(TableName.valueOf(tableName), columnFamilyDescriptor);
            System.out.println("inserted " + columns[i] + "...");
        }
    }

    /**
     * @title:insertData
     * @description:从表中插入数据，表名以参数形式传入[此处插入的数据只是模拟数据]
     * @param:tableName 表名
     */
    public static void insertData(String tablename) throws IOException {
        /* 1.2.6
        Admin admin = connection.getAdmin();
        // 获取表
        HTable hTable = new HTable(configuration, TableName.valueOf(tableName));
        // 获取当前时间戳
        Long timeStamp = System.currentTimeMillis();
        // 将时间戳设置为row key的唯一辨识
        Put put = new Put(Bytes.toBytes("row " + timeStamp.toString()));
        put.add(Bytes.toBytes("personal data"), Bytes.toBytes("name"), Bytes.toBytes("raju"));
        put.add(Bytes.toBytes("personal data"), Bytes.toBytes("city"), Bytes.toBytes("quanzhou"));
        put.add(Bytes.toBytes("professional data"), Bytes.toBytes("designation"), Bytes.toBytes("manager"));
        put.add(Bytes.toBytes("professional data"), Bytes.toBytes("salary"), Bytes.toBytes("50000"));
        hTable.put(put);
        System.out.println("inserted data...");
        hTable.close();
        */
        // 获取表
        TableName tableName = TableName.valueOf(tablename);
        Table table = connection.getTable(tableName);
        // 简单测试
        Long timeStamp = System.currentTimeMillis();
        Put put = new Put(Bytes.toBytes("row " + timeStamp.toString()));
        put.addColumn(Bytes.toBytes("personal data"), Bytes.toBytes("name"), Bytes.toBytes("raju"));
        put.addColumn(Bytes.toBytes("personal data"), Bytes.toBytes("city"), Bytes.toBytes("quanzhou"));
        put.addColumn(Bytes.toBytes("professional data"), Bytes.toBytes("designation"), Bytes.toBytes("manager"));
        put.addColumn(Bytes.toBytes("professional data"), Bytes.toBytes("salary"), Bytes.toBytes("50000"));
        table.put(put);
        System.out.println("inserted data...");
    }

    /**
     * @title:uptData
     * @description:更新数据
     * @param:tableName 表名
     */
    public static void uptData(String tableName) throws IOException {
        TableName tablename = TableName.valueOf(tableName);
        Table table = connection.getTable(tablename);
        Put put = new Put(Bytes.toBytes("row 1539179928919"));
        put.addColumn(Bytes.toBytes("personal data"), Bytes.toBytes("name"), Bytes.toBytes("hzhihui"));
        table.put(put);
        System.out.println("updated data...");
    }

    /**
     * @title:delData
     * @description:删除一行或者多行的数据
     * @param:tableName 表名
     * @param:rowKeys 主键
     */
    public static void delData(String tableName, String[] rowKeys) throws IOException {
        TableName tablename = TableName.valueOf(tableName);
        Table table = connection.getTable(tablename);
        List<Delete> deleteList = new ArrayList<Delete>(rowKeys.length);
        Delete delete;
        for(String rowKey:rowKeys){
            delete = new Delete(Bytes.toBytes(rowKey));
            deleteList.add(delete);
        }
        table.delete(deleteList);
        System.out.println("deleted data...");
    }

    /**
     * @title:scanTable
     * @description:查询hbase的表数据
     * @param:tableName
     */
    public static void scanTable(String tableName) throws IOException {
        /*  1.2.6
        Admin admin = connection.getAdmin();
        HTable table = new HTable(configuration, TableName.valueOf(tableName));
        // scan多行输出
        Scan scan = new Scan();
        ResultScanner resultScanner = table.getScanner(scan);
        // 遍历结果集，输出所有的结果
        for (Result result : resultScanner) {
            for (Cell cell : result.rawCells()) {
                System.out.println(Bytes.toString(result.getRow()) + "\t"
                        + Bytes.toString(CellUtil.cloneQualifier(cell)) + "\t"
                        + Bytes.toString(CellUtil.cloneValue(cell)) + "\t"
                        + cell.getTimestamp()
                );
                System.out.println("--------------------华丽的分割线--------------------");
            }
        }
        */
        // 获取表名
        TableName tablename = TableName.valueOf(tableName);
        Table table = connection.getTable(tablename);
        Scan scan = new Scan();
        ResultScanner resultScanner = table.getScanner(scan);
        for (Result result : resultScanner) {
            for (Cell cell : result.rawCells()) {
                System.out.println(Bytes.toString(result.getRow()) + "\t"
                        + Bytes.toString(CellUtil.cloneQualifier(cell)) + "\t"
                        + Bytes.toString(CellUtil.cloneValue(cell)) + "\t"
                        + cell.getTimestamp()
                );
                System.out.println("--------------------华丽的分割线--------------------");
            }
        }
    }
}

HbaseUtil.java/**
 * Copyright (C), 2015-2018, hzhiping@linewell.com
 * Title:HbaseUtil
 * Author:hzhiping
 * Date:2018/9/19 10:01
 * Description: 编写HbaseUtil工具类，可执行常规的增删改查操作
 */
package com.linewell.util;

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

import java.io.IOException;
import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;

public class HbaseUtil {
    private static Configuration configuration = null;
    private static Connection connection = null;
    // 设置集群的连接
    private static final String HBASE_ZOOKEEPER_QUORUM = "master.org.cn,slave01.org.cn,slave03.org.cn";
    // 可以在IP:16010端口所在的web页面查看相关的配置
    private static final String ZOOKEEPER_ZNODE_PARENT = "/hbase";
    private static final String HBASE_ZOOKEEPER_PROPERTY_CLIENTPORT = "2181";

    // 创建hbase连接
    static {
        configuration = HBaseConfiguration.create();
        // 设置hbase连接配置
        configuration.set("hbase.zookeeper.quorum", HBASE_ZOOKEEPER_QUORUM);
        configuration.set("zookeeper.znode.parent", ZOOKEEPER_ZNODE_PARENT);
        configuration.set("hbase.zookeeper.property.clientPort", HBASE_ZOOKEEPER_PROPERTY_CLIENTPORT);
        try {
            connection = ConnectionFactory.createConnection(configuration);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

    /**
     * @title:createTable
     * @description:创建表，表名称以参数的形式传递进来
     * @param:tableName 表名
     * @param:column 创建一个列，因为hbase在创建表的同时至少需要创建一个列
     */
    public static void createTable(String column, String tableName) throws IOException {
        /* 1.2.6
        TableName table = TableName.valueOf(tableName);
        Admin admin = connection.getAdmin();
        // 判断表是否存在
        if (admin.tableExists(table)) {
            admin.disableTable(table);// disable
            admin.deleteTable(table);// delete
        }
        HTableDescriptor hTableDescriptor = new HTableDescriptor(table);
        // 创建一个新的列
        HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(column);
        // 设置列的相关属性
        hColumnDescriptor.setMaxVersions(5);
        hColumnDescriptor.setBlockCacheEnabled(true);
        hColumnDescriptor.setBlocksize(1800000);
        // 添加列
        hTableDescriptor.addFamily(hColumnDescriptor);
        // 表创建
        admin.createTable(hTableDescriptor);
        System.out.println("---------表创建完成---------");
        admin.close();
        */
        TableName table = TableName.valueOf(tableName);
        Admin admin = connection.getAdmin();
        TableDescriptorBuilder tableDescriptor = TableDescriptorBuilder.newBuilder(table);
        // 判断表是否存在
        if (admin.tableExists(table)) {
            admin.disableTable(table);// disable
            admin.deleteTable(table);// delete
        }
        // 创建一个新的列族
        ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor columnFamilyDescriptor = new ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor(Bytes.toBytes(column));
        columnFamilyDescriptor.setMaxVersions(5);
        columnFamilyDescriptor.setBlockCacheEnabled(true);
        columnFamilyDescriptor.setBlocksize(1800000);
        // 将列族添加到表中
        TableDescriptorBuilder tableDescriptorBuilder =
                tableDescriptor.setColumnFamily(columnFamilyDescriptor);
        // 创建表
        admin.createTable(tableDescriptorBuilder.build());
    }

    /**
     * @title:deleteTable
     * @description:将表名以参数的形式传入，然后删除表
     * @param:tablename 表名
     */
    public static void deleteTable(String tablename) throws IOException {
        TableName tableName = TableName.valueOf(tablename);
        Admin admin = connection.getAdmin();
        // 判断表是否存在
        if (admin.tableExists(tableName)) {
            admin.disableTable(tableName);
            admin.deleteTable(tableName);
            System.out.println("---------删除表完成---------");
        }
    }

    /**
     * @title:getTable
     * @description:查询该集群中存在的表名
     * @return:TableName 表名
     */
    public static TableName[] getTable() throws IOException {
        /* 1.2.6和2.1.0版本一致*/
        Admin admin = connection.getAdmin();
        TableName[] listTableName = admin.listTableNames();
        System.out.println("---------查询表---------");
        for (TableName tableName : listTableName) {
            System.out.println(tableName.toString());
        }
        return listTableName;
    }

    /**
     * @title:addColumn
     * @description:往指定表中添加列
     * @param:columns 添加的列名
     * @param:tableName 表名
     */
    public static void addColume(String[] columns, String tableName) throws IOException {
        /* 1.2.6
        Admin admin = connection.getAdmin();
        // 列的大小
        int size = columns.length;
        // 遍历数组索引，添加列
        for (int i = 0; i < size; i++) {
            HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(columns[i]);
            admin.addColumn(TableName.valueOf(tableName), hColumnDescriptor);
            System.out.println("inserted " + columns[i] + "...");
        }
        */
        Admin admin = connection.getAdmin();
        // 列的大小
        int size = columns.length;
        for (int i = 0; i < size; i++) {
            ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor columnFamilyDescriptor = new ColumnFamilyDescriptorBuilder.ModifyableColumnFamilyDescriptor(Bytes.toBytes(columns[i]));
            admin.addColumnFamily(TableName.valueOf(tableName), columnFamilyDescriptor);
            System.out.println("inserted " + columns[i] + "...");
        }
    }

    /**
     * @title:insertData
     * @description:从表中插入数据，表名以参数形式传入[此处插入的数据只是模拟数据]
     * @param:tableName 表名
     */
    public static void insertData(String tablename) throws IOException {
        /* 1.2.6
        Admin admin = connection.getAdmin();
        // 获取表
        HTable hTable = new HTable(configuration, TableName.valueOf(tableName));
        // 获取当前时间戳
        Long timeStamp = System.currentTimeMillis();
        // 将时间戳设置为row key的唯一辨识
        Put put = new Put(Bytes.toBytes("row " + timeStamp.toString()));
        put.add(Bytes.toBytes("personal data"), Bytes.toBytes("name"), Bytes.toBytes("raju"));
        put.add(Bytes.toBytes("personal data"), Bytes.toBytes("city"), Bytes.toBytes("quanzhou"));
        put.add(Bytes.toBytes("professional data"), Bytes.toBytes("designation"), Bytes.toBytes("manager"));
        put.add(Bytes.toBytes("professional data"), Bytes.toBytes("salary"), Bytes.toBytes("50000"));
        hTable.put(put);
        System.out.println("inserted data...");
        hTable.close();
        */
        // 获取表
        TableName tableName = TableName.valueOf(tablename);
        Table table = connection.getTable(tableName);
        // 简单测试
        Long timeStamp = System.currentTimeMillis();
        Put put = new Put(Bytes.toBytes("row " + timeStamp.toString()));
        put.addColumn(Bytes.toBytes("personal data"), Bytes.toBytes("name"), Bytes.toBytes("raju"));
        put.addColumn(Bytes.toBytes("personal data"), Bytes.toBytes("city"), Bytes.toBytes("quanzhou"));
        put.addColumn(Bytes.toBytes("professional data"), Bytes.toBytes("designation"), Bytes.toBytes("manager"));
        put.addColumn(Bytes.toBytes("professional data"), Bytes.toBytes("salary"), Bytes.toBytes("50000"));
        table.put(put);
        System.out.println("inserted data...");
    }

    /**
     * @title:uptData
     * @description:更新数据
     * @param:tableName 表名
     */
    public static void uptData(String tableName) throws IOException {
        TableName tablename = TableName.valueOf(tableName);
        Table table = connection.getTable(tablename);
        Put put = new Put(Bytes.toBytes("row 1539179928919"));
        put.addColumn(Bytes.toBytes("personal data"), Bytes.toBytes("name"), Bytes.toBytes("hzhihui"));
        table.put(put);
        System.out.println("updated data...");
    }

    /**
     * @title:delData
     * @description:删除一行或者多行的数据
     * @param:tableName 表名
     * @param:rowKeys 主键
     */
    public static void delData(String tableName, String[] rowKeys) throws IOException {
        TableName tablename = TableName.valueOf(tableName);
        Table table = connection.getTable(tablename);
        List<Delete> deleteList = new ArrayList<Delete>(rowKeys.length);
        Delete delete;
        for(String rowKey:rowKeys){
            delete = new Delete(Bytes.toBytes(rowKey));
            deleteList.add(delete);
        }
        table.delete(deleteList);
        System.out.println("deleted data...");
    }

    /**
     * @title:scanTable
     * @description:查询hbase的表数据
     * @param:tableName
     */
    public static void scanTable(String tableName) throws IOException {
        /*  1.2.6
        Admin admin = connection.getAdmin();
        HTable table = new HTable(configuration, TableName.valueOf(tableName));
        // scan多行输出
        Scan scan = new Scan();
        ResultScanner resultScanner = table.getScanner(scan);
        // 遍历结果集，输出所有的结果
        for (Result result : resultScanner) {
            for (Cell cell : result.rawCells()) {
                System.out.println(Bytes.toString(result.getRow()) + "\t"
                        + Bytes.toString(CellUtil.cloneQualifier(cell)) + "\t"
                        + Bytes.toString(CellUtil.cloneValue(cell)) + "\t"
                        + cell.getTimestamp()
                );
                System.out.println("--------------------华丽的分割线--------------------");
            }
        }
        */
        // 获取表名
        TableName tablename = TableName.valueOf(tableName);
        Table table = connection.getTable(tablename);
        Scan scan = new Scan();
        ResultScanner resultScanner = table.getScanner(scan);
        for (Result result : resultScanner) {
            for (Cell cell : result.rawCells()) {
                System.out.println(Bytes.toString(result.getRow()) + "\t"
                        + Bytes.toString(CellUtil.cloneQualifier(cell)) + "\t"
                        + Bytes.toString(CellUtil.cloneValue(cell)) + "\t"
                        + cell.getTimestamp()
                );
                System.out.println("--------------------华丽的分割线--------------------");
            }
        }
    }
}

当然了，后续笔者会将demo代码链接上来。

源码链接

本例子代码：仓库的hbase01

坚壁清野

相关文章