Hbase工具类 V2.0.5

提供了

1.创建链接

2.创建命名空间

3.判断表存在与否

4.创建表

5.修改表

6.删除表

7.插入数据

8.查询数据

9.扫描数据

10.删除数据 

            
                org.apache.hbase
                hbase-server
                2.0.5
                
                    
                        org.glassfish
                        javax.el
                    
                
            
            
                org.apache.hbase
                hbase-client
                2.0.5
            
            
                org.glassfish
                javax.el
                3.0.1-b06
            
    

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.util.ArrayList;
import java.util.List;

public class HbaseUtils {
    
    private static String value="hadoop102,hadoop103,hadoop104";
    private static Connection connection;
    static{
        try {
            Configuration conf = HbaseConfiguration.create();
            conf.set("hbase.zookeeper.quorum", value);
            connection = ConnectionFactory.createConnection(conf);
            System.out.println("连接成功");
        }catch (Exception e) {
            System.out.println(e);
        }
    }
    
    public static Boolean createNameSpace(String namespace){
        boolean flag = false;
        try {
            Admin admin = connection.getAdmin();
            NamespaceDescriptor db = NamespaceDescriptor.create(namespace).build();
            admin.createNamespace(db);
            flag = true;
        }catch (Exception e) {
            System.out.println(e);
        }
        return flag;
    }
    
    public static boolean isTableExist(String namespace,String tableName) throws IOException {
        Admin admin = connection.getAdmin();
        boolean flag = admin.tableExists(TableName.valueOf(namespace, tableName));
        admin.close();
        return flag;
    }
    
    public static boolean createTable(String namespace,String tableName,String... familyNames) throws IOException {
        if (familyNames.length <= 0) {
            System.out.println("请输入列族数");
            return false;
        }
        if (isTableExist(namespace,tableName)) {
            System.out.println("表格已存在");
            return false;
        }
        Admin admin = connection.getAdmin();
        TableDescriptorBuilder builder = TableDescriptorBuilder.newBuilder(TableName.valueOf(namespace, tableName));
        for (String familyName : familyNames) {
            ColumnFamilyDescriptorBuilder builder1 = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(familyName));
            builder1.setMaxVersions(2);
            builder.setColumnFamily(builder1.build());
        }
        admin.createTable(builder.build());
        admin.close();
        return true;
    }
    
    public static boolean modifyTable(String nameSpace,String tableName,String familyName,int version) throws IOException {
        Admin admin = connection.getAdmin();
        TableDescriptor descriptor = admin.getDescriptor(TableName.valueOf(nameSpace, tableName));
        TableDescriptorBuilder tableDescriptorBuilder = TableDescriptorBuilder.newBuilder(descriptor);
        ColumnFamilyDescriptorBuilder columnFamilyDescriptorBuilder = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(familyName)).setMaxVersions(version);
        tableDescriptorBuilder.modifyColumnFamily(columnFamilyDescriptorBuilder.build());
        admin.modifyTable(tableDescriptorBuilder.build());
        admin.close();
        return true;
    }
    
    public static boolean deleteTable(String nameSpace,String tableName) throws IOException {
        if (!isTableExist(nameSpace, tableName)){
            System.out.println("表格不存在");
            return false;
        }
        Admin admin = connection.getAdmin();
        admin.disableTable(TableName.valueOf(nameSpace, tableName));
        admin.deleteTable(TableName.valueOf(nameSpace, tableName));
        admin.close();
        return true;
    }
    
    public static void putCell(String nameSpace,String tableName,String rowKey,String family,String column,String value) throws IOException {
        Table table = connection.getTable(TableName.valueOf(nameSpace, tableName));
        Put put = new Put(Bytes.toBytes(rowKey));
        put.addColumn(Bytes.toBytes(family),Bytes.toBytes(column),Bytes.toBytes(value));
        table.put(put);
        table.close();
    }
    
    public static String getCell(String nameSpace,String tableName,String rowKey,String family,String column) throws IOException {
        Table table = connection.getTable(TableName.valueOf(nameSpace, tableName));
        Get get = new Get(Bytes.toBytes(rowKey));
        get.addColumn(Bytes.toBytes(family),Bytes.toBytes(column));
        Result result = table.get(get);
        Cell[] cells = result.rawCells();
        String value = "";
        for (Cell cell : cells) {
            value += Bytes.toString(CellUtil.clonevalue(cell)) + "-";
        }
        table.close();
        return value;
    }
    
    public static List scanRows(String nameSpace, String tableName, String startRow, String stopRow) throws IOException {
        Table table = connection.getTable(TableName.valueOf(nameSpace, tableName));
        Scan scan = new Scan().withStartRow(Bytes.toBytes(startRow)).withStopRow(Bytes.toBytes(stopRow));
        ResultScanner scanner = table.getScanner(scan);
        ArrayList arrayList = new ArrayList<>();
        for (Result result : scanner) {
            arrayList.add(Bytes.toString(result.value()));
        }
        // 5.关闭资源
        scanner.close();
        table.close();
        return arrayList;
    }
    
    public static void deleteColumn(String nameSpace, String tableName, String rowKey, String family, String column) throws IOException {
        Table table = connection.getTable(TableName.valueOf(nameSpace, tableName));
        Delete delete = new Delete(Bytes.toBytes(rowKey));
        delete.addColumns(Bytes.toBytes(family), Bytes.toBytes(column));
        table.delete(delete);
        table.close();
    }

    public static void close(){
        try {
            connection.close();
        }catch (Exception e) {
            System.out.println("关闭连接失败");
        }
    }
}