jfinal+hbase+eclipse開發web專案詳細步驟04---在web頁面實現對hbase資料庫資料的增刪查改功能
阿新 • • 發佈：2018-12-06
首先提醒大家，本節是在步驟01、步驟02、步驟03都成功的基礎上做進一步開發。如果在之前的任何一個步驟出現問題，那麼希望你先解決好問題之後，再做本次的開發。
步驟1：建表。
1、開啟我們虛擬機器，並且啟動hadoop、hbase
start-all.sh
start-hbase.sh
2、進入hbase shell 介面
輸入：hbase shell
3、建立表並新增資料
輸入： create 'student','base_info'
再輸入：put 'student',1,'base_info:no','20181011'
再輸入：put 'student',1,'base_info:cls','16'
再輸入：put 'student',1,'base_info:name','xiaoming'
步驟2：修改HelloContorller類，Hbase類
全部複製之前的程式碼，程式碼如下：
HelloContorller.java
package com.demo; import java.io.IOException; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.util.Bytes; import com.jfinal.core.Controller; import com.plugin.Hbase; public class HelloController extends Controller { /** * 進入主頁面 */ public void index() { render("index.html"); } /** * 進入新增頁面 */ public void add() { render("add.html"); } /** * 進入新增頁面 */ public void openupdate() { //獲取頁面資料 String rowname=getPara("rowname"); Map<String, Object> resMap = new HashMap<String, Object>(); //獲取資料庫的資料 try { resMap=Hbase.get("student", rowname); } catch (Exception e) { e.printStackTrace(); } setAttr("info", resMap); renderJsp("update.jsp"); } public void indexData() { ArrayList<Student> studnets = new ArrayList<>(); Student s1 = new Student(); s1.setNo("01"); s1.setCls("16計本1班"); s1.setName("小米"); Student s2 = new Student(); s2.setNo("02"); s2.setCls("16計本1班"); s2.setName("小花"); Student s3 = new Student(); s3.setNo("01"); s3.setCls("16計本2班"); s3.setName("旺旺"); studnets.add(s1); studnets.add(s2); studnets.add(s3); setAttr("infos", studnets); renderJson(); } public void hbase() { Map<String, Object> resMap = new HashMap<String, Object>(); try { resMap = Hbase.get("stu", "2"); } catch (Exception e) { e.printStackTrace(); } renderText(resMap.toString()); } // 查詢student表資訊 public void scanStudent() { List<Map<String, Object>> studnets = new ArrayList<Map<String, Object>>(); try { studnets = Hbase.scan("student"); } catch (Exception e) { // TODO Auto-generated catch block e.printStackTrace(); } setAttr("infos", studnets); renderJson(); } // 儲存資料 public void save() { // 獲取頁面資料 String rowname = getPara("rowname"); String no = getPara("no"); String name = getPara("name"); String cls = getPara("cls"); List<Put> puts = new ArrayList<Put>(); Put put1 = new Put(Bytes.toBytes(rowname)); put1.addColumn(Bytes.toBytes("base_info"), Bytes.toBytes("no"), Bytes.toBytes(no)); Put put2 = new Put(Bytes.toBytes(rowname)); put2.addColumn(Bytes.toBytes("base_info"), Bytes.toBytes("name"), Bytes.toBytes(name)); Put put3 = new Put(Bytes.toBytes(rowname)); put3.addColumn(Bytes.toBytes("base_info"), Bytes.toBytes("cls"), Bytes.toBytes(cls)); puts.add(put1); puts.add(put2); puts.add(put3); // 儲存資料 try { Hbase.puts(puts, "student"); } catch (Exception e) { e.printStackTrace(); } render("index.html"); } /** * 刪除資料 */ public void delete() { // 獲取頁面資料 String rowname = getPara("rowname"); try { Hbase.deleteRow("student", rowname); } catch (IOException e) { e.printStackTrace(); } render("index.html"); } public void update() { } }
Hbase.java
package com.plugin; import java.io.IOException; import java.util.ArrayList; import java.util.HashMap; import java.util.List; import java.util.Map; import org.apache.hadoop.hbase.Cell; import org.apache.hadoop.hbase.HColumnDescriptor; import org.apache.hadoop.hbase.HTableDescriptor; import org.apache.hadoop.hbase.TableName; import org.apache.hadoop.hbase.client.Connection; import org.apache.hadoop.hbase.client.Delete; import org.apache.hadoop.hbase.client.Get; import org.apache.hadoop.hbase.client.HBaseAdmin; import org.apache.hadoop.hbase.client.Put; import org.apache.hadoop.hbase.client.Result; import org.apache.hadoop.hbase.client.ResultScanner; import org.apache.hadoop.hbase.client.Scan; import org.apache.hadoop.hbase.client.Table; import org.apache.hadoop.hbase.util.Bytes; public class Hbase { static Connection connection; //新建表 public static boolean create(String tableName, String columnFamily) throws Exception { HBaseAdmin admin = (HBaseAdmin) connection.getAdmin(); if (admin.tableExists(tableName)) { System.out.println(tableName + " exists!"); return false; } else { String[] columnFamilyArray = columnFamily.split(","); HColumnDescriptor[] hColumnDescriptor = new HColumnDescriptor[columnFamilyArray.length]; for (int i = 0; i < hColumnDescriptor.length; i++) { hColumnDescriptor[i] = new HColumnDescriptor(columnFamilyArray[i]); } HTableDescriptor familyDesc = new HTableDescriptor(TableName.valueOf(tableName)); for (HColumnDescriptor columnDescriptor : hColumnDescriptor) { familyDesc.addFamily(columnDescriptor); } HTableDescriptor tableDesc = new HTableDescriptor(TableName.valueOf(tableName), familyDesc); admin.createTable(tableDesc); System.out.println(tableName + " create successfully!"); return true; } } //插入資料 public static boolean put(String tablename, String row, String columnFamily, String qualifier, String data) throws Exception { Table table = connection.getTable(TableName.valueOf(tablename)); Put put = new Put(Bytes.toBytes(row)); put.addColumn(Bytes.toBytes(columnFamily), Bytes.toBytes(qualifier), Bytes.toBytes(data)); table.put(put); System.out.println("put '" + row + "', '" + columnFamily + ":" + qualifier + "', '" + data + "'"); return true; } //插入多條資料 public static boolean puts(List<Put> puts,String tablename) throws Exception { Table table = connection.getTable(TableName.valueOf(tablename)); table.put(puts); return true; } //把result轉換成map，方便返回json資料 private static Map<String, Object> resultToMap(Result result) { Map<String, Object> resMap = new HashMap<String, Object>(); List<Cell> listCell = result.listCells(); Map<String, Object> tempMap = new HashMap<String, Object>(); String rowname = ""; List<String> familynamelist = new ArrayList<String>(); for (Cell cell : listCell) { byte[] rowArray = cell.getRowArray(); byte[] familyArray = cell.getFamilyArray(); byte[] qualifierArray = cell.getQualifierArray(); byte[] valueArray = cell.getValueArray(); int rowoffset = cell.getRowOffset(); int familyoffset = cell.getFamilyOffset(); int qualifieroffset = cell.getQualifierOffset(); int valueoffset = cell.getValueOffset(); int rowlength = cell.getRowLength(); int familylength = cell.getFamilyLength(); int qualifierlength = cell.getQualifierLength(); int valuelength = cell.getValueLength(); byte[] temprowarray = new byte[rowlength]; System.arraycopy(rowArray, rowoffset, temprowarray, 0, rowlength); String temprow = Bytes.toString(temprowarray); byte[] tempqulifierarray = new byte[qualifierlength]; System.arraycopy(qualifierArray, qualifieroffset, tempqulifierarray, 0, qualifierlength); String tempqulifier = Bytes.toString(tempqulifierarray); byte[] tempfamilyarray = new byte[familylength]; System.arraycopy(familyArray, familyoffset, tempfamilyarray, 0, familylength); String tempfamily = Bytes.toString(tempfamilyarray); byte[] tempvaluearray = new byte[valuelength]; System.arraycopy(valueArray, valueoffset, tempvaluearray, 0, valuelength); String tempvalue = Bytes.toString(tempvaluearray); tempMap.put(tempfamily + ":" + tempqulifier, tempvalue); rowname = temprow; String familyname = tempfamily; if (familynamelist.indexOf(familyname) < 0) { familynamelist.add(familyname); } } resMap.put("rowname", rowname); for (String familyname : familynamelist) { HashMap<String, Object> tempFilterMap = new HashMap<String, Object>(); for (String key : tempMap.keySet()) { String[] keyArray = key.split(":"); if (keyArray[0].equals(familyname)) { tempFilterMap.put(keyArray[1], tempMap.get(key)); } } resMap.put(familyname, tempFilterMap); } return resMap; } //檢視某行 public static Map<String, Object> get(String tablename, String row) throws Exception { Table table = connection.getTable(TableName.valueOf(tablename)); Get get = new Get(Bytes.toBytes(row)); Result result = table.get(get); System.out.println("Get: " + result); return resultToMap(result); } //檢視全表 public static List<Map<String, Object>> scan(String tablename) throws Exception { Table table = connection.getTable(TableName.valueOf(tablename)); Scan s = new Scan(); ResultScanner rs = table.getScanner(s); List<Map<String, Object>> resList = new ArrayList<Map<String, Object>>(); for (Result r : rs) { Map<String, Object> tempmap = resultToMap(r); resList.add(tempmap); } return resList; } //刪除表 public static boolean delete(String tableName) throws IOException { HBaseAdmin admin = (HBaseAdmin) connection.getAdmin(); if (admin.tableExists(tableName)) { try { admin.disableTable(tableName); admin.deleteTable(tableName); } catch (Exception e) { e.printStackTrace(); return false; } } return true; } //刪除ColumnFamily public static boolean deleteColumnFamily(String tableName, String columnFamilyName) throws IOException { HBaseAdmin admin = (HBaseAdmin) connection.getAdmin(); if (admin.tableExists(tableName)) { try { admin.deleteColumn(tableName, columnFamilyName); } catch (Exception e) { e.printStackTrace(); return false; } } return true; } //刪除row public static boolean deleteRow(String tableName, String rowName) throws IOException { HBaseAdmin admin = (HBaseAdmin) connection.getAdmin(); Table table = connection.getTable(TableName.valueOf(tableName)); if (admin.tableExists(tableName)) { try { Delete delete = new Delete(rowName.getBytes()); table.delete(delete); } catch (Exception e) { e.printStackTrace(); return false; } } return true; } //刪除qualifier public static boolean deleteQualifier(String tableName, String rowName, String columnFamilyName, String qualifierName) throws IOException { HBaseAdmin admin = (HBaseAdmin) connection.getAdmin(); Table table = connection.getTable(TableName.valueOf(tableName)); if (admin.tableExists(tableName)) { try { Delete delete = new Delete(rowName.getBytes()); delete.addColumns(columnFamilyName.getBytes(), qualifierName.getBytes()); table.delete(delete); } catch (Exception e) { e.printStackTrace(); return false; } } return true; } }
第四步：新增及修改頁面
index.htm程式碼如下：
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>Insert title here</title>
<script type="text/javascript" src="../js/jquery-3.3.1.min.js"></script>
<script type="text/javascript">
$(document).ready(function(){
$.ajax({
data:{"data1":"11","data2":"22"},
url:"/hello/scanStudent",
type:"post",
success:function(data){
var list=data.infos;
var tr="";
$.each(list, function(i, item){
tr +="<tr><td>"+item.rowname+"</td>"+"<td>"+item.base_info.no+"</td>"
+"<td>"+item.base_info.name+"</td>"+"<td>"+item.base_info.cls+"</td>"
+"<td><a href='/hello/delete?rowname="+item.rowname+"'>刪除</a>|<a href='/hello/openupdate?rowname="+item.rowname+"'>修改</a></td>";
});
$("table").append(tr);
}
});
});
</script>
</head>
<body align="center">
這是學生資訊頁面<br>
<a href="/hello/add">新增</a>|<a href="/hello">重新整理</a>|
<hr>
<table border="1" align="center">
<thead>
<tr>
<td>行號</td>
<td>學號</td>
<td>姓名</td>
<td>班級</td>
<td>操作</td>
</tr>
</thead>
<tbody>
</tbody>
</table>
</body>
</html>新增add.htm和update.jsp兩張頁面
add.html程式碼如下：
<!DOCTYPE html>
<html>
<head>
<meta charset="UTF-8">
<title>新增學生資訊頁面</title>
</head>
<body>
請填寫學生資訊<br>
<form action="/hello/save" method="post">
行號：<input type="text" name="rowname"><br>
學號：<input type="text" name="no"><br>
姓名：<input type="text" name="name"><br>
班級：<input type="text" name="cls"><br>
<input type="submit" value="儲存">
</form>
</body>
</html>update.jsp程式碼如下：
<%@ page language="java" contentType="text/html; charset=utf-8"
pageEncoding="utf-8"%>
<!DOCTYPE html>
<html>
<head>
<meta charset="utf-8">
<title>修改資訊頁面</title>
</head>
<body>
請修改學生資訊<br>
<form action="/hello/save" method="post">
行號：<input type="text" name="rowname" value="${info.rowname}"><br>
學號：<input type="text" name="no" value="${info.base_info.no}"><br>
姓名：<input type="text" name="name" value="${info.base_info.name}"><br>
班級：<input type="text" name="cls" value="${info.base_info.cls}"><br>
<input type="submit" value="儲存">
</form>
</body>
</html>步驟5,：啟動服務，檢視執行結果
1、開啟start.java，右鍵執行
2、開啟瀏覽器，輸入：http://localhost:8082/hello
如果看到以上圖片的結果，說明成功！
接下來你就可以測試你的其他功能！！！！