依赖：
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.atlxl</groupId> <artifactId>Hbase01</artifactId> <version>1.0-SNAPSHOT</version> <dependencies> <dependency> <groupId>org.apache.hbase</groupId> <artifactId>hbase-server</artifactId> <version>1.3.1</version> </dependency> <dependency> <groupId>org.apache.hbase</groupId> <artifactId>hbase-client</artifactId> <version>1.3.1</version> </dependency> <!-- https://mvnrepository.com/artifact/commons-collections/commons-collections --> <dependency> <groupId>commons-collections</groupId> <artifactId>commons-collections</artifactId> <version>3.1</version> </dependency> <dependency> <groupId>commons-configuration</groupId> <artifactId>commons-configuration</artifactId> <version>1.5</version> </dependency> <dependency> <groupId>commons-codec</groupId> <artifactId>commons-codec</artifactId> <version>1.10</version> </dependency> <dependency> <groupId>commons-lang</groupId> <artifactId>commons-lang</artifactId> <version>2.5</version> </dependency> </dependencies> </project>
代码：
package com.atlxl; import org.apache.hadoop.conf.Configuration; import org.apache.hadoop.hbase.*; import org.apache.hadoop.hbase.client.*; import org.apache.hadoop.hbase.util.Bytes; import java.io.IOException; import static com.sun.xml.internal.fastinfoset.alphabet.BuiltInRestrictedAlphabets.table; public class TestHbase { private static Admin admin = null; private static Connection connection = null; private static Configuration configuration =null; static { //Hbase配置文件 // HBaseConfiguration configuration = new HBaseConfiguration(); configuration = HBaseConfiguration.create(); configuration.set("hbase.zookeeper.quorum", "192.168.192.102"); //获取连接对象 try { connection = ConnectionFactory.createConnection(configuration); admin = connection.getAdmin(); } catch (IOException e) { e.printStackTrace(); } } private static void close(Connection conn,Admin admin) { if (conn!=null) { try { conn.close(); } catch (IOException e) { e.printStackTrace(); } } if (admin!=null) { try { admin.close(); } catch (IOException e) { e.printStackTrace(); } } } //判断表是否存在 public static boolean tableExist(String tableName) throws IOException { //获取HBase管理员对象 // HBaseAdmin admin = new HBaseAdmin(configuration); //执行 // boolean tableExists = admin.tableExists(tableName); boolean tableExists = admin.tableExists(TableName.valueOf(tableName)); //关闭资源 admin.close(); return tableExists; } //创建表 public static void createTable(String tableName, String... cfs) throws IOException { if (tableExist(tableName)) { System.out.println("表已存在！！"); return; } //创建表描述器 HTableDescriptor hTableDescriptor = new HTableDescriptor(TableName.valueOf(tableName)); //添加列族 for (String cf : cfs) { //创建列描述器 HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(cf); hTableDescriptor.addFamily(hColumnDescriptor); } //创建表的操作 admin.createTable(hTableDescriptor); System.out.println("表创建成功！"); } //删除表 public static void deleteTable(String tableName) throws IOException { if (!tableExist(tableName)) { return; } //删除表之前先使表不可用（下线） admin.disableTable(TableName.valueOf(tableName)); //执行删除操作 admin.deleteTable(TableName.valueOf(tableName)); System.out.println("表已删除！！"); } //增//改 public static void putData(String tableName, String rowKey, String cf, String cn, String value) throws IOException { //获取表对象 Table table = connection.getTable(TableName.valueOf(tableName)); // HTable table = new HTable(configuration, TableName.valueOf(tableName)); //创建Put对象 Put put = new Put(Bytes.toBytes(rowKey)); put.addColumn(Bytes.toBytes(cf), Bytes.toBytes(cn), Bytes.toBytes(value)); //执行添加操作 table.put(put); } //删 public static void delete(String tableName, String rowKey, String cf, String cn) throws IOException { //获取table对象 Table table = connection.getTable(TableName.valueOf(tableName)); //创建delete对象 Delete delete = new Delete(Bytes.toBytes(rowKey)); delete.addColumns(Bytes.toBytes(cf), Bytes.toBytes(cn)); // delete.addColumn(Bytes.toBytes(cf), Bytes.toBytes(cn)); //执行删除操作 table.delete(delete); table.close(); } //查 //全表扫描 public static void scanTable(String tableName) throws IOException { //获取table对象 Table table = connection.getTable(TableName.valueOf(tableName)); //构建扫描器 Scan scan = new Scan(); // scan.setStartRow() // scan.setStopRow() ResultScanner results = table.getScanner(scan); //遍历数据并打印 for (Result result : results) { Cell[] cells = result.rawCells(); for (Cell cell : cells) { System.out.println("RK:" + Bytes.toString( CellUtil.cloneRow(cell)) + ",CF:" + Bytes.toString(CellUtil.cloneFamily(cell)) + ",CN:" + Bytes.toString(CellUtil.cloneQualifier(cell)) + ",VALUE:" + Bytes.toString(CellUtil.cloneValue(cell))); } } table.close(); } //获取指定列族：列的数据 public static void getData(String tableName, String rowKey, String cf, String cn) throws IOException { //获取表对象 Table table = connection.getTable(TableName.valueOf(tableName)); //创建一个Get对象 Get get = new Get(Bytes.toBytes(rowKey)); get.addColumn(Bytes.toBytes(cf), Bytes.toBytes(cn)); //指定版本 // get.setMaxVersions(); //指定列族 // get.addFamily(); //获取数据的操作 Result result = table.get(get); Cell[] cells = result.rawCells(); for (Cell cell : cells) { System.out.println("RK:" + Bytes.toString( CellUtil.cloneRow(cell)) + ",CF:" + Bytes.toString(CellUtil.cloneFamily(cell)) + ",CN:" + Bytes.toString(CellUtil.cloneQualifier(cell)) + ",VALUE:" + Bytes.toString(CellUtil.cloneValue(cell))); } table.close(); } public static void main(String[] args) throws IOException { // System.out.println(tableExist("student")); // System.out.println(tableExist("staff")); //调用创建表 // createTable("staff", "info"); //调用删除表 // deleteTable("staff"); //判断表是否存在 // System.out.println(tableExist("staff")); //插入数据 // putData("student", "1002", "info", "name", "zhangsan"); // putData("student", "1002", "info", "sex", "female"); // putData("student", "1002", "info", "age", "18"); // putData("student", "1003", "info", "name", "lisi"); // putData("student", "1003", "info", "sex", "male"); // putData("student", "1004", "info", "age", "18"); // putData("student", "1004", "info", "name", "wanwu"); // delete("student", "1001", "info", "sex"); // scanTable("student"); getData("student", "1003", "info", "name"); close(connection, admin); } }