HBase 最新版本（1.0以上）测试案例

野性酷女 2022-08-18 03:12 156阅读 0赞

最近写HBase，使用最近的1.0版本，发现很多功能都不建议使用，依据官方的文档写了份关于增删改查的测试案例，供学习交流。

import org.apache.hadoop.conf.Configuration;
    import org.apache.hadoop.hbase.*;
    import org.apache.hadoop.hbase.client.*;
    import org.apache.hadoop.hbase.io.compress.Compression;
    import org.apache.hadoop.hbase.util.Bytes;
    import org.junit.Before;
    import org.junit.Test;
    
    import java.io.IOException;
    
    /** * Hbase 基本CRUD 样例代码 覆盖Put Get Delete checkAndPut checkAndDelete Scan * 通过上面的各种操作的例子, 会基本覆盖Htable可以用的的所有方法 * 这里不涉及Hbase 管理代码的操作 * @author seagle * */
    public class HbaseCRUDTest {
    
        @Before
        public void beforeTest(){
    
        }
    
        @Test
        public void createTest() throws IOException {
            Configuration conf = HBaseConfiguration.create();
    
            Connection connection = ConnectionFactory.createConnection(conf);
            String tablename = "test";
            String familyname="info";
            Admin admin = connection.getAdmin();
            HTableDescriptor table = new HTableDescriptor(TableName.valueOf(tablename));
            table.addFamily(new HColumnDescriptor(familyname).setCompressionType(Compression.Algorithm.SNAPPY));
    
            System.out.print("Creating table. ");
    
            // 判断是否存在,如果存在,先删除.
            if (admin.tableExists(table.getTableName())) {
                admin.disableTable(table.getTableName());
                admin.deleteTable(table.getTableName()); // 删除存在的表
            }
    
            // 创建表
            admin.createTable(table);
            System.out.println(" Done.");
        }
    
        @Test
        public void putTest() throws IOException {
            Configuration conf = HBaseConfiguration.create();
    // Use below code for HBase version 1.x.x or above.
            Connection connection = ConnectionFactory.createConnection(conf);
            TableName tableName = TableName.valueOf("test");
            Table table = connection.getTable(tableName);
    
            Put put = new Put(Bytes.toBytes("8")); // row key
    
    //        put.addColumn(Bytes.toBytes("family"),Bytes.toBytes("qualifier"),Bytes.toBytes("value"));
    
            put.addColumn(Bytes.toBytes("info"),Bytes.toBytes("level_1"),Bytes.toBytes("4"));
            put.addColumn(Bytes.toBytes("info"),Bytes.toBytes("level_2"),Bytes.toBytes("4"));
            put.addColumn(Bytes.toBytes("info"),Bytes.toBytes("level_3"),Bytes.toBytes("4"));
            put.addColumn(Bytes.toBytes("info"),Bytes.toBytes("level_4"),Bytes.toBytes("4"));
    
            table.put(put);
        }
    
    
        @Test
        public void getTest() throws IOException {
            Configuration conf = HBaseConfiguration.create();
    // Use below code for HBase version 1.x.x or above.
            Connection connection = ConnectionFactory.createConnection(conf);
            TableName tableName = TableName.valueOf("test");
            Table table = connection.getTable(tableName);
    
            StringBuffer sb = null;
    
            Get get = new Get(Bytes.toBytes("8"));
            Result result = table.get(get);
            for (Cell c : result.rawCells()) {
                sb = new StringBuffer(Bytes.toString(CellUtil.cloneRow(c)));
                sb.append("==> ");
                sb.append(Bytes.toString(CellUtil.cloneFamily(c)));
                sb.append("{");
                sb.append(Bytes.toString(CellUtil.cloneQualifier(c)));
                sb.append(":");
                sb.append(Bytes.toString(CellUtil.cloneValue(c)));
                sb.append("}");
                System.out.println(sb);
            }
        }
    
        @Test
        public void scanTest() throws IOException {
            Configuration conf = HBaseConfiguration.create();
            Connection connection = ConnectionFactory.createConnection(conf);
            TableName tableName = TableName.valueOf("test");
            Table table = connection.getTable(tableName);
    
            StringBuffer sb = null;
            Scan scan = new Scan();
            ResultScanner scanner = table.getScanner(scan);
            for (Result res : scanner) {
                for (Cell c : res.rawCells()) {
                    sb = new StringBuffer(Bytes.toString(CellUtil.cloneRow(c)));
                    sb.append(" ==> ");
                    sb.append(Bytes.toString(CellUtil.cloneFamily(c)));
                    sb.append(" {");
                    sb.append(Bytes.toString(CellUtil.cloneQualifier(c)));
                    sb.append(":");
                    sb.append(Bytes.toString(CellUtil.cloneValue(c)));
                    sb.append("}");
                    System.out.println(sb.toString());
                }
            }
        }
    
        @Test
        public void modifyTest() throws IOException{
            Configuration conf = HBaseConfiguration.create();
            try (Connection connection = ConnectionFactory.createConnection(conf);
                 Admin admin = connection.getAdmin()) {
    
                TableName tableName = TableName.valueOf("test");
                if (!admin.tableExists(tableName)) {
                    System.out.println("表不存在");
                    System.exit(-1);
                }
    
                HTableDescriptor table = new HTableDescriptor(tableName);
    
                // add family
    //            HColumnDescriptor newColumn = new HColumnDescriptor("testinfo");
    //            newColumn.setCompactionCompressionType(Compression.Algorithm.GZ);
    //            newColumn.setMaxVersions(HConstants.ALL_VERSIONS);
    //            admin.addColumn(tableName, newColumn);
    
                // Update existing column family
                HColumnDescriptor existingColumn = new HColumnDescriptor("info");
                existingColumn.setCompactionCompressionType(Compression.Algorithm.GZ);
                existingColumn.setMaxVersions(HConstants.ALL_VERSIONS);
                table.modifyFamily(existingColumn);
                admin.modifyTable(tableName, table);
    
                // Disable an existing table
    //            admin.disableTable(tableName);
    
                // Delete an existing column family
    //            admin.deleteColumn(tableName, "testinfo".getBytes("UTF-8"));
    
                // Delete a table (Need to be disabled first)
    //            admin.deleteTable(tableName);
            }
        }
    
        @Test
        public void deleteColumnDataTest() throws IOException {
            Configuration conf = HBaseConfiguration.create();
            Connection connection = ConnectionFactory.createConnection(conf);
            TableName tableName = TableName.valueOf("test");
            Table table = connection.getTable(tableName);
            Delete delete = new Delete(Bytes.toBytes("8"));
            table.delete(delete);
            System.out.println("删除数据成功");
        }
    }