3.4 DML

package com.atguigu;

import org.apache.hadoop.hbase.Cell;
import org.apache.hadoop.hbase.CellUtil;
import org.apache.hadoop.hbase.TableName;
import org.apache.hadoop.hbase.client.*;
import org.apache.hadoop.hbase.filter.FilterList;
import org.apache.hadoop.hbase.util.Bytes;

import java.io.IOException;
import java.util.List;

public class HBaseDML {
//添加静态属性connection指向单例连接
public static Connection connection = HBaseConnect01_单线程创建链接.connection;
public static void main(String[] args) throws IOException {
putCell("bigdata","student","1002","info", "name","lisi"); String cell =
getCells("bigdata","student","1002","info", "name"); System.out.println(cell);
List<String> strings = scanRows("bigdata","student","1001","2000"); for (String
string :strings){ System.out.println(string);
deleteColumn("bigdata","student","1002","info", "name"); } } /** * 插入数据 *
@param namespace 命名空间名称 * @param tableName 表格名称 * @param rowKey 主键 * @param
columnFamily 列族名称 * @param columnName 列名 * @param value 值 */ public static void
putCell(String namespace,String tableName, String rowKey,String
columnFamily,String columnName,String value) throws IOException{ //1.获取table
Table table = connection.getTable(TableName.valueOf(namespace,tableName));
//2.调用相关方法插入数据 //2.1创建put对象 Put put = new Put(Bytes.toBytes(rowKey));
//2.2给put对象添加数据
put.addColumn(Bytes.toBytes(columnFamily),Bytes.toBytes(columnFamily),Bytes.toBytes(value));
//2.3将对象写入对应的方法 try { table.put(put); } catch (IOException e) {
e.printStackTrace(); //throw new RuntimeException(e); } //3.关闭table
table.close(); } /** * 读取数据 读取对应的一行中的某一列 * * @param namespace 命名空间名称 * @param
tableName 表格名称 * @param rowKey 主键 * @param columnFamily 列族名称 * @param
columnName 列名 * @return */ public static String getCells(String namespace,
String tableName, String rowKey, String columnFamily, String columnName) throws
IOException { //1.获取table Table table =
connection.getTable(TableName.valueOf(namespace,tableName)); //2.创建get对象 Get
get = new Get(Bytes.toBytes(rowKey)); //如果直接调用get方法读取数据，此时读一整行数据
//如果想读取某一列的数据，需要添加对应的参数
get.addColumn(Bytes.toBytes(columnFamily),Bytes.toBytes(columnName));
// //设置读取数据的版本
//此处无法识别，会报错
// get.readAllVersions();
try { //读取数据，得到result对象 Result result = table.get(get); //处理数据 Cell [] cells
= result.rawCells(); //测试方法：直接把读取的数据打印到控制台 //如果是实际开发，需要再额外写方法，对应处理数据 for (Cell
cell : cells){ //cell存储数据比较底层 String value = new
String(CellUtil.cloneValue(cell)); System.out.println(value); } } catch
(IOException e) { e.printStackTrace(); //throw new RuntimeException(e); }
//关闭table table.close(); return namespace; } /** * 扫描数据 * * @param namespace
命名空间 * @param tableName 表格名称 * @param startRow 开始的 row 包含的 * @param stopRow 结束的
row 不包含 * @return */ public static List<String> scanRows(String namespace,
String tableName, String startRow, String stopRow) throws IOException {
//1.获取table Table table =
connection.getTable(TableName.valueOf(namespace,tableName)); //2.创建scan对象 Scan
scan = new Scan(); //如果此时直接调用，会直接扫描整张表 //添加参数，来控制扫描的数据 //默认包含
//下面两个scan会报错，即withStartRow和withStopRow会报错。
// scan.withStartRow(Bytes.toBytes(startRow));
//默认不包含
// scan.withStopRow(Bytes.toBytes(stopRow));
try { //读取多行数据，获得scanner ResultScanner scanner = table.getScanner(scan);
//result来记录一行数据，cell数组 //ResultScanner来记录多行数据result的数组 for (Result result :
scanner){ Cell[] cells = result.rawCells(); for (Cell cell : cells){
System.out.println(new String(CellUtil.cloneRow(cell)) + "-" + new
String(CellUtil.cloneFamily(cell)+ "-")+ new
String(CellUtil.cloneQualifier(cell))+ "-"+ new
String(CellUtil.cloneValue(cell)) + "\t"); } System.out.println(); } }catch
(IOException e){ e.printStackTrace(); } //3.关闭table table.close(); return null;
} /** * 带过滤的扫描 * * @param namespace 命名空间 * @param tableName 表格名称 * @param
startRow 开始的 row 包含的 * @param stopRow 结束的 row 不包含 * @param columnFamily 列族名称 *
@param columnName 列名 * @param value value值 * @throws IOException */ public
static void filterScan(String namespace,String tableName,String startRow,String
stopRow ,String columnFamily,String columnName,String value) throws IOException
{ //1.获取table Table table =
connection.getTable(TableName.valueOf(namespace,tableName)); //2.创建scan对象 Scan
scan = new Scan(); //如果此时直接调用，会直接扫描整张表 //添加参数，来控制扫描的数据
//此处会报错，需要注意还是scan.withStartRow //默认包含
//scan.withStartRow(Bytes.toBytes(startRow)); //默认不包含
//scan.withStopRow(Bytes.toBytes(stopRow)); //可以添加多个过滤 FilterList filterList =
new FilterList(); //创建过滤器 //(1)结果只保留当前列的数据
/* 这里还是会报错
ColumnValueFilter columnValueFilter = new ColumnValueFilter( //列族名称
Bytes.toBytes(columnFamily); //列名 Bytes.toBytes(columnName); //比较关系
CompareOperator.EQUAL; //值 Bytes.toBytes(value); ); */
/* 这里还是会报错
//(2)结果保留整行数据
//结果同时会保留没有当前列的数据
SingleColumnValueFilter singleColumnValueFilter = new SingleColumnValueFilter(
//列族名称
Bytes.toBytes(columnFamily);
//列名
Bytes.toBytes(columnName);
//比较关系
CompareOperator.EQUAL;
//值
Bytes.toBytes(value);
);
*/ /* //本身可以添加过个过滤器 filterList.addFilter(singleColumnValueFilter); */ //添加过滤
scan.setFilter(filterList); try { //读取多行数据，获得scanner ResultScanner scanner =
table.getScanner(scan); //result来记录一行数据，cell数组 //ResultScanner来记录多行数据，result的数组
for (Result result : scanner){ Cell [] cells = result.rawCells(); for (Cell
cell : cells){ System.out.println(new String(CellUtil.cloneRow(cell)) + "-" +
new String(CellUtil.cloneFamily(cell))+ "-" + new
String(CellUtil.cloneFamily(cell))+ "-" + new String(CellUtil.cloneValue(cell))
+ "\t"); } System.out.println(); } }catch (IOException e){ e.printStackTrace();
} //3.关闭table table.close(); } /** * 删除column数据 * * @param namespace 命名空间 *
@param tableName 表格名称 * @param rowKey * @param family * @param column 列名 *
@throws IOException */ public static void deleteColumn(String namespace,String
tableName,String rowKey,String family,String column) throws IOException {
//1.获取table Table table =
connection.getTable(TableName.valueOf(namespace,tableName)); //2.创建Delete对象
Delete delete = new Delete(Bytes.toBytes(rowKey)); //3.添加删除信息 //3.1删除单个版本
delete.addColumn(Bytes.toBytes(family),Bytes.toBytes(column)); //3.2删除所有版本
delete.addColumns(Bytes.toBytes(family),Bytes.toBytes(column)); //3.3删除列族
delete.addFamily(Bytes.toBytes(family)); //4.删除数据 table.delete(delete);
//5.关闭资源 table.close(); }
}// HBaseDML

• « 上一篇：Python List pop()方法
• » 下一篇：SpringBoot 是怎样连接 MySql 数据库的