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

张哥编程

发布于 2024-12-17 10:37:15

3640

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

<%@ 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";
  }
}
/**
   * 批量导入部门信息
   * @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表中的数据到数据库，如何实现批量如何多个表呢？

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2022-03-09，如有侵权请联系 cloudcommunity@tencent.com 删除

excel

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

登录后参与评论

0 条评论

热度

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

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

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

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

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

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐

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

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