上次的hadoop学习，我们了解了如何通过Hbase的shell界面相关shell命令，对数据库中表及表中数据进行操作！
但其实在很多时候，我们需要的是通过程序编程，完成与用户的界面交互功能，肯定不能让用户来进行shell命令进行相关数据的操作吧，这时候，我们需要通过Java语言来进行对Hbase的数据库的访问操作，本次博客，林君学长主要带大家了解，如何通过JAVA编程，来对HBase数据库进行访问并且操作

• 操作系统：ubuntuKylin-16.04
• hadoop版本：hadoop-2.7.7
• hbase版本：hbase-1.4.13
• java版本：jdk-1.7

一、Hbase数据库的运行

1、运行SSH

1）、新建终端，输入以下命令切换hadoop账户，然后运行ssh

su - hadoop
ssh localhost

2、运行hadoop

1）、终端输入以下命令，运行hadoop

start-dfs.sh
jps

3、运行Hbase

1）、当前终端输入如下命令，运行Hbase

start-hbase.sh
jps

上面三步执行之后，便可以隐藏终端，不要关闭哦！

二、eclipse整体Java项目介绍

1、创建属于hbase的Java Project

记住上面的JSE的选择，一定要选择1.5版本，因为后面的代码需要这个版本的，高于版本的不支持有些代码，需要自己重新编写！

2、导入Hbase所需要的基本库

1）、找到安装hbase路径的地方，然后导入路径 /usr/local/hbase/lib文件中的所有的库:

3、创建相关的包、类

三、通过JAVA编程，实现对Hbase数据库的连接与关闭 ，已经菜单函数的编写

1、通过Java编程实现对Hbase数据库的连接

1）、java代码如下所示：

//建立连接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();}}

2、通过Java编程实现对Hbase数据库的关闭

1）、java代码如下所示：

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

3、菜单交互界面主函数

1）、java代码如下所示：

public static void main(String[] args) throws IOException{HDataBase h1=new HDataBase();@SuppressWarnings("resource")Scanner in = new Scanner(System.in);while(true){System.out.println("**********************基于JAVA的Hbase数据库表及表的基本操作**********************");System.out.println("1、向Hbase数据库创建一张表");System.out.println("2、查看数据库中已存在的表");System.out.println("3、为创建的表的某一行的某一列插入数据");System.out.println("4、根据行键rowkey查找数据");System.out.println("5、删除表中的数据");System.out.println("6、删除指定表");System.out.println("0、退出！");System.out.print("请输入你的选择:");int a=in.nextInt();switch(a){case 1: h1.createTable("Score",new String[]{"sname","course"});break;case 2: h1.listTables();break;case 3: h1.insertRow("Score", "10001", "sname"," ","chenYiYue");break;case 4: h1.getData("Score", "10001", "sname", " ");break;case 5: h1.deleteRow("Score", "10001", "sname", "chenYiYue");break;case 6: h1.deleteTable("Score");break;case 0:break;}}}

2）、运行结果如下：

四、Java编程实现对Hbase数据库表操作

1、通过JAVA编程，实现对Hbase数据库表的创建

1）、java程序如下所示：

public void createTable(String myTableName,String[] colFamily) throws IOException {init();TableName tableName = TableName.valueOf(myTableName);if(admin.tableExists(tableName)){System.out.println("该表已经存在!");}else {HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName);for(String str:colFamily){HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(str);hTableDescriptor.addFamily(hColumnDescriptor);}admin.createTable(hTableDescriptor);System.out.println("表创建成功！");}close();}

通过输入需要穿件的表名，以及包括的列名组，来进行hbase表的创建
如：createTable(“Score”,new String[]{“sname”,“course”})
2）、运行结果如下所示：

3）、在终端进入hbase的shell界面，通过shell命令查询该表是否完成创建

hbase shell
list

可以看出，上表Score已经完成创建！

2、通过JAVA编程，实现对Hbase数据库表的查询

1）、java代码如下所示：

public void listTables() throws IOException {init();HTableDescriptor hTableDescriptors[] = admin.listTables();for(HTableDescriptor hTableDescriptor :hTableDescriptors){System.out.println(hTableDescriptor.getNameAsString());}close();}

上面函数的主要功能就是查询出Hbase数据库中的所有表，并在终端显示出来
2）、运行结果如下所示：

3）、终端查询是否一致

上图可以看出，完全一致！

3、通过JAVA编程，实现对Hbase数据库表的删除

1）、java代码如下所示：

public void deleteTable(String tableName) throws IOException {init();TableName tn = TableName.valueOf(tableName);if (admin.tableExists(tn)) {admin.disableTable(tn);admin.deleteTable(tn);System.out.println("表:"+tableName+"已成功删除");}close();}

通过输入Hbase的表名，完成对数据库表的删除，如：deleteTable(“Score”)
2）、运行结果如下所示：

3）、在shell界面查询是否删除成功

终端已经没有该表了！以上步骤建议在完成以下数据操作步骤后执行！

五、Java实现对数据库表中数据的操作

1、通过JAVA编程，实现对Hbase数据库表中数据的插入

1）、java代码如下所示：

public 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());System.out.println("数据插入成功");table.put(put);table.close();close();}

通过输入表名、行键（可以理解为主键，主键唯一）、列族名、列族名下的列名、已经插入的数据进行表中数据的插入，如：insertRow(“Score”, “10001”, “sname”," ",“chenYiYue”)，由于sname下面没有其他的列名，所以我们输入空就行
2）、运行结果如下所示：

3）、shell界面查询是否成功插入数据

get 'Score','10001'

数据已成功插入！

2、通过JAVA编程，实现对Hbase数据库表中数据的查询

1）、java代码如下所示：

public 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();}
public 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))+" ");}}

通过输入表名、行键（主键）、以及列族名，和列族名下的列名，如：
getData(“Score”, “10001”, “sname”," ")，由于该sname列名下没有列名，所以我们输入空
2）、查询的结果如下所示：

3）、在shell界面查看查询的内容是否一致

get 'Score','10001','sname'

可以看出，完全一致！

3、通过JAVA编程，实现对Hbase数据库表中数据的删除

1）、java代码如下所示：

public 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);System.out.println("信息已经删除");table.close();close();}

通过指定表名、行键（主键唯一）、列族名、和列族名下的数据进行数据的删除，如：deleteRow(“Score”, “10001”, “sname”, “chenYiYue”)
2）、运行结果如下所示：

3）、在shell界面查询该条数据是否删除成功：

get 'Score','10001','sname'

可以看出，sname下的数据chenyiyue已经被成功删除，该列下已经没有数据了！

六、项目整体代码

1、菜单类

package view;import hbaseFile.HDataBase;
import java.io.IOException;
import java.util.Scanner;
public class Menu {public static void main(String[] args) throws IOException{HDataBase h1=new HDataBase();@SuppressWarnings("resource")Scanner in = new Scanner(System.in);while(true){System.out.println("**********************基于JAVA的Hbase数据库表及表的基本操作**********************");System.out.println("1、向Hbase数据库创建一张表");System.out.println("2、查看数据库中已存在的表");System.out.println("3、为创建的表的某一行的某一列插入数据");System.out.println("4、根据行键rowkey查找数据");System.out.println("5、删除表中的数据");System.out.println("6、删除指定表");System.out.println("0、退出！");System.out.print("请输入你的选择:");int a=in.nextInt();switch(a){case 1: h1.createTable("Score",new String[]{"sname","course"});break;case 2: h1.listTables();break;case 3: h1.insertRow("Score", "10001", "sname"," ","chenYiYue");break;case 4: h1.getData("Score", "10001", "sname", "chenYiYue");break;case 5: h1.deleteRow("Score", "10001", "sname", "chenYiYue");break;case 6: h1.deleteTable("Score");break;case 0:break;}}}
}

2、Hbase数据库操作类

package hbaseFile;import org.apache.hadoop.conf.Configuration;
import org.apache.hadoop.hbase.*;
import org.apache.hadoop.hbase.client.*;
import java.io.IOException;public class HDataBase{public static Configuration configuration;public static Connection connection;public static Admin admin;//建立连接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 void createTable(String myTableName,String[] colFamily) throws IOException {init();TableName tableName = TableName.valueOf(myTableName);if(admin.tableExists(tableName)){System.out.println("该表已经存在!");}else {HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName);for(String str:colFamily){HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(str);hTableDescriptor.addFamily(hColumnDescriptor);}admin.createTable(hTableDescriptor);System.out.println("表创建成功!");}close();}/*** 删除指定表* @param tableName 表名* @throws IOException*/public void deleteTable(String tableName) throws IOException {init();TableName tn = TableName.valueOf(tableName);if (admin.tableExists(tn)) {admin.disableTable(tn);admin.deleteTable(tn);System.out.println("表:"+tableName+"已成功删除");}close();}/*** 查看已有表* @throws IOException*/public 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 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());System.out.println("数据插入成功");table.put(put);table.close();close();}/*** 删除数据* @param tableName 表名* @param rowKey 行键* @param colFamily 列族名* @param col 列名* @throws IOException*/public 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);System.out.println("信息已经删除");table.close();close();}/*** 根据行键rowkey查找数据* @param tableName 表名* @param rowKey 行键* @param colFamily 列族名* @param col 列名* @throws IOException*/public 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 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))+" ");}}
}

3、程序关闭

每次操作之后，记得关闭自己的hadoop已经hbase,养成良好的操作习惯！

stop-hbase.sh
stop-dfs.sh
exit

以上就是本次博客的全部内容啦，希望阅读的小伙伴可以懂得如何通过java代码实现对Hbase数据库的操作，代码不要照搬，理解代码才是硬道理，一定要熟悉后理解哦！
遇到问题的小伙伴记得评论区留言，林君学长看到会为大家解答的，这个学长不太冷！
陈一月的又一天编程岁月^ _ ^

大数据hadoop学习【9】-----通过JAVA语言编程，实现对Hbase数据库表及数据的相关操作相关推荐

1. 【偏门技巧】C语言编程实现对IPV4地址的合法性判断（使用正则表达式）

   C语言编程实现对IPV4地址的合法性判断(使用正则表达式) 有了解过我的朋友,可能有点印象,我在N年前的博客中,就写了这个主题,当时确实是工作中遇到了这个问题.本想着等工作搞完之后,就把这个问题的解决 ...

2. Java快速入门学习笔记9 | Java语言中的方法

   有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...

3. Java快速入门学习笔记7 | Java语言中的类与对象

   有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...

4. java语言就业方向_四大就业方向彻底解决你学习Java语言编程的后顾之忧-生活感悟与随笔 -亦是美网络...

   前面的文章中已经给大家介绍了关于Java编程语言的优势.特点以及就业前景等内容,大家之所以这么热衷于Java编程学习,不仅是因为Java是编程市场上最为广泛流行的语言,大家更关心的是学习了Java编程 ...

5. Java快速入门学习笔记8 | Java语言中的数组

   有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...

6. Java快速入门学习笔记3 | Java语言中的表达式与操作符

   有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...

7. Java快速入门学习笔记2 | Java语言中的基本类型

   有人相爱,有人夜里开车看海,有人却连LeetCode第一题都解不出来!虽然之前系统地学习过java课程,但是到现在一年多没有碰过Java的代码,遇到LeetCode不知是喜是悲,思来想去,然后清空自己 ...

8. Java编程语言学习：Java语言编程的基础知识之Java的变量与数据类型、符号、运算符、数组Array总结之详细攻略

   Java编程语言学习:Java语言编程的基础知识之Java的变量与数据类型.符号.运算符.数组Array总结之详细攻略 目录 Java语言编程的基础知识之Java的变量与数据类型.符号.运算符.数组总 ...

9. JAVA学习脚印3: java语言控制流程

   JAVA学习脚印3: java语言控制流程 本节首先介绍,java语言中的字符串处理以及输入输出控制,最后介绍控制流程. 在讲述控制流程之前,先介绍以下java中字符串和输入输出的内容,以便后续练习编 ...

10. java 网络流量统计_IP数据包的流量统计(JAVA语言)

    如果不显示图片,或者出现排版错误,抽风,崩坏,节操丢失等一系列不正常情况,请点击下面链接观看,点我 IP数据包的流量统计(JAVA语言) 要求:编制程序,监控网络,捕获一段时间内网络上的IP数据包,按 ...

最新文章

1. 自动调度GPU的卷积层
2. AjaxControltoolkit(工具包)安装步骤说明
3. 一篇网站架构的文章：一步步构建大型网站架构
4. Java修炼之路——基础篇——Java关键字
5. bootstracp实现树形列表_Java实现一致性哈希算法，并搭建环境测试其负载均衡特性...
6. 支付宝开放新玩法：搜商家可领消费券
7. 关于Java 8 forEach
8. 整理LVS架构压力测试工作
9. Windows编程 第七回 绘图课（上）
10. matlab 和 ampl 结合,AMPL和MATLAB结合使用示例
11. LINUX无法定位软件包
12. c语言整型常量后加l或u,《软考程序员》整型常量
13. 象棋（ Xiangqi, ACM/ICPC Fuzhou 2011, UVa1589）
14. 牛客刷题——part2
15. 限制Editext输入字节长度
16. jAVA EE NZ2001 java EE学习总结 第七周（包含思维导图） 主要内容I/O框架、网络编程、反射
17. Java中 VO、PO、DO、DTO、BO、QO、DAO、POJO的概念
18. W801单片机学习笔记——调试器的配置与使用（适用于W801和W806)
19. 大数据分析python r matlab_大数据分析之如何让 Python, R, Matlab 与 Tableau 红尘作伴，玩的潇潇洒洒...
20. python返回索引值_python 返回列表中某个值的索引方法

热门文章

1. 计算机管理如何格式化u盘,优盘格式化,教您如何格式化u盘
2. 全面剖析雅虎助手以及网络实名的流氓行径(5)
3. C++模板函数 学习记录
4. airtest基本介绍
5. 北通G3游戏手柄开箱体验，原来手游高手都是这么成就的
6. Ubuntu系统镜像下载网站
7. fedora linux五笔输入法,ArchLinux 安装五笔输入法
8. 市面常见存储卡的读写速度对比测试
9. h3c交换机-初级命令
10. 基于MATLAB的车牌识别实现