Win下使用Java操作远程分布式集群中的HBase

前提条件

1. 本地Windows(7或10)系统下已经装好了JDK和Eclipse，笔者电脑JDK1.8。
2. 已经有搭建好的完全分布式集群，并已经成功启动Hadoop，Zookeeper和HBase。笔者当前搭建好的集群是Hadoop-3.0.3，Zookeeper-3.4.13和HBase-2.1.0。
3. 本地已经成功连接到远程HBase，连接方法详见：本地Java连接远程集群上的HBase

以下先逐个讲解每个操作的方法，文章最后附完整代码。

前言：建立连接和关闭连接

1.需要三个静态属性

public static Configuration configuration; //配置对象，用于管理配置信息(类似hbase-site.xml)
public static Connection connection;       //连接对象，用于连接数据库
public static Admin admin;                 //管理对象，用于管理表(如对表的增删改查)

2.创建连接(初始化)

public static void init(){
    	//1.根据hbase-site.xml文件初始化Configuration对象
        configuration  = HBaseConfiguration.create();
        configuration.set(\"hbase.rootdir\",\"hdfs://master:9000/hbase\");
        configuration.set(\"hbase.zookeeper.quorum\", \"master,ceph1,ceph2,ceph3\");
		configuration.set(\"hbase.zookeeper.property.clientPort\", \"2181\");
        try{
        	 //2.根据Configuration对象初始化Connection对象
            connection = ConnectionFactory.createConnection(configuration);
            //3.根据Connection对象获取Admin对象
            admin = connection.getAdmin(); 
            System.out.println(\"连接HBase成功.\");
        }catch (IOException e){
            System.err.println(\"连接HBase失败.\");
        }
    }

连接是否成功的关键代码是：

connection = ConnectionFactory.createConnection(configuration);

3.关闭连接
实际就是close掉admin和connection。

public static void close(){
    try{
        if(admin != null){
            admin.close();
        }
        if(null != connection){
            connection.close();
        }
    }catch (IOException e){
        e.printStackTrace();
    }
}

一、创建数据库表

查询新的API文档发现官网确实要在3.x版本中废弃1.x用的类和部分方法，遂笔者换了一个新的类和方法实现创建表功能。

public static void createTable(String myTableName,String[] colFamily) throws IOException {
    init();  //创建连接
    TableName tableName = TableName.valueOf(myTableName); 
    if(admin.tableExists(tableName)){ //若要创建的表名存在，则无需创建新表
        System.out.println(\"talbe is exists!\");
    }else {  //若要创建的表名不存在，则创建新表
        TableDescriptorBuilder tableDescriptor = TableDescriptorBuilder.newBuilder(tableName);  //创建新表实例
        for(String str:colFamily){  
            ColumnFamilyDescriptor columnfamily = ColumnFamilyDescriptorBuilder.of(str);  //根据字符串列簇名分别创建新的列簇
            tableDescriptor.setColumnFamily(columnfamily); //把新列簇依次添加到新表实例中
        }
        admin.createTable(tableDescriptor.build()); //把创建的新表实例添加到HBase中
        System.out.println(\"create table success\");
    }
    close();  //关闭连接
}

示例：创建一个名字为ls_world表，列簇分别为w1，w2。

createTable(\"ls_world\",new String[]{\"w1\",\"w2\"});

在命令行或http://10.0.86.245:16010可看到

补充：

待更新~