In my code i have read an excel sheet and passed the read parameter from excel sheet to method
@RestController
@RequestMapping("/api/v1")
public class ExcelController3 {
private MultipartFile uploadfile;
@Autowired
private EmployeeRepository employeeRepository;
@RequestMapping(value = "/upload3", method = RequestMethod.POST, consumes = javax.ws.rs.core.MediaType.MULTIPART_FORM_DATA)
public void uploadFileHandler(@RequestParam("name") String name,
@RequestParam("file") MultipartFile file) throws IOException {
this.uploadfile=file;
System.out.println("*****************************");
System.out.println("file.getOriginalFilename() " + file.getOriginalFilename());
System.out.println("file.getContentType()" + file.getContentType());
System.out.println("file.getInputStream() " + file.getInputStream());
System.out.println("file.toString() " + file.toString());
System.out.println("file.getSize() " + file.getSize());
System.out.println("name " + name);
System.out.println("file.getBytes() " + file.getBytes());
System.out.println("file.hashCode() " + file.hashCode());
System.out.println("file.getClass() " + file.getClass());
System.out.println("file.isEmpty() " + file.isEmpty());
try {
ExcelController ex=new ExcelController();
File f1=ex.convert(file);
// FileInputStream file = new FileInputStream(new File("E://Imp/Details.xlsx"));
XSSFWorkbook workbook = new XSSFWorkbook(f1);
XSSFSheet sheet = workbook.getSheetAt(0);
Iterator<Row> rowIterator = sheet.iterator();
rowIterator.next();
while(rowIterator.hasNext())
{
Row row = rowIterator.next();
//For each row, iterate through each columns
Iterator<Cell> cellIterator = row.cellIterator();
while(cellIterator.hasNext())
{
Cell cell = cellIterator.next();
//This will change all Cell Types to String
cell.setCellType(Cell.CELL_TYPE_STRING);
switch(cell.getCellType())
{
case Cell.CELL_TYPE_BOOLEAN:
System.out.println("boolean===>>>"+cell.getBooleanCellValue() + "\t");
break;
case Cell.CELL_TYPE_NUMERIC:
break;
case Cell.CELL_TYPE_STRING:
List list=new ArrayList();
list.add(cell.getStringCellValue());
break;
}
}
name=row.getCell(0).getStringCellValue();
String empid = row.getCell(1).getStringCellValue();
String add=row.getCell(2).getStringCellValue();
String mobile=row.getCell(3).getStringCellValue();
System.out.println(name+empid+add+mobile);
ExcelController3 ex1=new ExcelController3();
// ex1.InsertRowInDB(name,empid,add,mobile);
System.out.println("");
Employee em=new Employee();
em.setName(name);
em.setEmpid(empid);
em.setAddress(add);
em.setMobile(mobile);
System.out.println(em);
System.out.println(em.getAddress());
System.out.println(em.getEmpid());
System.out.println(em.getMobile());
System.out.println(em.getName());
ex1.InsertRowInDB(name,empid,add,mobile,em);
}
workbook.close();
} catch (FileNotFoundException e) {
e.printStackTrace();
} catch (IOException e) {
e.printStackTrace();
} catch (InvalidFormatException e) {
e.printStackTrace();
}
}
public void InsertRowInDB(String name,String empid,String add,String mobile,Employee em) {
// System.out.println("name "+name);
// System.out.println("empid "+empid);
// System.out.println("add "+add);
// System.out.println("mobile "+mobile);
// Employee em=new Employee();
//
// em.setName(name);
// em.setEmpid(empid);
// em.setAddress(add);
// em.setMobile(mobile);
// System.out.println(em);
// System.out.println(em.getAddress());
// System.out.println(em.getEmpid());
// System.out.println(em.getMobile());
// System.out.println(em.getName());
employeeRepository.save(em);
//employeeRepository.save(em);
// Statement stmt=db.con.createStatement();
// PreparedStatement ps=null;
// String sql="Insert into Employee(Name,EmployeeId,Address,ContactInfo) values(?,?,?,?)";
// ps=db.con.prepareStatement(sql);
// ps.setString(1, name);
// ps.setString(2, empid);
// ps.setString(3, add);
// ps.setString(4, mobile);
// ps.executeUpdate();
System.out.println("Values Inserted Successfully");
}
public File convert(MultipartFile file) throws IOException {
File convFile = new File(file.getOriginalFilename());
convFile.createNewFile();
FileOutputStream fos = new FileOutputStream(convFile);
fos.write(file.getBytes());
fos.close();
return convFile;
}
@GetMapping(value="/upload")
public ResponseEntity<Collection<Employee>> getallemployees(){
Collection<Employee> el =employeeRepository.findAll();
return new ResponseEntity<Collection<Employee>>(el, HttpStatus.OK);
}
}
But it gives me null pointer exception at employeeRepository.save(em); . unable to find out reason i have autowired employeeRepository also and created proper pojo class for jpa.