如何将excel的数据导入hbase

发布网友 发布时间：2022-04-24 13:02

我来回答

共1个回答

热心网友 时间：2022-04-14 09:20

package
Common;
import
java.io.FileInputStream;
import
java.io.FileNotFoundException;
import
java.io.FileOutputStream;
import
java.io.IOException;
import
java.util.ArrayList;
import
java.util.HashMap;
import
java.util.List;
import
java.util.Map;
import
org.apache.poi.hssf.usermodel.HSSFWorkbook;
import
org.apache.poi.poifs.filesystem.POIFSFileSystem;
import
org.apache.poi.ss.usermodel.*;
/**
*
*
@author
LFF
*
@version
0.5
Excel文件操作帮助类
*
*/
public
class
ExcelPOIHelper
{
//
D盘建一个空的workbook.xls文件
public
static
void
Create(String
path,
String
name)
{
Workbook
wb
=
new
HSSFWorkbook();
FileOutputStream
fileOut;
try
{
fileOut
=
new
FileOutputStream("D:/workbook.xls");
wb.write(fileOut);
fileOut.close();
}
catch
(FileNotFoundException
e)
{
e.printStackTrace();
}
catch
(IOException
e)
{
e.printStackTrace();
}
}
/**
*
取出Excel所有工作簿名
*
*
@param
fullPath
*
Excel文件完整地址("D:/workbook.xls")
*
@return
工作簿名列表
*/
public
static
List<String>
GetSheets(String
fullPath)
{
List<String>
result
=
new
ArrayList<String>();
try
{
FileInputStream
file
=
new
FileInputStream(fullPath);
POIFSFileSystem
ts
=
new
POIFSFileSystem(file);
Workbook
workbook
=
new
HSSFWorkbook(ts);
for
(int
i
=
0;
i
<
workbook.getNumberOfSheets();
i++)
{
String
sheetName
=
workbook.getSheetName(i);
result.add(i,
sheetName);
}
file.close();
}
catch
(FileNotFoundException
e)
{
e.printStackTrace();
}
catch
(IOException
e)
{
e.printStackTrace();
}
return
result;
}
/**
*
取工作簿中所有的行
*
*
@param
fullPath
*
Excel文件完整地址("D:/workbook.xls")
*
@param
sheetName
*
工作簿名
*
@return
键值对：<RowKey,<ColumnName,
Value>>
*/
public
static
Map<String,
List<Map<String,
String>>>
GetRows(
String
fullPath,
String
sheetName)
{
Map<String,
List<Map<String,
String>>>
resultRow
=
new
HashMap<String,
List<Map<String,
String>>>();
List<Map<String,
String>>
resultCells;
Map<String,
String>
resultCell;
try
{
FileInputStream
file
=
new
FileInputStream(fullPath);
POIFSFileSystem
ts
=
new
POIFSFileSystem(file);
Workbook
workbook
=
new
HSSFWorkbook(ts);
Sheet
sheet
=
workbook.getSheet(sheetName);
int
rowCounts
=
sheet.getPhysicalNumberOfRows();//
行数
int
columnCounts
=
sheet.getRow(0).getPhysicalNumberOfCells();
//
列数
for
(int
i
=
1;
i
<
rowCounts;
i++)
{
Row
row
=
sheet.getRow(i);//
循环取第一行之后的每一行
row.getCell(0).setCellType(Cell.CELL_TYPE_STRING);
resultCells
=
new
ArrayList<Map<String,
String>>();
resultCell
=
new
HashMap<String,
String>();
String
rowKey
=
row.getCell(0).toString();
for
(int
j
=
1;
j
<
columnCounts;
j++)
{
Cell
cell
=
row.getCell(j);//
循环取第一列之后的每一列
if
(null
!=
cell)
{
cell.setCellType(Cell.CELL_TYPE_STRING);
String
columnName
=
sheet.getRow(0).getCell(j)
.toString();
String
cellValue
=
cell.toString();
resultCell.put(columnName,
cellValue);
}
}
resultCells.add(resultCell);
resultRow.put(rowKey,
resultCells);
}
file.close();
}
catch
(FileNotFoundException
e)
{
e.printStackTrace();
}
catch
(IOException
e)
{
e.printStackTrace();
}
return
resultRow;
}
}