【hdfs】【hbase】【大数据技术底子】实践二 HBase Java API编程
实践二 HBase Java API编程为什么可以写命令还要编写程序？自动化批量处理？
只管我们可以通过HBase的shell命令行工具进行数据操纵，但在现实的生产环境中，为了提高效率和实现自动化处理，我们通常需要编写程序来与HBase进行交互。
本实例利用Eclipse编写java程序，来对HBase数据库进行增删改查等操纵，Eclipse可以在Ubuntu软件中心搜索下载并安装。
第一步：启动hadoop，启动hbase
在开始之前，确保你已经安装了Hadoop和HBase，而且它们正在运行。你可以通过以下命令启动它们：
[*]cd /usr/local/hadoop
[*]./sbin/start-dfs.sh
[*]cd /usr/local/hbase
[*]./bin/start-hbase.sh
https://i-blog.csdnimg.cn/direct/5181d10d184b4534a5f04c5d062bdd00.png
HBase 命令要在HBase shell中利用：
启动 HBase shell： 在命令行中输入以下命令来启动 HBase shell：
hbase shell 假如 HBase 服务启动成功，你将看到 HBase shell 的提示符，通常是一个光标背面跟着 hbase>。
https://i-blog.csdnimg.cn/direct/f93a98ba1a884466b7e8f2c8ba799b23.png
HBase命令利用：利用scan ‘Score’，示例：
https://i-blog.csdnimg.cn/direct/69fd9bd524eb4995a7e441e1931654e0.png
：因为我们表还没被创建，报错Unknown table Score是正常的。
报错了大概因为少了：ssh localhost
这个命令可不能少！利用SSH登录当地主机，确保HBase Shell可以正常访问。
https://i-blog.csdnimg.cn/direct/a35cc2fd706c42ffbb4843e8202bc6e2.png
第二步，新建Java Project——>新建Class
https://i-blog.csdnimg.cn/direct/46aac76c6f5c47c3b3e057d10a69ae66.png
第三步：在工程中导入外部jar包：
起首导入前面的HDFS API相应类包(实践一中导入的)。
然后导入hbase安装目次中的lib文件中的所有jar包。
https://i-blog.csdnimg.cn/direct/870bd5312e4947198eda4b30c872e5de.png
下列代码包含了数据库创建、增删改查等一系列操纵，需要大家根据需要逐步开放注释，进行分阶段运行。
这里给出一个编程实例,，以下是源代码：
[*]import org.apache.hadoop.conf.Configuration;
[*]import org.apache.hadoop.hbase.*;
[*]import org.apache.hadoop.hbase.client.*;
[*]import java.io.IOException;
[*]
[*]public class ExampleForHbase{
[*] public static Configuration configuration;
[*] public static Connection connection;
[*] public static Admin admin;
[*]
[*] //主函数中的语句请逐句执行，只需删除其前的//即可，如：执行insertRow时请将其他语句注释
[*] public static void main(String[] args)throws IOException{
[*] //创建一个表，表名为Score，列族为sname,course
[*] createTable("Score",new String[]{"sname","course"});
[*]
[*] //在Score表中插入一条数据，其行键为95001,sname为Mary（因为sname列族下没有子列所以第四个参数为空）
[*] //等价命令：put 'Score','95001','sname','Mary'
[*] //insertRow("Score", "95001", "sname", "", "Mary");
[*] //在Score表中插入一条数据，其行键为95001,course:Math为88（course为列族，Math为course下的子列）
[*] //等价命令：put 'Score','95001','score:Math','88'
[*] //insertRow("Score", "95001", "course", "Math", "88");
[*] //在Score表中插入一条数据，其行键为95001,course:English为85（course为列族，English为course下的子列）
[*] //等价命令：put 'Score','95001','score:English','85'
[*] //insertRow("Score", "95001", "course", "English", "85");
[*]
[*] //1、删除Score表中指定列数据，其行键为95001,列族为course，列为Math
[*] //执行这句代码前请deleteRow方法的界说中，将删除指定列数据的代码取消注释注释，将删除制定列族的代码注释
[*] //等价命令：delete 'Score','95001','score:Math'
[*] //deleteRow("Score", "95001", "course", "Math");
[*]
[*] //2、删除Score表中指定列族数据，其行键为95001,列族为course（95001的Math和English的值都会被删除）
[*] //执行这句代码前请deleteRow方法的界说中，将删除指定列数据的代码注释，将删除制定列族的代码取消注释
[*] //等价命令：delete 'Score','95001','score'
[*] //deleteRow("Score", "95001", "course", "");
[*]
[*] //3、删除Score表中指定行数据，其行键为95001
[*] //执行这句代码前请deleteRow方法的界说中，将删除指定列数据的代码注释，以及将删除制定列族的代码注释
[*] //等价命令：deleteall 'Score','95001'
[*] //deleteRow("Score", "95001", "", "");
[*]
[*] //查询Score表中，行键为95001，列族为course，列为Math的值
[*] //getData("Score", "95001", "course", "Math");
[*] //查询Score表中，行键为95001，列族为sname的值（因为sname列族下没有子列所以第四个参数为空）
[*] //getData("Score", "95001", "sname", "");
[*]
[*] //删除Score表
[*] //deleteTable("Score");
[*] }
[*]
[*] //创建连接
[*] 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(null != connection){
[*] connection.close();
[*] }
[*] }catch (IOException e){
[*] e.printStackTrace();
[*] }
[*] }
[*]
[*] /**
[*] * 建表。HBase的表中会有一个体系默认的属性作为主键，主键无需自行创建，默以为put命令操纵中表名后第一个数据，因此此处无需创建id列
[*] * @param myTableName 表名
[*] * @param colFamily 列族名
[*] * @throws IOException
[*] */
[*] 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 {
[*] HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName);
[*] for(String str:colFamily){
[*] HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(str);
[*] hTableDescriptor.addFamily(hColumnDescriptor);
[*] }
[*] admin.createTable(hTableDescriptor);
[*] System.out.println("create table success");
[*] }
[*] 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();
[*] }
[*]
[*] /**
[*] * 查看已有表
[*] * @throws IOException
[*] */
[*] public static void listTables() throws IOException {
[*] init();
[*] HTableDescriptor hTableDescriptors[] = admin.listTables();
[*] for(HTableDescriptor hTableDescriptor :hTableDescriptors){
[*] System.out.println(hTableDescriptor.getNameAsString());
[*] }
[*] close();
[*] }
[*] /**
[*] * 向某一行的某一列插入数据
[*] * @param tableName 表名
[*] * @param rowKey 行键
[*] * @param colFamily 列族名
[*] * @param col 列名（假如其列族下没有子列，此参数可为空）
[*] * @param val 值
[*] * @throws IOException
[*] */
[*] public static void insertRow(String tableName,String rowKey,String colFamily,String col,String val) throws IOException {
[*] init();
[*] 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();
[*] 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());
这里应该是：
if (col != null && !col.isEmpty()) {
// 假如有 col 参数传入，则删除指定列
delete.addColumn(colFamily.getBytes(), col.getBytes());
} else if(colFamily != null && !colFamily.isEmpty()) {
// 否则，删除指定列族的所有数据
delete.addFamily(colFamily.getBytes());
}
[*]
[*] table.delete(delete);
[*] table.close();
[*] close();
[*] }
[*] /**
[*] * 根据行键rowkey查找数据
[*] * @param tableName 表名
[*] * @param rowKey 行键
[*] * @param colFamily 列族名
[*] * @param col 列名
[*] * @throws IOException
[*] */
[*] public static void getData(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))+" ");
[*] }
[*] }
[*]}
第四步：执行与验证
每次执行完，都可以回到shell界面查看是否执行成功，如：执行完插入数据后，在shell界面中执行scan 'Score'。截图如下:
建表：
建表成功~
https://i-blog.csdnimg.cn/direct/33ac1ad2298344b0865ac846c96df9b8.png
https://i-blog.csdnimg.cn/direct/d70fa404f7244d40ac76f6f4dce7d64f.png
添加数据：
https://i-blog.csdnimg.cn/direct/4cc7dbc568f34afea71a00aac1cba91c.png
删除指定列：
https://i-blog.csdnimg.cn/direct/9b51d81d4a7a4d3f80e932a6b1e4021f.png
https://i-blog.csdnimg.cn/direct/2e2507e232904ad3910e3ee1fa17bceb.png
删除指定列族：
https://i-blog.csdnimg.cn/direct/e0622c73e3054e30b3446bbc5b7be667.png
删除整行数据：
https://i-blog.csdnimg.cn/direct/86fd6da3869647328a36a455719e95d8.png
查询Score表中，行键为95001，列族为course，列为Math的值：
https://i-blog.csdnimg.cn/direct/a40d5954710c466b938c1ec367ea8649.png
查询Score表中，行键为95001，列族为sname的值（因为sname列族下没有子列所以第四个参数为空）：
https://i-blog.csdnimg.cn/direct/8de6b7c154ca4710abc3706538c1bb90.png
【遇到的问题】：为什么打印了内存地址而不是值？
【解决方法】：把+" "删除就好了？
https://i-blog.csdnimg.cn/direct/0187a7fcd0d74e2d99f017a3b5b3c986.png
免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。
页:
[1]