HBase 中用 put 命令添加数据，但在 HBase 中一次只能为一个表的一行数据的一个列，也就是一个单元格添加一个数据，这点和关系型数据库是不一样的，在关系型数据库中直接是插入整行的数据，所以 HBase 直接用 shell 命令插入数据效率很低，在实际应用中，一般都是利用编程操作 HBase 的。
1. HBase 操作命令
表列表：
命令格式：
list创建表：
命令格式（不指定默认保存的版本数，默认值为 3）：
create '表名','列族1','列族2'命令格式（指定默认保存的版本数）：
create '表名',{NAME=>'列族1',VERSIONS=>保存的版本数}, {NAME=>'列族2',VERSIONS=>保存的版本数}查看表描述：
命令格式：
describe '表名'删除表：
命令格式（先使该表不可用）：
disable '表名'命令格式（删除表）：
drop '表名'添加数据：
命令格式（列族只有单个列名）：
put '表名','行号','列族','列值'命令格式（列族有多个列名）：
put '表名','行号','列族:列名','列值'删除数据：
命令格式（删除某个单元格数据）：
delete '表名','行号','列族'命令格式（删除某行号数据）：
deleteall '表名','行号'修改数据：
命令格式（HBase中实际上是没有修改数据命令的）：
put '表名','行号','列族','新的单元格值'查看数据：
命令格式（查看某个列族的数据）：
get '表名','行号',{COLUMN=>'列族',VERSIONS=>查看的版本数}命令格式（查看某行号数据）：
get '表名','行号'命令格式（查看整个表的数据）：
scan '表名'
2. Java 编程来操作 HBase
操作 HBase 所用的 jar 包，使用 Maven 导入，引入依赖 hbase-it，pom.xml 文件依赖部分如下：
说明：我安装的 HBase 是 1.1.0 版本的，所以这里使用的依赖版本也是 1.1.0，请保持 jar 包版本和 HBase 版本一致。
<dependencies> <dependency> <groupId>org.apache.hbase</groupId> <artifactId>hbase-it</artifactId> <version>1.1.0</version> </dependency> </dependencies>
HBase 的提供的 jar 包只是对 HBase 命令操作的基本封装，为了便于使用，可以在此基础上做进一步的封装来调用。
下面是 HBase 封装后的工具类 HBaseUtil。
package com.weizhiwen.util;import java.io.IOException;import org.apache.hadoop.conf.Configuration;import org.apache.hadoop.hbase.Cell;import org.apache.hadoop.hbase.CellUtil;import org.apache.hadoop.hbase.HBaseConfiguration;import org.apache.hadoop.hbase.HColumnDescriptor;import org.apache.hadoop.hbase.HTableDescriptor;import org.apache.hadoop.hbase.TableName;import org.apache.hadoop.hbase.client.Admin;import org.apache.hadoop.hbase.client.Connection;import org.apache.hadoop.hbase.client.ConnectionFactory;import org.apache.hadoop.hbase.client.Delete;import org.apache.hadoop.hbase.client.Get;import org.apache.hadoop.hbase.client.Put;import org.apache.hadoop.hbase.client.Result;import org.apache.hadoop.hbase.client.Table;public class HBaseUtil { public static Configuration configuration; public static Connection connection; public static Admin admin; /**
* 建表。HBase的表中会有一个系统默认的属性作为主键，
* 主键无需自行创建，默认为put命令操作中表名后第一个数据，
* 因此此处无需创建id列
* @param myTableName 表名
* @param columnFamily 列族数组
* @throws IOException
*/
@SuppressWarnings("all") public static void createTable(String myTableName, String[] columnFamily) throws IOException {
init();
TableName tableName = TableName.valueOf(myTableName); if(admin.tableExists(tableName)) {
System.out.println(myTableName+" is exists");
} else {
HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName); for(String columnName : columnFamily) {
HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(columnName);
hTableDescriptor.addFamily(hColumnDescriptor);
}
admin.createTable(hTableDescriptor);
System.out.println("create "+myTableName+" success");
}
close();
}
/**
* 删除指定表
* @param myTableName 表名
* @throws IOException
*/
public static void deleteTable(String myTableName) throws IOException {
init();
TableName tableName = TableName.valueOf(myTableName); if (admin.tableExists(tableName)) {
admin.disableTable(tableName); // 先使表无效
admin.deleteTable(tableName); // 在删除表
}
close();
}
/**
* 查看已有表
* @throws IOException
*/
public static void listTables() throws IOException {
init();
HTableDescriptor hTableDescriptors[] = admin.listTables(); for(HTableDescriptor hTableDescriptor : hTableDescriptors){
System.out.println(hTableDescriptor.getNameAsString());
}
close();
}
/**
* 向某一行的某一列插入数据
* @param myTableName 表名
* @param rowKey 行键
* @param colFamily 列族名
* @param column 列名（如果列族下没有子列名，此参数可为空）
* @param value 单元格值
* @throws IOException
*/
public static void insertRowData(String tableName, String rowKey, String colFamily, String column, String value) throws IOException {
init();
Table table = connection.getTable(TableName.valueOf(tableName));
Put put = new Put(rowKey.getBytes());
put.addColumn(colFamily.getBytes(), column.getBytes(), value.getBytes());
table.put(put);
table.close();
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();
}
/**
* 根据行键查询数据
* @param tableName 表名
* @param rowKey 行键
* @param colFamily 列族名
* @param col 列名
* @throws IOException
*/
public static void getRowData(String tableName,String rowKey,String colFamily,String col)throws IOException{
init();
Table table = connection.getTable(TableName.valueOf(tableName));
Get get = new Get(rowKey.getBytes());
get.addColumn(colFamily.getBytes(),col.getBytes());
Result result = table.get(get);
showCell(result);
table.close();
close();
}
/**
* 格式化输出
* @param result
*/
public static void showCell(Result result){
Cell[] cells = result.rawCells(); for(Cell cell:cells){
System.out.println("RowName:"+new String(CellUtil.cloneRow(cell))+" ");
System.out.println("Timetamp:"+cell.getTimestamp()+" ");
System.out.println("column Family:"+new String(CellUtil.cloneFamily(cell))+" ");
System.out.println("row Name:"+new String(CellUtil.cloneQualifier(cell))+" ");
System.out.println("value:"+new String(CellUtil.cloneValue(cell))+" ");
}
}
// 建立连接
public static void init() {
configuration = HBaseConfiguration.create();
configuration.set("hbase.rootdir", "hdfs://localhost:9000/hbase"); try {
connection = ConnectionFactory.createConnection(configuration);
admin = connection.getAdmin();
} catch (IOException e) {
e.printStackTrace();
}
}
// 关闭连接
public static void close() { try { if(admin != null) {
admin.close();
} if(connection != null) {
connection.close();
}
} catch (IOException e) {
e.printStackTrace();
}
}
}工具类的测试类 HBaseUtilTest。
package com.weizhiwen.test;import java.io.IOException;import com.weizhiwen.util.HBaseUtil;public class HBaseTest { public static void main(String[] args) throws IOException { // 查看 HBase 数据库中的所有表
HBaseUtil.listTables(); // 删除成绩表（HBase 数据库中已有数据表）
HBaseUtil.deleteTable("chengji"); // 重新创建成绩表
HBaseUtil.createTable("chengji", new String[]{"score"}); // 插入数据
HBaseUtil.insertRowData("chengji", "zhangsan", "score", "English", "98");
HBaseUtil.insertRowData("chengji", "zhangsan", "score", "Math", "94");
HBaseUtil.insertRowData("chengji", "zhangsan", "score", "Computer", "98"); // 查看单行数据
HBaseUtil.getRowData("chengji", "zhangsan", "score", "Math");
}
}上面 HBaseUtil 类的封装也只是基本的封装，还可以根据实际使用 HBase 在来进行自己需要的封装，比如单行多列插入，查询整表等等。
作者：Wizey
链接：https://www.jianshu.com/p/01b7624875e1