如何将excel的数据导入hbase

Answer 1

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;}}