HBASE的Java與Javaweb（采用MVC模式）實現增刪改查附帶源碼

 項目文件截圖

 

 

Java運行截圖

package domain;

import java.io.IOException;
import java.util.ArrayList;
import java.util.List;
import java.util.Scanner;

import org.apache.hadoop.hbase.client.Put;

import com.sun.corba.se.spi.orbutil.fsm.Guard.Result;
import com.sun.org.apache.xml.internal.security.keys.content.KeyValue;

import hbase.dao.HBaseDAO;
import hbase.dao.imp.HBaseDAOImp;

public class Test {

    public static void main(String[] args) {
        HBaseDAOImp hBaseDAOImp=new HBaseDAOImp();
        try 
        {  
            int n=0;
        
            Scanner in = new Scanner(System.in);
            while(n!=20)
            {    System.out.println("**********歡迎使用HBase系統××××××××××");
                System.out.println("1.創建指定的數據庫");
                System.out.println("2.列出 Hbase 所有的表的信息");
                System.out.println("3.向數據庫表中插入信息");//添加信息
                System.out.println("4.查看指定數據庫表的信息");//查看信息
                System.out.println("5.清空指定的表的所有記錄數據");
                System.out.println("6.統計數據庫中數據表的行數");
                System.out.println("7.向指定數據庫表中插入某一行全部信息");
                System.out.println("8.查看指定數據庫表中某一行全部信息");
                System.out.println("9.刪除指定數據庫表中某一行的指定行健的的信息");
                System.out.println("10.修改指定數據庫表中某一行的指定列的信息");
                System.out.println("############多條件查詢###########");
                System.out.println("11.按照兩列的值進行查詢");
                System.out.println("20.退出");
                System.out.println("請選擇：");
                if(in.hasNextInt())
                {
                    n=in.nextInt();
                }
                else
                {
                    System.out.println("輸入的不是整數，請重新輸入：");
                    continue;
                }
                switch(n)
                {
                case 1:{
                    System.out.println("輸入你要創建的數據庫的名稱");
                    String tablename=in.next();
                    System.out.println("輸入你要創建的數據庫的列族名稱");
                    String field=in.next();
                    String[] fields= {field};
                    //String[] fields= {"name","num","password"};
                    hBaseDAOImp.createTable(tablename, fields);
                    
                    
                    
                    break;
                }
                case 2:{
                    hBaseDAOImp.listTables();
                    break;
                }
             case 3:{
                 String tablename=null;
                 tablename="zythbase";
                 String rowKey=null;
                 rowKey="zyt001";
                 String family=null;
                 family="zyt";
                 String quailifer=null;//列的名稱
                 quailifer="name";
                 String value=null;
                 value="張運濤";
                 hBaseDAOImp.insert(tablename, rowKey, family, quailifer, value);
                 break;
             }
              case 4:{
                  System.out.println("輸入你要查詢的數據庫的名稱");
                      String tablename=in.next();
                      hBaseDAOImp.getData(tablename);
                       break;
              }
                case 5: {
                     System.out.println("輸入你要清空的數據庫的名稱");
                       String tablename=in.next();
                       hBaseDAOImp.clearRows(tablename);
                    break;
                }
                        
                case 6:{
                    System.out.println("輸入你要統計的數據庫的行數名稱");
                      String tablename=in.next();
                    hBaseDAOImp.countRows(tablename);
                   
                    break;
                }
                case 7:{
                    System.out.println("輸入你要插入的數據庫的名稱");
                      String tablename=in.next();
                      System.out.println("輸入你要插入的此行數據的的行健");
                      String hqname=in.next();
                      System.out.println("輸入你要插入的此行數據的的列族名稱");
                      String lzname=in.next();
                  
                    List<Put> list = new ArrayList<Put>();
                    Put put = new Put(hqname.getBytes());//參數為行鍵的值
                    put.add(lzname.getBytes(), "name".getBytes(), "啊是的颯颯大家阿詩丹頓所".getBytes()) ;//參數為列族的名稱，列的名稱，列對應的值
                    list.add(put) ;
                    
                    put.add(lzname.getBytes(), "addr".getBytes(), "shanghai1".getBytes()) ;
                    list.add(put) ;
                    put.add(lzname.getBytes(), "age".getBytes(), "30".getBytes()) ;
                    list.add(put) ;
                    put.add(lzname.getBytes(), "tel".getBytes(), "13567882341".getBytes()) ;
                    list.add(put) ;
                    hBaseDAOImp.save(list, tablename);//參數為數據庫的名稱
                    System.out.println("數據插入成功！！！！");
                   
                    break;
                }
                case 8:{
                    System.out.println("輸入你要查看的數據庫的名稱");
                      String tablename=in.next();
                      System.out.println("輸入你要查看的此行數據的的行健");
                      String hqname=in.next();
                      System.out.println("數據查詢結果如下！！！！");
                      hBaseDAOImp.showlistOneRow(tablename, hqname);
                    
                    
                   
                    break;
                }
                case 9:{
                    System.out.println("輸入你要刪除的數據庫的名稱");
                      String tablename=in.next();
                      System.out.println("輸入你要刪除的此行數據的的行健");
                      String hqname=in.next();
                      
                      hBaseDAOImp.deleteRow(tablename, hqname);
                      System.out.println("數據刪除成功！！！！");
                    
                    
                   
                    break;
                }
                case 10:{
                    System.out.println("輸入你要修改的數據庫的名稱");
                      String tablename=in.next();
                      System.out.println("輸入你要修改的此行數據的的行健");
                      String hqname=in.next();
                      System.out.println("輸入你要修改的此行數據的列族");
                      String column=in.next();
                      System.out.println("輸入你要修改的此行數據的列名");
                      String lieming=in.next();
                      System.out.println("輸入你要修改后的值");
                      String val=in.next();
                      
                      hBaseDAOImp.modifyData(tablename, hqname, column, lieming, val);
                      System.out.println("數據修改完成！！！！");
                    
                    
                   
                    break;
                }
                case 11:{
                    /*System.out.println("輸入你要查詢的數據庫的名稱");
                      String tablename=in.next();*/
                      /*System.out.println("輸入你要修改的此行數據的的行健");
                      String hqname=in.next();
                      System.out.println("輸入你要修改的此行數據的列族");
                      String column=in.next();*/
                      
                      
                      hBaseDAOImp.QueryByCondition2("Student");
                      
                    
                    
                   
                    break;
                }
                case 20:break;
                default:System.out.println("輸入錯誤，請重新輸入");break;
                }
            }
        
        } 
        catch (Exception e)
        { 
            e.printStackTrace(); 
        } 
    }

    }

 

 

 

 

 

 

 

 

 

 

 

 

 

 Javaweb運行截圖

全部源代碼：https://pan.baidu.com/s/1gsgFQ1RpbtTb43_xoOAiAA