HBase 1.1.2 Java 客户端 api(hbase 1.0 增删改查,建表、删表等)

来源:转载


说明:
1.第一部分为代码
2.第二部分为工程pom文件

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;/** * Created by xuemin on 15/9/28. */public class HBaseTest { public static Configuration configuration; public static Connection connection; public static Admin admin; public static void main(String[] args) throws IOException { createTable("t2",new String[]{"cf1","cf2"}); insterRow("t2", "rw1", "cf1", "q1", "val1"); getData("t2", "rw1", "cf1", "q1"); scanData("t2", "rw1", "rw2"); deleRow("t2","rw1","cf1","q1"); deleteTable("t2"); } //初始化链接 public static void init(){ configuration = HBaseConfiguration.create(); configuration.set("hbase.zookeeper.quorum","10.10.3.181,10.10.3.182,10.10.3.183"); configuration.set("hbase.zookeeper.property.clientPort","2181"); configuration.set("zookeeper.znode.parent","/hbase"); try { connection = ConnectionFactory.createConnection(configuration); admin = connection.getAdmin(); } catch (IOException e) { e.printStackTrace(); } } //关闭连接 public static void close(){ try { if(null != admin) admin.close(); if(null != connection) connection.close(); } catch (IOException e) { e.printStackTrace(); } } //建表 public static void createTable(String tableNmae,String[] cols) throws IOException { init(); TableName tableName = TableName.valueOf(tableNmae); if(admin.tableExists(tableName)){ System.out.println("talbe is exists!"); }else { HTableDescriptor hTableDescriptor = new HTableDescriptor(tableName); for(String col:cols){ HColumnDescriptor hColumnDescriptor = new HColumnDescriptor(col); hTableDescriptor.addFamily(hColumnDescriptor); } admin.createTable(hTableDescriptor); } close(); } //删表 public static void deleteTable(String tableName) throws IOException { init(); TableName tn = TableName.valueOf(tableName); if (admin.tableExists(tn)) { admin.disableTable(tn); admin.deleteTable(tn); } close(); } //查看已有表 public static void listTables() throws IOException { init(); HTableDescriptor hTableDescriptors[] = admin.listTables(); for(HTableDescriptor hTableDescriptor :hTableDescriptors){ System.out.println(hTableDescriptor.getNameAsString()); } close(); } //插入数据 public static void insterRow(String tableName,String rowkey,String colFamily,String col,String val) throws IOException { init(); Table table = connection.getTable(TableName.valueOf(tableName)); Put put = new Put(Bytes.toBytes(rowkey)); put.addColumn(Bytes.toBytes(colFamily), Bytes.toBytes(col), Bytes.toBytes(val)); table.put(put); //批量插入 /* List<Put> putList = new ArrayList<Put>(); puts.add(put); table.put(putList);*/ table.close(); close(); } //删除数据 public static void deleRow(String tableName,String rowkey,String colFamily,String col) throws IOException { init(); Table table = connection.getTable(TableName.valueOf(tableName)); Delete delete = new Delete(Bytes.toBytes(rowkey)); //删除指定列族 //delete.addFamily(Bytes.toBytes(colFamily)); //删除指定列 //delete.addColumn(Bytes.toBytes(colFamily),Bytes.toBytes(col)); table.delete(delete); //批量删除 /* List<Delete> deleteList = new ArrayList<Delete>(); deleteList.add(delete); table.delete(deleteList);*/ table.close(); close(); } //根据rowkey查找数据 public static void getData(String tableName,String rowkey,String colFamily,String col)throws IOException{ init(); Table table = connection.getTable(TableName.valueOf(tableName)); Get get = new Get(Bytes.toBytes(rowkey)); //获取指定列族数据 //get.addFamily(Bytes.toBytes(colFamily)); //获取指定列数据 //get.addColumn(Bytes.toBytes(colFamily),Bytes.toBytes(col)); Result result = table.get(get); showCell(result); table.close(); close(); } //格式化输出 public static void showCell(Result result){ Cell[] cells = result.rawCells(); for(Cell cell:cells){ System.out.println("RowName:"+new String(CellUtil.cloneRow(cell))+" "); System.out.println("Timetamp:"+cell.getTimestamp()+" "); System.out.println("column Family:"+new String(CellUtil.cloneFamily(cell))+" "); System.out.println("row Name:"+new String(CellUtil.cloneQualifier(cell))+" "); System.out.println("value:"+new String(CellUtil.cloneValue(cell))+" "); } } //批量查找数据 public static void scanData(String tableName,String startRow,String stopRow)throws IOException{ init(); Table table = connection.getTable(TableName.valueOf(tableName)); Scan scan = new Scan(); //scan.setStartRow(Bytes.toBytes(startRow)); //scan.setStopRow(Bytes.toBytes(stopRow)); ResultScanner resultScanner = table.getScanner(scan); for(Result result : resultScanner){ showCell(result); } table.close(); close(); }}
<?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>td</groupId> <artifactId>hbase_test</artifactId> <version>1.0</version> <properties> <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding> <!-- <hadoop.version>2.6.0-cdh5.4.5</hadoop.version>--> <hbase.version>1.1.2</hbase.version> </properties> <dependencies> <dependency> <groupId>org.apache.hbase</groupId> <artifactId>hbase-client</artifactId> <version>${hbase.version}</version> </dependency> </dependencies></project>




分享给朋友:
您可能感兴趣的文章:
随机阅读: