项目文件截图
Java运行截图
1 package domain; 2 3 import java.io.IOException; 4 import java.util.ArrayList; 5 import java.util.List; 6 import java.util.Scanner; 7 8 import org.apache.hadoop.hbase.client.Put; 9 10 import com.sun.corba.se.spi.orbutil.fsm.Guard.Result; 11 import com.sun.org.apache.xml.internal.security.keys.content.KeyValue; 12 13 import hbase.dao.HBaseDAO; 14 import hbase.dao.imp.HBaseDAOImp; 15 16 public class Test { 17 18 public static void main(String[] args) { 19 HBaseDAOImp hBaseDAOImp=new HBaseDAOImp(); 20 try 21 { 22 int n=0; 23 24 Scanner in = new Scanner(System.in); 25 while(n!=20) 26 { System.out.println("**********欢迎使用HBase系统××××××××××"); 27 System.out.println("1.创建指定的数据库"); 28 System.out.println("2.列出 Hbase 所有的表的信息"); 29 System.out.println("3.向数据库表中插入信息");//添加信息 30 System.out.println("4.查看指定数据库表的信息");//查看信息 31 System.out.println("5.清空指定的表的所有记录数据"); 32 System.out.println("6.统计数据库中数据表的行数"); 33 System.out.println("7.向指定数据库表中插入某一行全部信息"); 34 System.out.println("8.查看指定数据库表中某一行全部信息"); 35 System.out.println("9.删除指定数据库表中某一行的指定行健的的信息"); 36 System.out.println("10.修改指定数据库表中某一行的指定列的信息"); 37 System.out.println("############多条件查询###########"); 38 System.out.println("11.按照两列的值进行查询"); 39 System.out.println("20.退出"); 40 System.out.println("请选择："); 41 if(in.hasNextInt()) 42 { 43 n=in.nextInt(); 44 } 45 else 46 { 47 System.out.println("输入的不是整数，请重新输入："); 48 continue; 49 } 50 switch(n) 51 { 52 case 1:{ 53 System.out.println("输入你要创建的数据库的名称"); 54 String tablename=in.next(); 55 System.out.println("输入你要创建的数据库的列族名称"); 56 String field=in.next(); 57 String[] fields= {field}; 58 //String[] fields= {"name","num","password"}; 59 hBaseDAOImp.createTable(tablename, fields); 60 61 62 63 break; 64 } 65 case 2:{ 66 hBaseDAOImp.listTables(); 67 break; 68 } 69 case 3:{ 70 String tablename=null; 71 tablename="zythbase"; 72 String rowKey=null; 73 rowKey="zyt001"; 74 String family=null; 75 family="zyt"; 76 String quailifer=null;//列的名称 77 quailifer="name"; 78 String value=null; 79 value="张运涛"; 80 hBaseDAOImp.insert(tablename, rowKey, family, quailifer, value); 81 break; 82 } 83 case 4:{ 84 System.out.println("输入你要查询的数据库的名称"); 85 String tablename=in.next(); 86 hBaseDAOImp.getData(tablename); 87 break; 88 } 89 case 5: { 90 System.out.println("输入你要清空的数据库的名称"); 91 String tablename=in.next(); 92 hBaseDAOImp.clearRows(tablename); 93 break; 94 } 95 96 case 6:{ 97 System.out.println("输入你要统计的数据库的行数名称"); 98 String tablename=in.next(); 99 hBaseDAOImp.countRows(tablename); 100 101 break; 102 } 103 case 7:{ 104 System.out.println("输入你要插入的数据库的名称"); 105 String tablename=in.next(); 106 System.out.println("输入你要插入的此行数据的的行健"); 107 String hqname=in.next(); 108 System.out.println("输入你要插入的此行数据的的列族名称"); 109 String lzname=in.next(); 110 111 List<Put> list = new ArrayList<Put>(); 112 Put put = new Put(hqname.getBytes());//参数为行键的值 113 put.add(lzname.getBytes(), "name".getBytes(), "啊是的飒飒大家阿诗丹顿所".getBytes()) ;//参数为列族的名称，列的名称，列对应的值 114 list.add(put) ; 115 116 put.add(lzname.getBytes(), "addr".getBytes(), "shanghai1".getBytes()) ; 117 list.add(put) ; 118 put.add(lzname.getBytes(), "age".getBytes(), "30".getBytes()) ; 119 list.add(put) ; 120 put.add(lzname.getBytes(), "tel".getBytes(), "13567882341".getBytes()) ; 121 list.add(put) ; 122 hBaseDAOImp.save(list, tablename);//参数为数据库的名称 123 System.out.println("数据插入成功！！！！"); 124 125 break; 126 } 127 case 8:{ 128 System.out.println("输入你要查看的数据库的名称"); 129 String tablename=in.next(); 130 System.out.println("输入你要查看的此行数据的的行健"); 131 String hqname=in.next(); 132 System.out.println("数据查询结果如下！！！！"); 133 hBaseDAOImp.showlistOneRow(tablename, hqname); 134 135 136 137 break; 138 } 139 case 9:{ 140 System.out.println("输入你要删除的数据库的名称"); 141 String tablename=in.next(); 142 System.out.println("输入你要删除的此行数据的的行健"); 143 String hqname=in.next(); 144 145 hBaseDAOImp.deleteRow(tablename, hqname); 146 System.out.println("数据删除成功！！！！"); 147 148 149 150 break; 151 } 152 case 10:{ 153 System.out.println("输入你要修改的数据库的名称"); 154 String tablename=in.next(); 155 System.out.println("输入你要修改的此行数据的的行健"); 156 String hqname=in.next(); 157 System.out.println("输入你要修改的此行数据的列族"); 158 String column=in.next(); 159 System.out.println("输入你要修改的此行数据的列名"); 160 String lieming=in.next(); 161 System.out.println("输入你要修改后的值"); 162 String val=in.next(); 163 164 hBaseDAOImp.modifyData(tablename, hqname, column, lieming, val); 165 System.out.println("数据修改完成！！！！"); 166 167 168 169 break; 170 } 171 case 11:{ 172 /*System.out.println("输入你要查询的数据库的名称"); 173 String tablename=in.next();*/ 174 /*System.out.println("输入你要修改的此行数据的的行健"); 175 String hqname=in.next(); 176 System.out.println("输入你要修改的此行数据的列族"); 177 String column=in.next();*/ 178 179 180 hBaseDAOImp.QueryByCondition2("Student"); 181 182 183 184 185 break; 186 } 187 case 20:break; 188 default:System.out.println("输入错误，请重新输入");break; 189 } 190 } 191 192 } 193 catch (Exception e) 194 { 195 e.printStackTrace(); 196 } 197 } 198 199 }
Javaweb运行截图
全部源代码：https://pan.baidu.com/s/1gsgFQ1RpbtTb43_xoOAiAA