大数据hadoop学习【10】 |
您所在的位置:网站首页 › 如何创建一个学生表格 › 大数据hadoop学习【10】 |
大数据hadoop学习【10】-----根据关系型数据库表,分别通过HBase Shell命令和JAVA编程设计并创建适宜的HBase数据表目录
一、Hbase关系数据库表1、学生信息表2、课程信息表3、选课信息表
二、对Hbase关系数据库表进行分析1、规划思路2、规划结果3、结果分析
三、通过Shell命令创建Hbase关系数据表1、终端运行hbase数据库,并进入hbase的shell界面2、创建综合关系表3、添加学生信息4、添加学生选择课程的基本信息5、添加学生所选课程的成绩6、学生选课信息查询7、关系Hbase数据库,结束该实验
四、通过JAVA编程,实现学生选课信息表的创建及相关操作1、创建对Hbase数据库的实现功能类和菜单类2、编写创建学生信息表的方法3、编写添加学生选课信息的方法4、编写浏览学生选课信息表的方法5、编写修改学生选课信息的方法6、编写删除学生选课信息的方法7、菜单函数
每一种数据库的学习,都要学会怎么样对关系数据库表进行联系创建,当然,Hbase数据库也一样。但是Hbase数据库也有不同的地方,那就是HBase数据库是建立在列的基础上建立的关系,其他关系型数据库基本都是建立在行上面建立的关系,这就是不同的地方,加入给大家几张有关系的表,让我们建立起他们的联系,这时候就需要我们对表进行规划了,然后创建出他们的关系,本次博客,林君学长主要带大家了解如何通过Hbase Shell命令,进行关系数据库表的创建
操作系统:ubuntuKylin-16.04hadoop版本:hadoop-2.7.7hbase版本:hbase-1.4.13
一、Hbase关系数据库表
题目:根据以下关系型数据库表,使用HBase Shell设计并创建适宜的HBase数据表 1、学生信息表 学号(S_No)姓名(S_Name)性别(S_Sex)年龄(S_Age)2015001ZhangSanmale232015002Maryfemale222015003LiSimale24 2、课程信息表 课程号(C_No)课程名(C_Name)学分(C_Credit)123001Math2.0123002Computer Science5.0123003English3.0 3、选课信息表 学号(SC_Sno)课程号(SC_Cno)成绩(SC_Score)201500112300186201500112300369201500212300277201500212300399201500312300198201500312300295 二、对Hbase关系数据库表进行分析对于上面的学生信息以及学生选课信息,关系数据库表已经给大家给出,那么我们如何进行关系模拟来将学生和课程产生关系,使得我们在查询学生的时候,能够自动的也他选择的课程也一并显示出现,这就需要我们构建!在很多时候,不是一看到表就直接进行创建,然后进行联系,Hbase关系型数据库和其他数据库不一样,所以需要大家进行关系表的规划,自由明白他们之间的关系,我们才能创建出合适这个关系的表格! 1、规划思路1)、上面我们可以看出,学生的选课直接和学生信息和课程信息有关,而直接相关的就是学生学号和课程号,第三章选课表也就是根据学生信息和课程信息的综合而来,学号和课程号是直接的关系纽带! 2、规划结果1)、通过以上关系,那么我们可以进行综合,直接将学生信息和他选择的课程信息进行综合,进而联系在一起,形成下面的综合关系表;将学生信息表、课程信息表、选课信息表综合在一起,然后进行建表的规划: 1)、通过上面的表格规划,那么我们就可以来进行建表,建表的思路就和上面的表格思路一样,我们需要建立的表格就是学生选课信息表,从中不仅可以查询学生信息,更可以查询课程信息,以及每个学生选课的成绩! 2)、所有的关系整个为一个学生信息资源表,studentInformation,该表中包含三个列族名:学习信息、数学选课信息、计算机选课信息、英选课信息,而每个列族名下面包括几个子列名,例如: 学生信息的子列是:学生学号、学生姓名、性别、年龄 选课信息的子列是:课程号、课程名、学分、成绩 由此,我们便可以通过以上关系进行建表了! 三、通过Shell命令创建Hbase关系数据表 1、终端运行hbase数据库,并进入hbase的shell界面1)、运行SSH ssh localhost
1)、创建综合关系表 create 'studentInformation','Student','Math','ComputerScience','English'
1)、添加学号为2015001的学生信息,学号作为行键 put 'studentInformation','2015001','Student:S_No','2015001' put 'studentInformation','2015001','Student:S_Name','ZhangSan' put 'studentInformation','2015001','Student:S_Sex','male' put 'studentInformation','2015001','Student:S_Age','23'
1)、添加学号为:2015001学生的选课信息 由上面总结的综合关系表可以看出,学号为2015001的同学选择了数学和英语课程,因此,我们需要添加的也就是这两门课程的信息 ①.添加该同学选择的数学课程的基本信息 put 'studentInformation','2015001','Math:C_No','123001' put 'studentInformation','2015001','Math:C_Name','Math' put 'studentInformation','2015001','Math:C_Credit','2.0'
由上面总结的综合关系表可以看出,学号为2015002的同学选择了英语和计算机科学课程,因此,我们需要添加的也就是这两门课程的信息 ①.添加该同学选择的英语课程的基本信息 put 'studentInformation','2015002','English:C_No','123002' put 'studentInformation','2015002','English:C_Name','English' put 'studentInformation','2015002','English:C_Credit','3.0'
由上面总结的综合关系表可以看出,学号为2015003的同学选择了数学和计算机科学课程,因此,我们需要添加的也就是这两门课程的信息 ①.添加该同学选择的数学课程的基本信息 put 'studentInformation','2015003','Math:C_No','123001' put 'studentInformation','2015003','Math:C_Name','Math' put 'studentInformation','2015003','Math:C_Credit','2.0'
1)、添加学号为:2015001学生所选课的成绩 学号为2015001的同学选择了数学和英语课程,所以他只有这两门课程会有成绩 put 'studentInformation','2015001','Math:SC_Score','86' put 'studentInformation','2015001','English:SC_Score','69'
学号为2015002的同学选择了英语和计算机科学课程,所以他只有这两门课程会有成绩 put 'studentInformation','2015002','English:SC_Score','77' put 'studentInformation','2015002','ComputerScience:SC_Score','99'
学号为2015003的同学选择了数学和计算机科学课程,所以他只有这两门课程会有成绩 put 'studentInformation','2015003','Math:SC_Score','98' put 'studentInformation','2015003','ComputerScience:SC_Score','95'1)、查询学号为:2015001同学的学生信息及选课信息和所得的成绩 get 'studentInformation','2015001'从查询的结果可以看出该同学的基本信息,和选择了两门课程:英语、数学;分别的成绩为:69、86 2)、查询学号为:2015002同学的学生信息及选课信息和所得的成绩 get 'studentInformation','2015002'从查询的结果可以看出该同学的基本信息,和选择了两门课程:英语、计算机科学;分别的成绩为:77、99 3)、查询学号为:2015003同学的学生信息及选课信息和所得的成绩 get 'studentInformation','2015003'从查询的结果可以看出该同学的基本信息,和选择了两门课程:数学、计算机科学;分别的成绩为:98、95! 7、关系Hbase数据库,结束该实验 exit stop-hbase.sh stop-dfs.sh exit
上面我们也可以知道,通过HBase shell命令进行数据的数据不仅麻烦、而且费时,因此,在现实生活中一般是通过JAVA编程语言来实现对表的创建以及表中数据的操作,接下来,林君学长就带大家了解如何通过java语言实现对刚刚创建的表中数据的操作吧! 1、创建对Hbase数据库的实现功能类和菜单类1)、这里就不给大家介绍怎么创建了,直接看林君学长的截图吧! JAVA程序命令就是通过以上建立连接和关闭连接来进行访问的哦,这是开启JAVA访问的第一步,也是必须的一步,每一步操作命令都必须先与Hbase数据库建立连接,然后再关闭连接 2、编写创建学生信息表的方法1)、要求:createTable(String tableName, String[] fields) 创建表,参数tableName为表的名称,字符串数组fields为存储记录各个域名称的数组。要求当HBase已经存在名为tableName的表的时候,先删除原有的表,然后再创建新的表。 2)、java程序代码: public void createTable(String myTableName,String[] colFamily) throws IOException { @SuppressWarnings("resource") Scanner in = new Scanner(System.in); init(); TableName tableName = TableName.valueOf(myTableName); if(admin.tableExists(tableName)){ System.out.println("该表已经存在!"); System.out.println("是否删除该表重新创建?"); System.out.println("1、是"); System.out.println("2、否"); System.out.print("请输入你的选择:"); int a=in.nextInt(); switch(a){ case 1:if (admin.tableExists(tableName)) { admin.disableTable(tableName); admin.deleteTable(tableName); System.out.println("表:"+tableName+"已成功删除"); } HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName); for(String str:colFamily){ HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(str); hTableDescriptor.addFamily(hColumnDescriptor); } admin.createTable(hTableDescriptor); System.out.println("表创建成功!");break; case 2:break; } }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(); }3)、运行截图: 在菜单函数中调用功能类中的上面的这个方法,进行学生Zhangsan选课信息表的创建: createTable("StudentScore",new String[]{"student","Math","ComputerScience","English"})
1)、要求:addRecord(String tableName, String row, String[] fields, String[] values) 向表tableName、行row(用S_Name表示)和字符串数组files指定的单元格中添加对应的数据values。其中fields中每个元素如果对应的列族下还有相应的列限定符的话,用“columnFamily:column”表示。例如,同时向“Math”、“ComputerScience”、“English”三列添加成绩时,字符串数组fields为{“Score:Math”,”Score:ComputerScience”,”Score:English”},数组values存储这三门课的成绩 2)、java程序代码: public void addRecord(String tableName,String rowKey,String []fields,String [] values) throws IOException { init(); Table table = connection.getTable(TableName.valueOf(tableName)); for (int i = 0; i |
今日新闻 |
推荐新闻 |
CopyRight 2018-2019 办公设备维修网 版权所有 豫ICP备15022753号-3 |