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

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

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("删除数据成功");

}

}