HBase Shell API 操作

创建工程

本实验的环境实在ubuntu18.04下完成，首先在改虚拟机中安装开发工具eclipse。

然后创建Java项目名字叫hbase-test

配置运行环境

在src下创建HBaseDemo类

然后编写init方法和close方法，一个创建与HBASE的连接，一个关闭连接。

/**

	 * 创建连接返回admin

	 */

	public static void init() {

		configuration = HBaseConfiguration.create();

		configuration.set("hbase.rootdir", "file:///usr/local/hbase/hbase-tmp");

		// configuration.set("hbase.zookeeper.quorum", "hadoop02");

		try {

			connection = ConnectionFactory.createConnection(configuration);

			admin = connection.getAdmin();

		} catch (IOException e) {

			e.printStackTrace();

		}

	}

	/**

	 * 连接关闭

	 */

	public static void close() {

		try {

			if (admin != null) {

				admin.close();

			}

			if (null != connection) {

				connection.close();

			}

		} catch (IOException e) {

			e.printStackTrace();

		}

	}

建表操作

	/**

	 * 创建表方法

	 *

	 * @param myTableName

	 * @param colFamily

	 * @throws IOException

	 */

	public static void createTable(String myTableName, String[] colFamily) throws IOException {

		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 family = ColumnFamilyDescriptorBuilder.newBuilder(Bytes.toBytes(str)).build();

				tableDescriptor.setColumnFamily(family);

			}

			admin.createTable(tableDescriptor.build());

		}

	}

测试：创建student表，列族有score

	public static void main(String[] args) throws IOException {

		init();

		System.out.print("==================分割线===================");

		//创建student表

		  createTable("student",new String[]{"score"});

		close();

	}

查看执行结果

查看现有表的名称

	 /**

     * 查看已有表

     * @throws IOException

     */

    public static void listTables() throws IOException {

        init();

        HTableDescriptor hTableDescriptors[] = admin.listTables();

        for(HTableDescriptor hTableDescriptor :hTableDescriptors){

            System.out.println(hTableDescriptor.getNameAsString());

        }

        close();

     }

测试：

public static void main(String[] args) throws IOException {

		init();

		System.out.println("==================分割线===================");

		listTables();

		System.out.println("==================分割线===================");

		close();

	}

删除表操作

代码：

	/**

     * 删除指定表

     * @param tableName 表名

     * @throws IOException

     */

    public static void deleteTable(String tableName) throws IOException {

        init();

        TableName tn = TableName.valueOf(tableName);

        if (admin.tableExists(tn)) {

            admin.disableTable(tn);

            admin.deleteTable(tn);

        }

        close();

}

测试：

public static void main(String[] args) throws IOException {

		init();

		System.out.println("==================分割线===================");

		deleteTable("student");

		System.out.println("==================分割线===================");

		close();

	}

结果

删除指定列操作

代码

    /**

     * 删除指定列数据

     * @param tableName 表名

     * @param rowKey 行键

     * @param colFamily 列族名

     * @param col 列名

     * @throws IOException

     */

    public static void deleteRow(String tableName,String rowKey,String colFamily,String col) throws IOException {

        init();

        Table table = connection.getTable(TableName.valueOf(tableName));

        Delete delete = new Delete(rowKey.getBytes());

        //删除指定列族的所有数据

        //delete.addFamily(colFamily.getBytes());

        //删除指定列的数据

        delete.addColumn(colFamily.getBytes(), col.getBytes());

        table.delete(delete);

        table.close();

        close();

}

测试

public static void main(String[] args) throws IOException {

		init();

		System.out.println("==================分割线===================");

		deleteRow("student", "zhangsan", "score", "Math");

		System.out.println("==================分割线===================");

		close();

	}

结果 zhangsan行，score列族中的Math列被删除

添加数据

	/**

	 * 向指定表中插入数据

	 *

	 * @param tableName

	 * @param rowKey

	 * @param colFamily

	 * @param col

	 * @param val

	 * @throws IOException

	 */

	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();

	}

向student表中添加三条数据，分别是zhangsan的英语成绩，数学成绩和计算机成绩。

	public static void main(String[] args) throws IOException {

		init();

		System.out.print("==================分割线===================");

		  //插入三条数据

		  insertData("student","zhangsan","score","English","69");

		  insertData("student","zhangsan","score","Math","86");

		  insertData("student","zhangsan","score","Computer","77");

		close();

	}

测试结果

查看数据

/**

	 * 获取指定表中ceil数据

	 *

	 * @param tableName

	 * @param rowKey

	 * @param colFamily

	 * @param col

	 * @throws 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(tableName+"表，"+colFamily+"列族，"+col+"的值是："+new String(result.getValue(colFamily.getBytes(), col == null ? null : col.getBytes())));

		table.close();

	}

查看张三英语的成绩

	public static void main(String[] args) throws IOException {

		init();

		System.out.println("==================分割线===================");

		  getData("student","zhangsan", "score","English");

		close();

	}

控制台输出结果：

巴特西

Java API 操作HBase Shell