/*** 获取链接, 只需要zookeeper的链接就可了*/@Beforepublic void beforeTest() throws IOException {Configuration conf = HBaseConfiguration.create();// hbase端口默认2181, 可以使用hbase.zookeeper.property.clientPort设置conf.set("hbase.zookeeper.quorum", "192.168.208.106,192.168.208.107,192.168.208.108");// 去的数据库连接对象connect = ConnectionFactory.createConnection(conf);}/*** 关闭资源*/@Afterpublic void afterTest() throws IOException {if (connect != null) {connect.close();}}

    @Testpublic void testCreate() throws IOException {//去的一个数据库元操作对象Admin admin = connect.getAdmin();if (admin.tableExists(table)) {// 删除需要先disable
            admin.disableTable(table);admin.deleteTable(table);}// 创建表描述对象HTableDescriptor htable = new HTableDescriptor(table);// 创建列族描述对象HColumnDescriptor hColumn = new HColumnDescriptor("cf1".getBytes());hColumn.setMaxVersions(5);hColumn.setBlockCacheEnabled(true);hColumn.setBlocksize(1800000);// 数据库中新建一个列族
        htable.addFamily(hColumn);// 新建数据库
        admin.createTable(htable);}

    /*** 数据插入*/@Testpublic void testInsert() throws IOException {Table table = connect.getTable(tableName);List<Put> list = new ArrayList<>();for (int i = 0; i < 1000; i++) {int month = i % 3;int day = i % 9;Put put = new Put(getRowKey("138", month, day).getBytes());// 列1put.addColumn("cf1".getBytes(), "address".getBytes(), "bj".getBytes());// 列2put.addColumn("cf1".getBytes(), "type".getBytes(), String.valueOf(random.nextInt(2)).getBytes());list.add(put);}table.put(list);　　　　 table.flushCommits();}

    /*** rowkey 生成策略, 电话号 + 日期*/public String getRowKey(String prePhone, int month, int day) {return prePhone + random.nextInt(99999999) + "_2017" + month + day;}

    /*** 根据rowkey 查询* @throws IOException*/@Testpublic void scan() throws IOException {Table table = connect.getTable(tableName);//rowkey 按照字典排序, 所以可以截取Scan scan = new Scan("13862288854_201700".getBytes(), "13899338829_201714".getBytes());ResultScanner scanner = table.getScanner(scan);for (Iterator<Result> iterator = scanner.iterator(); iterator.hasNext(); ) {Result next = iterator.next();byte[] value = next.getValue("cf1".getBytes(), "type".getBytes());System.out.println(new String(value, "utf8"));}}

    @Testpublic void filter() throws IOException {// All表示全部匹配, 相当于and, one 相当于 orFilterList filterList = new FilterList(FilterList.Operator.MUST_PASS_ALL);// 查询某一个电话, type 等于 1PrefixFilter prefixFilter = new PrefixFilter("1388".getBytes());SingleColumnValueFilter singleColumnValueFilter = new SingleColumnValueFilter("cf1".getBytes(), "type".getBytes(), CompareFilter.CompareOp.EQUAL, "1".getBytes());// 过滤器是对结果排序, 所以顺序影响效率
        filterList.addFilter(prefixFilter);filterList.addFilter(singleColumnValueFilter);// 创建查询对象Scan scan = new Scan();scan.setFilter(filterList);Table table = connect.getTable(tableName);ResultScanner scanner = table.getScanner(scan);for (Result result : scanner) {byte[] value = result.getValue("cf1".getBytes(), "type".getBytes());System.out.println(new String(value, "utf8"));}}

    @Testpublic void testGet() throws IOException {Table table = connect.getTable(tableName);Get get = new Get("13899126419_201717".getBytes());Result result = table.get(get);Cell cell = result.getColumnLatestCell("cf1".getBytes(), "address".getBytes());System.out.println(new String(cell.getValueArray(), "utf8"));}