共享单车之数据存储--第2关:保存共享单车数据

package com.educoder.savedata;

import java.io.InputStream;

import java.text.DecimalFormat;

import java.util.ArrayList;

import java.util.Date;

import java.util.List;

import org.apache.commons.lang3.time.FastDateFormat;

import org.apache.hadoop.hbase.client.Put;

import org.apache.hadoop.hbase.util.Bytes;

import org.apache.poi.ss.usermodel.Cell;

import org.apache.poi.ss.usermodel.Row;

import org.apache.poi.ss.usermodel.Sheet;

import org.apache.poi.ss.usermodel.Workbook;

import org.apache.poi.ss.usermodel.WorkbookFactory;

import com.educoder.util.HBaseUtil;

public class SaveData {

    public static void SaveBicycleData()  throws Exception {

       HBaseUtil.createTable("t_shared_bicycle", "info"); 

       InputStream resourceAsStream = SaveData.class.getClassLoader().getResourceAsStream("dataResources.xls"); 

       Workbook workbook = WorkbookFactory.create(resourceAsStream); 

       Sheet sheet = workbook.getSheetAt(0); 

       int rows = sheet.getPhysicalNumberOfRows(); 

       List puts = new ArrayList(); 

       for (int n = 1; n < rows; n++) { 

        // 通过异常方式清除格式不准确、数据不存在的无效行

            try { 

                Row row = sheet.getRow(n); 

                // 唯一骑行id,当作行rowkey s

                DecimalFormat formatter1 = new DecimalFormat("########"); 

                String trip_id = formatter1.format(row.getCell(0).getNumericCellValue()); 

                Put put = new Put(Bytes.toBytes(trip_id)); 

                byte[] family = Bytes.toBytes("info"); 

                // 开始时间

                FastDateFormat instance = FastDateFormat.getInstance("MM/dd/yyyy HH:mm"); 

                String beginTimeValue = row.getCell(1).getStringCellValue(); 

                Date parse = instance.parse(beginTimeValue); 

                put.addColumn(family, Bytes.toBytes("beginTime"),Bytes.toBytes(String.valueOf(parse.getTime()))); 

                // 结束时间

                String endTimeValue = row.getCell(2).getStringCellValue();