上传Excel到HBase数据库(POI、poi-ooxml)
作者:互联网
这里调用了HBase的API和操作excel的POI
一、配置文件pom.xml
<?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>org.example</groupId>
<artifactId>Test</artifactId>
<version>1.0-SNAPSHOT</version>
<properties>
<maven.compiler.source>15</maven.compiler.source>
<maven.compiler.target>15</maven.compiler.target>
</properties>
<dependencies>
<dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase-server</artifactId>
<version>2.1.9</version>
</dependency>
<dependency>
<groupId>org.apache.hbase</groupId>
<artifactId>hbase-client</artifactId>
<version>2.1.9</version>
</dependency>
<dependency>
<groupId>org.apache.poi</groupId>
<artifactId>poi-ooxml</artifactId>
<version>3.17</version>
</dependency>
</dependencies>
</project>
二、函数实现
参数说明:
- filePath传入excel的绝对路径
- keyName你需要作为rowkey列的列名
这里需要注意的是,调用POI去获取excel表格的长度时,你获得的长度和宽度大概率是不准确的,该数据一定比实际的值要大,因为POI算的是长度,而不是有几个单元格。这就意味着如果你的单元格被你拉的很宽很长,那么POI计算出来的行数和列数必定比实际要大。就拿我来举例,我一个excel表格的长度是50(有50行),可是使用POI计算出来的行数是200,还以为出了BUG。
当然,在下面的函数中解决了该问题,该函数会把你excel列名(第一行)作为HBase列族中的列名,对应的数据就是value值
public static void Excel_to_HBase(String filePath,String keyName) throws IOException {
HBaseHelper.Exec_CreateNamesplace(tableName);
HBaseHelper.Exec_CreateTable(tableName, family);
if(!filePath.endsWith(".xlsx")){
System.out.println("传入文件不是excel类型");
}
FileInputStream fis = null;
Workbook workbook = null;
//获取绝对路径
try{
fis = new FileInputStream(filePath);
} catch (Exception e) {
e.printStackTrace();
}
//创建工作表
try{
//XSSF读取后缀为xlsx的excel文件
assert fis != null;
workbook = new XSSFWorkbook(fis);
}catch (Exception e){
try{
//HSSF读取后缀为xls的excel文件
workbook = new HSSFWorkbook(fis);
}catch (Exception ex){
ex.printStackTrace();
}
}
//得到一个工作表
assert workbook != null;
Sheet sheet = workbook.getSheetAt(0);
//获取表头
Row rowHead = sheet.getRow(0);
//获取总列数
int totalColumnNum = rowHead.getPhysicalNumberOfCells();
//获取总行数,这里会因为excel格式的问题而获取与实际数据不一致的行数信息,获取的都是比实际行数大的值
int totalRowNum = sheet.getLastRowNum();
//获取keyName所在列的列数
int rowIndex = 0;
for (int i = 0; i < totalColumnNum; i++) {
Cell sheetTableName = rowHead.getCell(i);
if(String.valueOf(sheetTableName).equals(keyName)){
rowIndex = i;
}
}
//获取excel实际长度
int ListLength = 0;
for (int i = 0; i < totalRowNum; i++) {
Row row = sheet.getRow(i+1);
Cell cell1 = row.getCell(rowIndex);
//指定格式,否则无法读取数字列
cell1.setCellType(CellType.STRING);
String data = cell1.getStringCellValue();
if (!data.isEmpty()){
ListLength = i;
}
}
//循环遍历添加数据
for (int i = 0; i < totalColumnNum; i++) {
//不添加作为行键的数据列
if (i!=rowIndex) {
Cell cell = rowHead.getCell(i);
if(!String.valueOf(cell).isEmpty()) {
System.out.println(cell);
//判断是否为空
if (!String.valueOf(cell).isEmpty()) {
for (int j = 0; j <= ListLength; j++) {
Row row = sheet.getRow(j + 1);
Cell cell1 = row.getCell(i);
Cell key = row.getCell(rowIndex);
//指定格式,否则无法读取数字列
cell1.setCellType(CellType.STRING);
String data = cell1.getStringCellValue();
//调用函数
Exec_AddData(tableName, family, String.valueOf(key), String.valueOf(cell), data);
}
}
}
}
}
}
}
//插入数据
public static boolean Exec_AddData(String Tname,String family,String rowkey,String column,String value){
try {
Put put = new Put(Bytes.toBytes(rowkey));
put.addColumn(Bytes.toBytes(family), Bytes.toBytes(column), Bytes.toBytes(value));
TableName tableName = TableName.valueOf(Tname);
GetConn().getTable(tableName).put(put);
return true;
} catch (IOException e) {
return false;
}
标签:String,int,excel,valueOf,Excel,cell1,POI,ooxml 来源: https://blog.csdn.net/weixin_48435461/article/details/122329960