HBase 的 Java Api

淡淡的烟草味﹌ 2022-11-18 01:50 177阅读 0赞

# 整合 #

## 依赖 ##

<dependency>
                <groupId>org.apache.hbase</groupId>
                <artifactId>hbase-client</artifactId>
                <version>2.2.5</version>
            </dependency>
            <dependency>
                <groupId>org.apache.hbase</groupId>
                <artifactId>hbase-common</artifactId>
                <version>2.2.5</version>
            </dependency>

## 创建 HBaseAdmin ##

public static void main(String[] args) throws IOException { 
            Configuration conf = HBaseConfiguration.create();
            // hbase 连接的 zk 地址
            conf.set("hbase.zookeeper.quorum" , "192.168.56.129");
            // 如果 hbase 连接的 zk 端口不是 2181
            // conf.set("hbase.zookeeper.property.clientPort", "2181");
    
            /* 获取一个Connection对象 */
            // org.apache.hadoop.hbase.client.Connection
            Connection connection = ConnectionFactory.createConnection(conf);
            /* 通过connection获取到一个HbaseAdmin */
            HBaseAdmin hBaseAdmin = (HBaseAdmin) connection.getAdmin() ;
    		
    		// 操作 hbase ....
    
    		// 关流
    		if(hBaseAdmin != null){ 
    			hBaseAdmin.close();  
    		}
    	}

*  注意一个关键点：client 会去获取 zk 上的 HMaster 的主机名，然后去连接这个主机名  
    ![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNDYwNw_size_16_color_FFFFFF_t_70]

解决办法

*  方法一：更改 hbase 所在 linux 机器的 hostname 为其 ip
 *  方法二：更改 client 机器的 host 文件，把 hbase 主机名对应的地址改为 linux 机器的地址

## 常用 DDL ##

### 列举 namespace ###

@Test
    	public void nameSpace_list(){ 
    		//通过hBaseAdmin获取listNamespaceDescriptors
    		NamespaceDescriptor[] namespaceDescriptors = this.hBaseAdmin.listNamespaceDescriptors(); 
    		//遍历
    		for (int i = 0; i < namespaceDescriptors.length; i++){ 
    			NamespaceDescriptor namespaceDescriptor = namespaceDescriptors[i];
    			String name = namespaceDescriptor.getName(); 
    			this.logger.info("==nameSpace_list==计数:{},名字:{}",i,name);
    		}
    	}

### 列举表 ###

@Test
    	public void table_list(){ 
    		/* list:列出所有的表 */
    		TableName[] tables = this.hBaseAdmin.listTableNames() ; 
    		for (int i = 0; i < tables.length; i++){ 
    			TableName tableNameTemp = tables[i];
    			this.logger.info("==test==计数:{},名字:{}",i,tableNameTemp);
    		}
    	}

### 创建 namespace ###

@Test
    	public void nameSpace_create(){ 
    		/* 数据库 */
    		private String nameSpace = "test" ; 
    		
    		NamespaceDescriptor descriptor = NamespaceDescriptor.create(nameSpace).build();
    		/* create_namespace '' */
    		this.hBaseAdmin.createNamespace(descriptor);
    	}

### 创建表 ###

@Test
    	public void table_create(){ 
    		/* 表名 */
    		String tableName = "test:tab1";
    		/* 表的名字 */
    		TableName tableNameObj = TableName.valueOf(tableName);
    		/* 表的描述信息 */
    		TableDescriptorBuilder builder = TableDescriptorBuilder.newBuilder(tableNameObj);
    
    		/* 列族 */
    		private String cf = "cf1"
    		/* 列族的描述信息 */
    		ColumnFamilyDescriptor familyDescriptor = ColumnFamilyDescriptorBuilder.of(cf);
    		/* 添加列族;单个列族 */
    		builder.setColumnFamily(familyDescriptor);
    		/* 获取表的描述信息 */
    		TableDescriptor desc = builder.build() ; 
    		/* 如果表存在 */
    		if(this.hBaseAdmin.tableExists(tableNameObj)){ 
    			/* 禁用表 */
    			this.hBaseAdmin.disableTable(tableNameObj);
    			/* 删除表 */
    			this.hBaseAdmin.deleteTable(tableNameObj);
    		}
    		/* create_namespace '' */
    		this.hBaseAdmin.createTable(desc);
    	}

## 常用 DML ##

### 添加数据 ###

@Test
    	public void table_put(){ 
    		/* 表名 */
    		String tableName = "test:tab1";
    		/* 表的描述信息 */
    		TableName tableNameObj = TableName.valueOf(tableName);
    		/* 获取到表对象 */
    		Table table = this.connection.getTable(tableNameObj);
    		/* 获取表名字 */
    		this.logger.info("name:{}",table.getName().getNameAsString());
    			
    		/* 列族 */
    		private String cf = "cf1"
    		/* 行键(键) */
    		String rowKey = "02" ; 
    		/* 插入数据的对象 */
    		Put put = new Put(rowKey.getBytes("UTF-8"));
    		/* 列族的属性 * 参数1:列族 * 参数2:属性 * 参数3:值 **/
    		put.addColumn(cf.getBytes("UTF-8"), "name".getBytes("UTF-8"), "lisi".getBytes("UTF-8"));
    		put.addColumn(cf.getBytes("UTF-8"), "age".getBytes("UTF-8"), "20".getBytes("UTF-8"));
    		put.addColumn(cf.getBytes("UTF-8"), "createTime".getBytes("UTF-8"), "2019-11-11 11:11:11".getBytes("UTF-8"));
    			
    		/* 添加数据 * 参数如果是Put,那就是单条操作, * 参数如果是List,那就是海量操作(批处理); **/
    		table.put(put);
    	}

### 删除数据 ###

### 获取数据（get） ###

@Test
    	public void table_get(){ 
    		/* 表名 */
    		String tableName = "test:tab1";
    		/* 表的描述信息 */
    		TableName tableNameObj = TableName.valueOf(tableName);
    		/* 获取到表对象 */
    		Table table = this.connection.getTable(tableNameObj);
    		/* 获取表名字 */
    		this.logger.info("name:{}",table.getName().getNameAsString());
    			
    		/* 行键(键) */
    		String rowKey = "02" ; 
    		/* 条件,rowKey */
    		Get get = new Get(rowKey.getBytes("UTF-8"));
    		/* 根据rowKey查询数据 */
    		Result result = table.get(get);
    
    		/* 列族 */
    		private String cf = "cf1"
    		/* 取单个 */
    		byte[] valueByte = result.getValue(cf.getBytes("UTF-8"), "name".getBytes("UTF-8"));
    		this.logger.info("根据键,取单个列:{}",new String(valueByte,"UTF-8"));
    			
    		/* 获取最新的值 */
    		Cell lastCell = result.getColumnLatestCell(cf.getBytes("UTF-8"), "name".getBytes("UTF-8"));
    		byte[] lastCells = lastCell.getValueArray() ;
    		this.logger.info("根据键,取单个列:{}",new String(lastCells,"UTF-8"));
    	}

### 获取数据(scan) ###

@Test
    	public void table_scan(){ 
    		/* 表名 */
    		String tableName = "test:tab1";
    		/* 表的描述信息 */
    		TableName tableNameObj = TableName.valueOf(tableName);
    		/* 获取到表对象 */
    		Table table = this.connection.getTable(tableNameObj);
    		/* 获取表名字 */
    		this.logger.info("name:{}",table.getName().getNameAsString());
    			
    		/* 获取所有数据 */
    		Scan scan = new Scan();
    		/* 列族 */
    		private String cf = "cf1"
    		
    		/* 扫描整张表 */
    		ResultScanner resultScan = table.getScanner(scan);
    		for (Iterator iterator = resultScan.iterator(); iterator.hasNext();){ 
    			Result result = (Result) iterator.next();
    			/* 取单个 */
    			byte[] nameByte = result.getValue(cf.getBytes("UTF-8"), "name".getBytes("UTF-8"));
    			this.logger.info("根据键,取单个列:{}",new String(nameByte,"UTF-8"));
    				
    			byte[] ageByte = result.getValue(cf.getBytes("UTF-8"), "age".getBytes("UTF-8"));
    			this.logger.info("根据键,取单个列:{}",new String(ageByte,"UTF-8"));
    				
    			byte[] createTimeByte = result.getValue(cf.getBytes("UTF-8"), "createTime".getBytes("UTF-8"));
    			this.logger.info("根据键,取单个列:{}",new String(createTimeByte,"UTF-8"));
    		}	
    	}

*  设置起始行数
    
        Scan s = new Scan();
        s.setStartRow(Bytes.toBytes("100001"));
        s.setStopRow(Bytes.toBytes("1000020"));
 *  设置过滤器
    
        FilterList filterList = new FilterList(FilterList.Operator.MUST_PASS_ALL);
        SingleColumnValueFilter filter1 = new SingleColumnValueFilter(
                Bytes.toBytes("info"), // family 列祖
                Bytes.toBytes("age"), // quilifieq 列名
                CompareOp.GREATER_OR_EQUAL, // 要求
                Bytes.toBytes("25") 
                );
        SingleColumnValueFilter filter2 = new SingleColumnValueFilter(
                Bytes.toBytes("info"),
                Bytes.toBytes("age"),
                CompareOp.LESS_OR_EQUAL,
                Bytes.toBytes("30")
                );
        filterList.addFilter(filter1);
        filterList.addFilter(filter2);
                
        Scan scan = new Scan();
        scan.setFilter(filterList);

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MzkzNDYwNw_size_16_color_FFFFFF_t_70]: /images/20221022/0feff4b82f1543b8ad0dc35490bd285a.png