Java 操作Hbase 完整例子

Posted 2021-03-02

开发工具：Eclipse，
三步
1.新建一个项目
2.把hbase安装下的lib的文件都拷贝进来
3.把lib目录下jar文件都引入
4.lib下的client-facing-thirdparty 目录下的jar也都引入
看图

package com.yue;

import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.;
import org.apache.hadoop.hbase.client.;

import java.io.IOException;
public class Test {
public static Configuration configuration; // 管理Hbase的配置信息
public static Connection connection; // 管理Hbase连接
public static Admin admin; // 管理Hbase数据库的信息

public static void main(String[] args) throws IOException {
    // TODO Auto-generated method stub
    System.out.println("sheet");
    init();
    String colF[] ={"score"};
    createTable("stu41",colF);
    insertData("stu41","zhangsan","score","English","69");
    insertData("stu41","lisi","score","English","69");
    getData("stu41","zhangsan","score","English");
    close();
}

public static void init(){
     configuration = HBaseConfiguration.create();
     configuration.set("hbase.zookeeper.quorum", "localhost");
    try{
     connection = ConnectionFactory.createConnection(configuration);
    admin = connection.getAdmin();
    }catch(IOException e){
        e.printStackTrace();
    }

 }

 public static void createTable(String myTableName,String[] colFamily) throws IOException{
        TableName tableName = TableName.valueOf(myTableName);
        if(admin.tableExists(tableName)){
            System.out.println("Table exists");
        }else {
            HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName);
            for(String str:colFamily){
                HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(str);
                hTableDescriptor.addFamily(hColumnDescriptor);
            }
            admin.createTable(hTableDescriptor);
        }
    }

 // 添加单元格数据
    /*
    * @param tableName 表名
    * @param rowKey 行键
    * @param colFamily 列族
    * @param col 列限定符
    * @param val 数据
    * @thorws Exception
    * */
    public static void insertData(String tableName,String rowKey,String colFamily,String col,String val) throws IOException{
        Table table = connection.getTable(TableName.valueOf(tableName));
        Put put = new Put(rowKey.getBytes());
        put.addColumn(colFamily.getBytes(),col.getBytes(),val.getBytes());
        table.put(put);
        table.close();
    }

  //浏览数据
    /*
    * @param tableName 表名
    * @param rowKey 行
    * @param colFamily 列族
    * @param col 列限定符
    * @throw IOException
    * */
    public static void getData(String tableName,String rowKey,String colFamily,String col) throws IOException{
        Table table = connection.getTable(TableName.valueOf(tableName));
        Get get = new Get(rowKey.getBytes());
        get.addColumn(colFamily.getBytes(),col.getBytes());
        Result result =table.get(get);
        System.out.println(new String(result.getValue(colFamily.getBytes(),col==null?null:col.getBytes())));
        table.close();
    }

    // 操作数据库之后，关闭连接
    public static void close(){
        try{
            if(admin!=null){
                admin.close(); // 退出用户
            }
            if(null != connection){
                connection.close(); // 关闭连接
            }
        }catch (IOException e){
            e.printStackTrace();
        }
    }

  //删除表
    public static void deleteTable(String tableName){

        try {
            TableName tablename = TableName.valueOf(tableName);
            admin = connection.getAdmin();
            admin.disableTable(tablename);
            admin.deleteTable(tablename);
        } catch (IOException e) {
            e.printStackTrace();
        }
    }

 //End

}
单机模式

configuration = HBaseConfiguration.create();
configuration.set("hbase.zookeeper.quorum", "localhost");
集群模式

configuration.set("hbase.rootdir","hdfs://master:9000/hbase");//主节点
configuration.set("hbase.zookeeper.quorum","master,slave1,slave2"); // 设置zookeeper节点
configuration.set("hbase.zookeeper.property.clientPort","2181"); // 设置客户端节点
java开发Hbase简直不费劲，当时鼓捣那个php操作Hbase搞了好几天。
https://java-er.com/blog/java-hbase-example/