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 版本一致。
代码语言：javascript复制<dependencies>
<dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase-it</artifactId>
<version>1.1.0</version>
</dependency>
</dependencies>HBase 的提供的 jar 包只是对 HBase 命令操作的基本封装，为了便于使用，可以在此基础上做进一步的封装来调用。
下面是 HBase 封装后的工具类 HBaseUtil。
代码语言：javascript复制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。
代码语言：javascript复制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 在来进行自己需要的封装，比如单行多列插入，查询整表等等。
个人 GitHub 地址：https://github.com/weizhiwen，欢迎来访。
