2.     /**
  3.      *     1、namespace相关
  4.      *         1、创建namespace: create_namespace '命名空间名称'
  5.      *         2、查看所有的命名空间： list_namespace
  6.      *         3、查看命名空间下所有表: list_namespace_tables '命名空间名称'
  7.      *         4、删除命名空间[删除命名的时候,命名空间下不能有表,如果有表不能删除命名空间]: drop_namespace '命名空间名称'
  8.      *     2、表相关
  9.      *         1、创建表[版本默认为1]: create '表名','列簇名1','列簇2',..
  10.      *         2、创建表,指定版本号:  create '表名',{NAME=>'列簇名',VERSIONS=>版本数},...
  11.      *         3、修改表: alter '表',{NAME=>'列簇名',VERSIONS=>版本数},..
  12.      *         4、删除表:
  13.      *             1、禁用表: disable '表名'
  14.      *             2、删除表: drop '表名'
  15.      *         5、启动表: enable '表名'
  16.      *         6、查看所有表: list
  17.      *     3、数据相关
  18.      *         1、插入/修改数据: put '命名空间名称:表名',rowkey,'列簇名:列限定符名称',值
  19.      *         2、查询数据
  20.      *             1、根据rowkey查询单条数据:
  21.      *                 1、查询整行数据: get '命名空间名称:表名',rowkey
  22.      *                 2、查询某个列的数据: get '命名空间名称:表名',rowkey,'列簇名:列限定符名称'
  23.      *                 3、查看某个列簇的数据: get '命名空间名称:表名',rowkey,'列簇名'
  24.      *                 4、查看某个时间戳的数据: get '命名空间名称:表名',rowkey,{COLUMN=>'列簇名:列限定符名称',TIMESTAMP=>时间戳}
  25.      *                 5、查看多个版本的数据: get '命名空间名称:表名',rowkey,{COLUMN=>'列簇名:列限定符名称',VERSIONS=>版本数}
  26.      *             2、扫描表
  27.      *                 1、查询整表数据: scan '命名空间名称:表名'
  28.      *                 2、查询查询某个列的数据: scan '命名空间名称:表名',{COLUMNS=>'列簇名:列限定符名称'}
  29.      *                 3、查看某个列簇的数据： scan '命名空间名称:表名',{COLUMNS=>'列簇名'}
  30.      *                 4、查看多个版本的数据：scan '命名空间名称:表名',{COLUMNS=>'列簇名',VERSIONS=>版本数}
  31.      *                 5、查看指定rowkey范围段的数据: scan '命名空间名称:表名',{STARTKEY=>起始rowkey,STOPKEY=>结束rowkey} [查询结果不包含stopkey]
  32.      *         3、删除数据
  33.      *             1、delete： 只能删除单个cell
  34.      *                 delete '命名空间名称:表名',rowkey,'列簇名:列限定符名称'
  35.      *             2、deleteall： 可以删除单个cell也可以删除整行数据
  36.      *                 1、删除单个cell: deleteall '命名空间名称:表名',rowkey,'列簇名:列限定符名称'
  37.      *                 2、删除整行: deleteall '命名空间名称:表名',rowkey
  38.      *         4、统计表的行数: count '命名空间名称:表名'
  39.      *         5、清空表数据: truncate '命名空间名称:表名'
  40.      */

初始化与关闭io流

  1.  private Admin admin;
  2.     private Connection connection;
  3.     @Before
  4.     public void init () throws Exception{
  5.         //获取连接
  6.         Configuration conf = HBaseConfiguration.create();
  7.         conf.set("hbase.zookeeper.quorum","hadoop102:2181,hadoop103:2181,hadoop104:2181");
  9.          connection = ConnectionFactory.createConnection(conf);
  10.         //获取admin对象
  11.          admin = connection.getAdmin();
  12.     }
  13.     @After
  14.     public void close() throws Exception{
  16.         //关闭
  17.         admin.close();
  18.         connection.close();
  19.     }

createNamespace

  1.  @Test
  2.     public void createNamespace() throws IOException {
  5.         //描述命名空间
  6.         NamespaceDescriptor bigdata2 = NamespaceDescriptor.create("bigdata2").build();
  7.         //创建
  8.         admin.createNamespace(bigdata2);
  10.     }

listNamespace

  1.  @Test
  2.     public void listNamespace() throws Exception{
  4.         NamespaceDescriptor[] namespaceDescriptors = admin.listNamespaceDescriptors();
  6.         for(NamespaceDescriptor des: namespaceDescriptors){
  7.             System.out.println(des.getName());
  8.         }
  9.     }

listNamespaceTables

  1. @Test
  2.     public void listNamespaceTables() throws Exception{
  4.         TableName[] tableNames = admin.listTableNamesByNamespace("bigdata");
  6.         for(TableName tableName: tableNames){
  7.             System.out.println(tableName.getNameAsString());
  8.         }
  9.     }

dropNamespace

  1.  @Test
  2.     public void dropNamespace() throws Exception{
  4.         //删除命名空间下所有表
  5.             //获取命名空间下所有表
  6.             TableName[] tables = admin.listTableNamesByNamespace("bigdata");
  8.             for(TableName table: tables){
  9.                 //禁用表
  10.                 admin.disableTable(table);
  11.                 //删除表
  12.                 admin.deleteTable(table);
  13.                 //启动表
  14.                 //admin.enableTable(table);
  15.             }
  17.         //删除命名空间
  18.         admin.deleteNamespace("bigdata");
  19.     }

createTable

  1. @Test
  2.     public void createTable() throws Exception{
  4.         //描述列簇
  5.         ColumnFamilyDescriptor f1 = ColumnFamilyDescriptorBuilder.newBuilder("f1".getBytes()).setMaxVersions(3).build();
  6.         ColumnFamilyDescriptor f2 = ColumnFamilyDescriptorBuilder.newBuilder("f2".getBytes()).setMaxVersions(3).build();
  7.         //描述表
  8.         TableDescriptor build = TableDescriptorBuilder.newBuilder(TableName.valueOf("bigdata2:person4"))
  9.                 .setColumnFamily(f1)
  10.                 .setColumnFamily(f2)
  11.                 .build();
  12.         //创建
  13.         //admin.createTable(build);
  14. /*        byte[][] splitkeys = { "aa".getBytes(),"bb".getBytes(),"cc".getBytes() };
  15.         admin.createTable(build,splitkeys);*/
  17.         admin.createTable(build,"1".getBytes(),"3".getBytes(),5);
  18.     }

alterTable

  1. @Test
  2.     public void alterTable() throws Exception{
  3.         //描述列簇
  4.         ColumnFamilyDescriptor f1 = ColumnFamilyDescriptorBuilder.newBuilder("f1".getBytes()).setMaxVersions(3).build();
  5.         //ColumnFamilyDescriptor f2 = ColumnFamilyDescriptorBuilder.newBuilder("f2".getBytes()).setMaxVersions(3).build();
  6.         //描述表
  7.         TableDescriptor build = TableDescriptorBuilder.newBuilder(TableName.valueOf("bigdata2:person"))
  8.                 .setColumnFamily(f1)
  9.                 //.setColumnFamily(f2)
  10.                 .build();
  11.         admin.modifyTable(build);
  13.     }

put

  1. @Test
  2.     public void put() throws Exception{
  4.         //获取Table对象
  5.         Table table = connection.getTable(TableName.valueOf("bigdata2:person"));
  6.         // put '命名空间名称:表名',rowkey,'列簇名:列限定符名称',值
  7.         //封装数据
  8.         Put put = new Put("1001".getBytes());
  10.         put.addColumn("f1".getBytes(),"name".getBytes(),"lisi".getBytes());
  11.         put.addColumn("f1".getBytes(),"age".getBytes(), Bytes.toBytes(20));
  12.         put.addColumn("f1".getBytes(),"address".getBytes(),"shenzhen".getBytes());
  13.         //插入
  14.         table.put(put);
  15.         //关闭table对象
  16.         table.close();
  18.     }

putList

  1. @Test
  2.     public void putList() throws Exception{
  3.         //获取Table对象
  4.         Table table = connection.getTable(TableName.valueOf("bigdata2:person"));
  5.         // put '命名空间名称:表名',rowkey,'列簇名:列限定符名称',值
  7.         //封装数据
  8.         List<Put> list = new ArrayList<Put>();
  9.         Put put = null;
  11.         for(int i=0;i<=10;i++){
  12.             put = new Put( ("100"+i).getBytes() );
  13.             put.addColumn("f1".getBytes(),"name".getBytes(),("lisi-"+i).getBytes());
  14.             put.addColumn("f1".getBytes(),"age".getBytes(),Bytes.toBytes(20+i));
  15.             put.addColumn("f1".getBytes(),"address".getBytes(),("shenzhe-"+i).getBytes());
  16.             list.add(put);
  17.         }
  18.         //插入
  19.         table.put(list);
  20.         //关闭
  21.         table.close();
  22.     }

get

  1. @Test
  2.     public void get()  throws Exception{
  3.         //获取表对象
  4.         Table table = connection.getTable(TableName.valueOf("bigdata2:person"));
  5.         //封装数据
  6.         //1、查询整行数据: get '命名空间名称:表名',rowkey
  7.         //Get get = new Get("1001".getBytes());
  8.         //2、查询某个列的数据: get '命名空间名称:表名',rowkey,'列簇名:列限定符名称'
  9.         //Get get = new Get("1001".getBytes());
  10.         //get.addColumn("f1".getBytes(),"name".getBytes());
  11.         //3、查看某个列簇的数据: get '命名空间名称:表名',rowkey,'列簇名'
  12.         //Get get = new Get("1001".getBytes());
  13.         //get.addFamily("f1".getBytes());
  14.         //4、查看某个时间戳的数据: get '命名空间名称:表名',rowkey,{COLUMN=>'列簇名:列限定符名称',TIMESTAMP=>时间戳}
  15.         Get get = new Get("1001".getBytes());
  16.         get.addColumn("f1".getBytes(),"name".getBytes());
  17.         //get.setTimestamp(1620887027129L);
  18.         //5、查询多个版本数据
  19.         get.readVersions(3);
  20.         //查询,一个result逻辑结构上是一整行数据，在物力结构中是多行
  21.         Result result = table.get(get);
  22.         //结果展示
  23.         List<Cell> cells = result.listCells();
  24.         // 每个cell都是值，所以都是以字节数组的形式存储，所以要解码为字符串、
  25.         // 解码：byte-->字符串
  26.         // 编码：字符串-->byte
  27.         for(Cell cell:cells){
  29.             //获取rowkey
  30.             String rowkey = new String(cell.getRowArray(), cell.getRowOffset(), cell.getRowLength());
  31.             //获取列簇
  32.             String family = new String(cell.getFamilyArray(), cell.getFamilyOffset(), cell.getFamilyLength());
  33.             //获取列限定符
  34.             String qualifier = new String(cell.getQualifierArray(), cell.getQualifierOffset(), cell.getQualifierLength());
  35.             //获取值,判断column，如果是int型不能放进Sting（）类中。
  36.             if(family.equals("f1") && qualifier.equals("age") ){
  38.                 int value = Bytes.toInt(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength());
  39.                 System.out.println("rowkey="+rowkey+",family="+family+",qualifier="+qualifier+",value="+value);
  40.             }else{
  42.                 String value = new String(cell.getValueArray(), cell.getValueOffset(), cell.getValueLength());
  43.                 System.out.println("rowkey="+rowkey+",family="+family+",qualifier="+qualifier+",value="+value);
  44.             }
  48.         }
  49.         //关闭
  50.         table.close();
  51.     }

scan

  1. /**
  2.      * 扫描数据
  3.      *                 1、查询整表数据: scan '命名空间名称:表名'
  4.      *                 2、查询查询某个列的数据: scan '命名空间名称:表名',{COLUMNS=>'列簇名:列限定符名称'}
  5.      *                 3、查看某个列簇的数据： scan '命名空间名称:表名',{COLUMNS=>'列簇名'}
  6.      *                 4、查看多个版本的数据：scan '命名空间名称:表名',{COLUMNS=>'列簇名',VERSIONS=>版本数}
  7.      *                 5、查看指定rowkey范围段的数据: scan '命名空间名称:表名',{STARTKEY=>起始rowkey,STOPKEY=>结束rowkey} [查询结果不包含stopkey]
  8.      * @throws Exception
  9.      */
  10.     @Test
  11.     public void scan() throws Exception{
  13.         //获取表对象
  14.         Table table = connection.getTable(TableName.valueOf("bigdata2:person"));
  15.         //封装数据
  16.         //1、查询整表
  17.         Scan scan = new Scan();
  18.         //2、查询查询某个列的数据: scan '命名空间名称:表名',{COLUMNS=>'列簇名:列限定符名称'}
  19.         //scan.addColumn("f1".getBytes(),"name".getBytes());
  20.         //3、查看某个列簇的数据： scan '命名空间名称:表名',{COLUMNS=>'列簇名'}
  21.         scan.addFamily("f1".getBytes());
  22.         //4、查看多个版本的数据：scan '命名空间名称:表名',{COLUMNS=>'列簇名',VERSIONS=>版本数}
  23.         scan.readVersions(3);
  24.         //5、查看指定rowkey范围段的数据: scan '命名空间名称:表名',{STARTKEY=>起始rowkey,STOPKEY=>结束rowkey} [查询结果不包含stopkey]
  25.         scan.withStartRow("1001".getBytes(),false);
  26.         scan.withStopRow("1002".getBytes(),true);
  27.         //查询
  28.         ResultScanner scanner = table.getScanner(scan);
  29.         //结果展示
  30.         Iterator<Result> it = scanner.iterator();
  31.         while (it.hasNext()){
  33.             Result row = it.next();
  35.             List<Cell> cells = row.listCells();
  37.             for(Cell cell:cells){
  39.                 //获取rowkey
  40.                 String rowkey = new String(CellUtil.cloneRow(cell));
  41.                 //获取列簇
  42.                 String family = new String(CellUtil.cloneFamily(cell));
  43.                 //获取列限定符
  44.                 String qualifier = new String(CellUtil.cloneQualifier(cell));
  45.                 //获取值
  46.                 if(family.equals("f1") && qualifier.equals("age") ){
  48.                     int value = Bytes.toInt(CellUtil.cloneValue(cell));
  49.                     System.out.println("rowkey="+rowkey+",family="+family+",qualifier="+qualifier+",value="+value);
  50.                 }else{
  52.                     String value = new String(CellUtil.cloneValue(cell));
  53.                     System.out.println("rowkey="+rowkey+",family="+family+",qualifier="+qualifier+",value="+value);
  54.                 }
  55.             }
  56.         }
  57.         //关闭
  58.         table.close();
  59.     }

delete

  1.  @Test
  2.     public void delete() throws Exception{
  4.         //获取表对象
  5.         Table table = connection.getTable(TableName.valueOf("bigdata2:person"));
  6.         //封装数据
  7.         //删除整行
  8.         Delete delete = new Delete("10010".getBytes());
  9.         //删除单个Cell
  10.         //delete.addColumn("f1".getBytes(),"name".getBytes());
  11.         //删除列簇
  12.         delete.addFamily("f1".getBytes());
  13.         //删除
  14.         table.delete(delete);
  16.         //关闭
  17.         table.close();
  18.     }

truncate

  1. @Test
  2.     public void truncate() throws Exception{
  4.         if( admin.tableExists(TableName.valueOf("bigdata2:person"))){
  5.             //禁用表
  6.             admin.disableTable(TableName.valueOf("bigdata2:person"));
  7.             //清空表
  8.             admin.truncateTable(TableName.valueOf("bigdata2:person"),false);
  9.         }
  10.     }