HBase Java API编程实例
本节通过一个具体的编程实例来学习如何使用 HBase Java API 解决实际问题。在本实例中,首先创建一个学生成绩表 scores,用来存储学生各门课程的考试成绩,然后向 scores 添加数据。
表 scores 的概念视图如图 1 所示,用学生的名字 name 作为行键,年级 grade 是一个只有一个列的列族,score 是一个列族,每一门课程都是 score 的一个列,如 english、math、Chinese 等。score 的列可以随时添加。
例如,后续学生又参加了其他课程的考试,如 computing、physics 等,那么就可以添加到 score 列族。因为每个学生参加考试的课程也会不同,所以,并不一定表中的每一个单元都会有值。在该实例中,要向学生成绩表 scores 中添加的数据如图 2 所示。
图 1 学生成缋表 scores 的概念视图
图 2 学生成绩表 scores 的数据
本节首先对学生成绩表实例的代码框架进行描述,然后详细介绍每一个功能模块的代码细节。
import ;
import ;
import .*;
import .*;
import ;
public class StudentScores {
public static Configuration configuration; //HBase 配置信息
public static Connection connection; //HBase 连接
public static void main (String [] agrs) thorws IOException{
init();//建立连接
createTable();//建表
insertData();//添加课程成绩
insertData();//添加课程成绩
insertData();//添加课程成绩
getData();//浏览课程成绩
close();//关闭连接
}
public static void init () {......} //建立连接
public static void close () {......} //关闭连接
public static void createTable (){......} //创建表
public static void insertData () {......} //添加课程成绩
public static getData() {……} //浏览操程成绩
}
下面分别对每一个功能模块的代码进行介绍。
1. 建立连接和关闭连接
在使用 HBase 数据库前,必须首
HBase Java API编程实例 来自淘豆网m.daumloan.com转载请标明出处.