按条件查询与删除数据-----HBase(伪分布)学习笔记
站在用户的角度思考问题,与客户深入沟通,找到双清网站设计与双清网站推广的解决方案,凭借多年的经验,让设计与互联网技术结合,创造个性化、用户体验好的作品,建站类型包括:成都网站制作、成都网站建设、企业官网、英文网站、手机端网站、网站推广、域名申请、网站空间、企业邮箱。业务覆盖双清地区。
/* * 删除RowKey所有行 * 非空判断√ */ public static void deleteRows(String tablename,String RowKey){ HTable h=null; HBaseAdmin ha=null; Get get=new Get(Bytes.toBytes(RowKey)); try{ ha=new HBaseAdmin(config); if(ha.tableExists(tablename)){ h=new HTable(config,tablename); Delete d=new Delete(Bytes.toBytes(RowKey)); if(h.exists(get)){ h.delete(d); System.out.println("删除成功"); }else{ System.out.println("滚犊子!!!"); } }else{ System.out.println("表呢?你的表那!!"); } }catch(Exception e){ e.printStackTrace(); }finally{ try { h.close(); } catch (IOException e) { e.printStackTrace(); } } } /* * 删除指定一行的数据 * */ public static void deleteRow(String tablename,String RowKey,String family,String qualifier){ HTable h=null; try { h=new HTable(config,tablename); Delete d=new Delete(Bytes.toBytes(RowKey)); d.deleteColumn(Bytes.toBytes(family), Bytes.toBytes(qualifier)); h.delete(d); System.out.println("删除成功!"); } catch (IOException e) { e.printStackTrace(); }finally{ try { h.close(); } catch (IOException e) { e.printStackTrace(); } } } /* * 按条件查询(应用filter) */ @SuppressWarnings("deprecation") public static void GetByParam(String tablename,String Family,String qualifier,String value){ HTable h=null; ResultScanner rs=null; try { h=new HTable(config,tablename); Filter f=new SingleColumnValueFilter(Bytes.toBytes(Family),Bytes.toBytes(qualifier),CompareOp.EQUAL,Bytes.toBytes(value) ); Scan scan=new Scan(); scan.setFilter(f); scan.addColumn(Bytes.toBytes(Family),Bytes.toBytes(qualifier)); rs=h.getScanner(scan); System.out.println("行 列簇 列名 值 时间戳"); for (Result r : rs) { for (KeyValue kv : r.raw()) { System.out.println(kv.getRowOffset()+" "+Family+" "+qualifier+" "+new String(kv.getValue())+" "+ kv.getTimestamp()); } } } catch (IOException e) { e.printStackTrace(); }finally{ try{ rs.close(); h.close(); }catch(Exception e){ e.printStackTrace(); } } } /* * 按条件查询value * 参数:表名,行,列簇,列名 */ public static void get(String tablename,String rowKey,String Family,String qualifier)throws Exception{ HConnection connection = HConnectionManager.createConnection(config); HTableInterface table = connection.getTable(TableName.valueOf(tablename)); try { System.out.println("开始获取------哔哔哔"); Get get=new Get(rowKey.getBytes()); get.addColumn(Family.getBytes(), qualifier.getBytes()); Result r=table.get(get); for(KeyValue kv:r.raw()) { System.out.println("您要查的值为"+new String(kv.getValue())); } } finally { table.close(); connection.close(); } }
当前题目:按条件查询与删除数据-----HBase(伪分布)学习笔记
网页路径:http://hbruida.cn/article/podspi.html