ssm之九 批量导入excel到数据库

时间：2021-07-11 07:46:41

本案例承接以前的SSM整合系列，针对Oracle中的Dept表做操作，如果单击浏览，则进行批量导入；单击2则是单个导入。ssm之九 批量导入excel到数据库

<%@ page language="java" import="java.util.*" pageEncoding="UTF-8"%>
<%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core" %>
<%
String path = request.getContextPath();
String basePath = request.getScheme()+"://"+request.getServerName()+":"+request.getServerPort()+path+"/";
%>


<!DOCTYPE HTML PUBLIC "-//W3C//DTD HTML 4.01 Transitional//EN">
<html>
  <head>
    <base href="<%=basePath%>">
   
    <title>部门添加</title>
   
	<meta http-equiv="pragma" content="no-cache">
	<meta http-equiv="cache-control" content="no-cache">
	<meta http-equiv="expires" content="0">    
	<meta http-equiv="keywords" content="keyword1,keyword2,keyword3">
	<meta http-equiv="description" content="This is my page">
	<script type="text/javascript" src="easyui/jquery-1.8.3.min.js"></script>
	<!--
	<link rel="stylesheet" type="text/css" href="styles.css">
	-->
	<script type="text/javascript"><%--
	   function onload(){
		   var temp =  '${errormsg}';
		   if(temp!=''){
			    alert(temp);
		   }
		  
	   }
	--%>
	  $(function(){
		  $("#subbtn").click(function(){
			  var deptNo = $(".deptNo").val();
			  if($.trim(deptNo)==''){
				 // alert("部门编号不能为空！");
				  $("#spana").html("部门编号不能为空！");
				   return;
			  }else{
				  if(deptNo.length<2){
					    $("#spana").html("部门编号不能小于2位数！");
					    return;
				  }
			  }
			   var dName = $("#dName").val();
			  if(dName==''){
				 // alert("部门编号不能为空！");
				  $("#spana").html("部门名称不能为空！");
				   return;
			  }
			  var loc = $("#loc").val();
			  if(loc==''){
				 // alert("部门编号不能为空！");
				  $("#spana").html("部门位置不能为空！");
				   return;
			  }
			  $("#form1").submit();
		  });
	  });
	</script>


  </head>
  
  <body onload="onload()">
      <div align="center">部门添加  <c:if test="${errormsg}">1111</c:if> <span id="spana" style="color:#ff0000">${errormsg}</span>   </div>
      <form action="dept/deptImp" method="post" enctype="multipart/form-data">
      	  <div align="center">  <a href="jsp/deptinfo.xls">模板下载</a> <input type="file" name="mFile"><input type="submit" value="提交">   </div> 
      </form>
      <form action="dept/add" method="post" id="form1">
	      <table border="1" align="center" width="80%">
	      <tr align="center"><td>部门编号</td><td> <input type="text" name="deptNo" class="deptNo"> </td> </tr> 
		       <tr align="center"><td>部门名称</td><td> <input type="text" name="dName" id="dName"> </td> </tr> 
		       <tr align="center"><td>部门位置</td><td> <input type="text" name="loc" id="loc"> </td> </tr> 
		        <tr align="center"><td colspan="2"> <input  type="button" id="subbtn" value="提交"> </td></tr>
	      </table>
      </form>
  </body>
</html>
批量导入部门的控制器代码: 

package com.aaa.ssm.controller;

import java.io.IOException;
import java.io.InputStream;
import java.util.Enumeration;
import java.util.HashMap;
import java.util.List;
import java.util.Map;

import javax.servlet.http.HttpServletRequest;

import jxl.Cell;
import jxl.Sheet;
import jxl.Workbook;
import jxl.read.biff.BiffException;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.ui.Model;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.ResponseBody;
import org.springframework.web.multipart.MultipartFile;

import com.aaa.ssm.entity.Dept;
import com.aaa.ssm.service.IDeptService;
import com.aaa.ssm.util.PageData;
import com.aaa.ssm.util.PageUtil;

/**
 *@classname:DeptController.java
 *@discription:部门 控制器,负责与前后台及模型交互
 *
 *@author:zhz
 *@createtime:2017-4-13上午09:09:16
 *@version:1.0
 */
@Controller
@RequestMapping("/dept")
public class DeptController {
   
	@Autowired
	private IDeptService service;
	/**
	 * 部门列表方法
	 * @return
	 */
	@RequestMapping("/list")
	public String list(Model model,Integer pageNo,HttpServletRequest request){
		/*System.out.println("URI地址："+request.getRequestURI());
		Enumeration  pNames=request.getParameterNames();  
		 while(pNames.hasMoreElements()){  
		  String  name=(String)pNames.nextElement();
		  System.out.println("name:"+name+"="+request.getParameter(name));
		 }*/
		int pageSize=2;
		if(pageNo==null){
			pageNo=1;
		}
		Map map =new HashMap();
		map.put("start", (pageNo-1)*pageSize);
		map.put("end", pageNo*pageSize+1);
		PageData pageData = service.getList(map);
		int count = pageData.getCount();//总数量
		String pageString = new PageUtil(pageSize, pageNo, count, request).getPageString();
		model.addAttribute("deptList", pageData.getList());
		model.addAttribute("pageString", pageString);
		return "dept/list";
	}
	
	/**
	 * 批量导入部门信息
	 * @param mFile
	 * @return
	 * @throws IOException
	 * @throws BiffException 
	 */
	@RequestMapping("/deptImp")
	public String deptImport(@RequestParam MultipartFile mFile) throws IOException, BiffException{
		//获取文件流
		InputStream inputStream = mFile.getInputStream();
		//利用JAR提供的Workbook类读取文件
		Workbook workbook = Workbook.getWorkbook(inputStream);
		//获取工作薄
		Sheet sheet = workbook.getSheet(0);
		//获取总行数
		int rows = sheet.getRows();
		//获取总列数
		int cells = sheet.getColumns();
		//循环读取数据
		Dept dept = null;
		for(int i=1;i<rows;i++){
			dept = new Dept();
			Cell[] cell=sheet.getRow(i);
			dept.setDeptNo(Integer.valueOf(cell[0].getContents()));
			dept.setdName(cell[1].getContents());
			dept.setLoc(cell[2].getContents());
			service.add(dept);
			/*for(int j=0;j<cells;j++){
				System.out.println(cell[j].getContents());
			}*/
		}
		return "redirect:list";
	}
	/**
	 * 返回DeptJson
	 * @return
	 */
	@ResponseBody
	@RequestMapping("/deptJson")
	public Object deptJson(){
		Map map =new HashMap();
		map.put("start", 0);
		map.put("end", 100);
		PageData pageData = service.getList(map);
		int count = pageData.getCount();//总数量
		List<Dept> deptList = pageData.getList();
		Map mapJson =new HashMap();
		mapJson.put("total", count);
		mapJson.put("rows", deptList);
		return mapJson;
	}
	/**
	 * 跳转添加方法
	 * @return
	 */
	@RequestMapping("/toAdd")
	public String toAdd(){
		return "dept/add";
	}
	/**
	 * 添加方法
	 * @param dept
	 * @return
	 */
	@RequestMapping("/add")
	public String add(Dept dept,Model model){
		 try {
			service.add(dept);
			return "redirect:list";
		} catch (Exception e) {
			// TODO Auto-generated catch block
			e.printStackTrace();
			model.addAttribute("errormsg", "添加部门失败！");
			return "dept/add";
		}
	}
	
	/**
	 * 跳转部门更新
	 * @return
	 */
	@RequestMapping("/toUpdate")
	public String toUpdate(Model model,int deptNo){
		Dept dept =  service.getById(deptNo);
		model.addAttribute("dept", dept);
		return "dept/update";
	}
	
	/**
	 * 部门更新
	 * @param dept
	 * @return
	 */
	@RequestMapping("/update")
	public String update(Dept dept){
		service.update(dept);
		return "redirect:list";
	}
	
	/**
	 * 部门删除
	 * @return
	 */
	@RequestMapping("/del")
	public String delete(Integer deptNo){
		service.delete(deptNo);
		return "redirect:list";
	}
}

服务层Service的代码: 

package com.aaa.ssm.service;

import java.util.List;
import java.util.Map;

import com.aaa.ssm.entity.Dept;
import com.aaa.ssm.util.PageData;

/**
 *@classname:IDeptService.java
 *@discription:部门业务类接口
 *
 *@author:zhz
 *@createtime:2017-4-13上午09:06:39
 *@version:1.0
 */
public interface IDeptService {

	/**
	 * 根据部门编号获取部门对象
	 * @return
	 */
	public Dept getById(int deptNo);
	/**
	 * 部门列表
	 * @return
	 */
	public PageData getList(Map map);
	/**
	 * 部门添加
	 * @param dept
	 */
	public void add(Dept dept);
	/**
	 * 部门更新
	 * @param dept
	 */
	public void update(Dept dept);
	/**
	 * 部门删除
	 * @param deptNo
	 */
	public void delete(int deptNo);
	
}
服务层实现类和以前的一样： 

	/**
	 * 部门添加
	 */
	public void add(Dept dept) {
		// TODO Auto-generated method stub
			dao.add(dept);
		//	System.out.println(1/0);
	}

扩展篇，该段示例代码只能实现，批量导入dept表中的数据到数据库，如何实现批量如何多个表呢？

标签：

相关文章