关于hbase:Hbase常用数据库操作类

pom.xml 中援用 hbase-client

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

HBaseConn.java 获取 hbase 链接

package com.rumenz;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.HBaseConfiguration;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.Connection;
import org.apache.hadoop.hbase.client.ConnectionFactory;
import org.apache.hadoop.hbase.client.Table;

import java.io.IOException;


public class HBaseConn {private static final HBaseConn INSTANCE=new HBaseConn();
      private static Configuration configuration;
      private static Connection connection;

      private HBaseConn(){
          try{if(configuration==null){configuration=HBaseConfiguration.create();
                  configuration.set("hbase.zookeeper.quorum", "192.168.82.177:2181");
              }
          }catch (Exception e){e.printStackTrace();
          }
      }
      private Connection getConnection(){if(connection==null||connection.isClosed()){
               try{connection=ConnectionFactory.createConnection(configuration);
               }catch(Exception e){e.printStackTrace();
               }
          }
          return connection;
      }
      public static Connection getHbaseConn(){return INSTANCE.getConnection();
      }
      public static Table getTable(String table) throws IOException {return INSTANCE.getConnection().getTable(TableName.valueOf(table));
      }
      public static void closeConn(){if(connection!=null){
             try{connection.close();
             }catch(Exception e){e.printStackTrace();
             }
          }
      }

}

HBaseUtil.java 数据库增删改查操作

package com.rumenz;

import org.apache.hadoop.hbase.HTableDescriptor;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.filter.FilterList;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;
import java.util.ArrayList;
import java.util.Arrays;
import java.util.List;

public class HBaseUtil {

    /**
     * 创立一个表
     * @param tableName 表名
     * @param cf 列族名
     * @return
     * @throws IOException
     */

    public static boolean createTable(String tableName,String[] cf) throws IOException {try(HBaseAdmin admin = (HBaseAdmin) HBaseConn.getHbaseConn().getAdmin()){if(admin.tableExists(TableName.valueOf(tableName))){return false;}
            List<ColumnFamilyDescriptor> res=new ArrayList<>();
            Arrays.stream(cf).forEach(cff->{res.add(ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(cff)).build());
            });
            TableDescriptor hTableDescriptor= TableDescriptorBuilder.newBuilder(TableName.valueOf(tableName)).setColumnFamilies(res).build();
            admin.createTable(hTableDescriptor);
        }catch(Exception e){e.printStackTrace();
        }
        return true;
    }

    /**
     * 删除一个表
     * @param tableName 表名
     * @return
     */

    public static boolean deleteTable(String tableName){try(HBaseAdmin admin= (HBaseAdmin) HBaseConn.getHbaseConn().getAdmin()){admin.disableTable(TableName.valueOf(tableName));
            admin.deleteTable(TableName.valueOf(tableName));
        }catch(Exception e){e.printStackTrace();

        }
        return true;
    }

    /**
     *  插入一条数据
     * @param tableName 表名
     * @param rowkey    主键
     * @param cfName    列族
     * @param qualifier 列名
     * @param data   数据
     * @return
     */
    public static boolean putRow(String tableName,String rowkey,String cfName,String qualifier,String data){try(Table table=  HBaseConn.getTable(tableName)){Put put=new Put(Bytes.toBytes(rowkey));
            put.addColumn(Bytes.toBytes(cfName), Bytes.toBytes(qualifier), Bytes.toBytes(data));
            table.put(put);

        }catch (Exception e){e.printStackTrace();
        }
        return true;
    }

    /**
     * 批量增加数据
     * @param tableName 表名
     * @param puts      数据列表
     * @return
     */
    public static boolean putRows(String tableName,List<Put> puts){try(Table table=  HBaseConn.getTable(tableName)){table.put(puts);
        }catch (Exception e){e.printStackTrace();
        }
        return true;
    }

    /**
     * 通过 rowkey 查问数据
     * @param tableName 表名
     * @param rowkey    rowkey
     * @return
     * @throws IOException
     */
    public static Result getRow(String tableName,String rowkey) throws IOException {try(Table table=HBaseConn.getTable(tableName)){Get get=new Get(Bytes.toBytes(rowkey));
           return table.get(get);
       }catch (Exception e){e.printStackTrace();
       }
        return null;
    }

    /**
     * 通过 scan 查问数据
     * @param tableName 表名
     * @param startRow  开始的 row
     * @param endRow    完结的 row
     * @return
     */
    public static ResultScanner getScanner(String tableName,String startRow,String endRow){try(Table table=HBaseConn.getTable(tableName)){Scan scan=new Scan();
            scan.withStartRow(Bytes.toBytes(startRow));
            scan.withStopRow(Bytes.toBytes(endRow));
            scan.setCaching(1000);
            return  table.getScanner(scan);
        }catch (Exception e){e.printStackTrace();
        }
        return null;
    }

    /**
     * 通过过滤器查问数据
     * @param tableName 表名
     * @param startRow  开始
     * @param endRow    完结
     * @param flist     过滤器
     * @return
     */
    public static ResultScanner getScanner(String tableName, String startRow, String endRow, FilterList flist){try(Table table=HBaseConn.getTable(tableName)){Scan scan=new Scan();
            scan.withStartRow(Bytes.toBytes(startRow));
            scan.withStopRow(Bytes.toBytes(endRow));
            scan.setFilter(flist);
            scan.setCaching(1000);
            return  table.getScanner(scan);
        }catch (Exception e){e.printStackTrace();
        }
        return null;
    }

    /**
     * 通过 rowkey 删除数据
     * @param tableName 表名
     * @param rowKey    rowkey
     * @return
     */
    public static boolean deleteRow(String tableName,String rowKey){try(Table table=HBaseConn.getTable(tableName)){Delete delete=new Delete(Bytes.toBytes(rowKey));
           table.delete(delete);
       }catch (Exception e){e.printStackTrace();
       }
       return true;
    }

    /**
     * 删除列族
     * @param tableName 表名
     * @param cfName    列族
     * @return
     */
    public static boolean deleteColumnFamily(String tableName,String cfName){try(HBaseAdmin admin= (HBaseAdmin) HBaseConn.getHbaseConn().getAdmin()){admin.deleteColumnFamily(TableName.valueOf(tableName),Bytes.toBytes(cfName));
        }catch (Exception e){e.printStackTrace();
        }
        return true;
    }

    /**
     * 删除列名
     * @param tableName  表名
     * @param rowKey     rowkey
     * @param cfName     列族
     * @param qualifier  列名
     * @return
     */
    public static boolean deleteQualifier(String tableName,String rowKey,String cfName,String qualifier){try(Table table=HBaseConn.getTable(tableName)){Delete delete=new Delete(Bytes.toBytes(rowKey));
            delete.addColumn(Bytes.toBytes(cfName), Bytes.toBytes(qualifier));
            table.delete(delete);
        }catch (Exception e){e.printStackTrace();
        }
        return true;

    }

}