springBoot集成Mybatis

缺乏、安全感 2022-04-13 14:43 380阅读 0赞

编辑工具：IDEA  
新建project:  
（1）**pom.xml文件引入依赖：**

<?xml version="1.0" encoding="UTF-8"?>
    <project xmlns="http://maven.apache.org/POM/4.0.0"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
        <modelVersion>4.0.0</modelVersion>
    
        <groupId>cn.ps</groupId>
        <artifactId>SPRINGNVCJSONREST</artifactId>
        <version>1.0-SNAPSHOT</version>
        <packaging>war</packaging>
    
        <parent>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-parent</artifactId>
            <version>2.0.6.RELEASE</version>
        </parent>
    
        <dependencies>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-web</artifactId>
            </dependency>
            <dependency>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-starter-data-jpa</artifactId>
            </dependency>
    
            <dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
            </dependency>
            <dependency>
                <groupId>com.alibaba</groupId>
                <artifactId>druid-spring-boot-starter</artifactId>
                <version>1.1.10</version>
            </dependency>
    
            <dependency>
                <groupId>commons-lang</groupId>
                <artifactId>commons-lang</artifactId>
                <version>2.2</version>
            </dependency>
            <dependency>
                <groupId>org.hibernate</groupId>
                <artifactId>hibernate-validator</artifactId>
                <version>5.3.4.Final</version>
            </dependency>
            <dependency>
                <groupId>org.mybatis.spring.boot</groupId>
                <artifactId>mybatis-spring-boot-starter</artifactId>
                <version>1.3.2</version>
            </dependency>
            <dependency>
                <groupId>com.github.pagehelper</groupId>
                <artifactId>pagehelper</artifactId>
                <version>4.1.6</version>
            </dependency>
    
        </dependencies>
    </project>

（2）resource文件夹新建application.properties文件：

//指定端口
    server.port=8089
    //指定mysql数据库
    spring.datasource.druid.url=jdbc:mysql://localhost:3306/factory
    spring.datasource.druid.username=root
    spring.datasource.druid.password=ps123456
    spring.datasource.druid.driver-class-name=com.mysql.jdbc.Driver
    //连接池
    spring.datasource.druid=com.alibaba.druid.pool.DruidDataSource  **

**（3）前端界面直接引入layui（放在webapp的resource下面）**  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjI0ODc2NA_size_16_color_FFFFFF_t_70]  
**（4）前端html页面代码（js和jquery）**

<!DOCTYPE html>
    <html lang="en">
    <head>
        <meta charset="UTF-8">
        <title>Title</title>
        <link rel="stylesheet" href="resource/layui/css/layui.css"/>
        <script src="resource/layui/layui.js"></script>
        
        <script src="https://cdn.staticfile.org/jquery/1.10.2/jquery.min.js">
        </script>
        <script type="text/javascript">
            layui.use('form',function () {
                var form=layui.form;
                form.on('submit(myForm)', function(data){
                  //  alert(JSON.stringify(data));
                    // alert(data.field.ename);
    
                    layui.table.reload('myEmpTable', {
                        url: 'emps'
                        ,where: data.field
                    });
                    return false;
                });
    
                //填写表单 提交数据
                form.on('submit(addForm)', function(data){
                   //alert(JSON.stringify(data.field));
                   $.ajax({
                       url:'emp',
                       dataType:'json',
                       data:data.field,
                       type:'post',
                       success:function (da) {
                           if(da.code==0){
                               alert("新增成功");
                               //关闭弹出页面
                               layer.close(addWindow);
                               //新增成功之后重新加载表格
                               layui.table.reload('myEmpTable', {
                                   url: 'emps'
                               });
                           }else{
                                alert(da.msg);
                           }
                       }
                   });
                    return false;
                });
    
               //修改
                form.on('submit(updateForm)', function(data){
                    data.field["_method"]="put";
                    $.ajax({
                        url:'emp/'+data.field.empno,
                        dataType:'json',
                        data:data.field,
                        type:'post',
                        success:function (da) {
                            if(da.code==0){
                                alert("修改成功")
                                layer.close(updateWindow);
                                layui.table.reload('myEmpTable',{
                                    url: 'emps'
                                });
                            }else{
                                alert(da.msg);
                            }
                        }
                    })
                    return false;
                });
    
            })
    
            layui.use('table', function(){
                var table = layui.table;
    
                //第一个实例
                table.render({
                    elem: '#myEmpTable'
                    ,height: 312
                    ,width:'100%'
                    ,url: 'emps' //数据接口
                    ,page: true //开启分页
                    ,cols: [[ //表头
                        {field: 'empno', title: '雇员编号', width:200, sort: true, fixed: 'left'}
                        ,{field: 'ename', title: '雇员名称', width:200}
                        ,{field: 'sal', title: '薪水', width:200, sort: true}
                        ,{field: 'job', title: '职位', width:200}
                        ,{field: 'email', title: '邮箱', width: 200}
                        ,{field: 'phone', title: '手机号码', width: 200, sort: true},
                        {field: 'pe', title: '操作', width: 200, sort: true,templet: function(d){
                            var str=JSON.stringify(d);
                                return "<button onclick='toDelete("+d.empno+")'>删除</button> " +
                                       "<button onclick=\"toUpdate()\"  data='"+str+"'>修改</button>";
    
                            }}
    
                    ]]
                });
    
            });
    
            var addWindow=null;
            //单击弹出框事件
            function toAdd() {
                layui.use('layer', function() {
                    addWindow=layer.open({
                        type: 1,
                        area: ['500px', '500px'],
                        content:$("#addForm")
                    });
                });
            }
            
            //删除点击事件
            function toDelete(empno) {
                $.ajax({
                    url:'emp/'+empno,
                    dataType:'json',
                    data:{
                        "_method":"delete"
                    },
                    type:'post',
                    success:function (da) {
                        if(da.code==0){
                            alert("删除成功");
                            //删除成功之后重新加载表格
                            layui.table.reload('myEmpTable', {
                                url: 'emps'
                            });
                        }else{
                            alert(da.msg);
                        }
                    }
                });
                return false;
            }
            //修改点击事件
            function toUpdate(str) {
    
               var source=JSON.parse(event.srcElement.getAttribute("data"));
                layui.use('layer', function() {
                    addWindow=layer.open({
                        type: 1,
                        area: ['500px', '500px'],
                        content:$("#updateForm")
                    });
                });
                layui.form.val("updateForm",source )
            }
    
        </script>
    
    </head>
    <body>
    
    <form class="layui-form" action="">
        <div class="layui-inline">
            <label class="layui-form-label">雇员名称</label>
            <div class="layui-input-inline" style="width: 300px;">
                <input type="text" name="ename" placeholder="请输入雇员名称" autocomplete="off" class="layui-input">
            </div>
            <div class="layui-input-inline" style="width: 300px;">
                <button class="layui-btn " lay-submit lay-filter="myForm">查询</button>
                <a href="javascript:toAdd()" class="layui-btn">新增</a>
            </div>
        </div>
    </form>
    
    <table id="myEmpTable" ></table>
    </body>
    </html>
    
    
    
    <form id="addForm" class="layui-form" style="display: none" > 
        <div class="layui-form-item">
            <label class="layui-form-label">雇员名字</label>
            <div class="layui-input-block" style="margin-right: 40px">
                <input type="text" name="ename" lay-verify="required" placeholder="请输入" autocomplete="off" class="layui-input">
            </div>
        </div>
        <div class="layui-form-item">
            <label class="layui-form-label">职位</label>
            <div class="layui-input-block" style="margin-right: 40px">
                <input type="text" name="job"  placeholder="请输入" autocomplete="off" class="layui-input">
            </div>
        </div>
        <div class="layui-form-item">
            <label class="layui-form-label">薪水</label>
            <div class="layui-input-block" style="margin-right: 40px">
                <input type="text" name="sal"  lay-verify="number" placeholder="请输入" autocomplete="off" class="layui-input">
            </div>
        </div>
        <div class="layui-form-item">
            <label class="layui-form-label">邮箱</label>
            <div class="layui-input-block" style="margin-right: 40px">
                <input type="text" name="email" lay-verify="email" placeholder="请输入" autocomplete="off" class="layui-input">
            </div>
        </div>
        <div class="layui-form-item">
            <label class="layui-form-label">电话</label>
            <div class="layui-input-block" style="margin-right: 40px">
                <input type="text" name="phone" lay-verify="phone" placeholder="请输入" autocomplete="off" class="layui-input">
            </div>
        </div>
    
        <div class="layui-form-item">
            <div class="layui-input-block">
                <button class="layui-btn" lay-submit lay-filter="addForm">立即提交</button>
                <button type="reset" class="layui-btn layui-btn-primary">重置</button>
            </div>
        </div>
    </form>
    
    
    
    <form id="updateForm" class="layui-form" lay-filter="updateForm" style="display: none" > 
        <input type="hidden" name="empno">
        <div class="layui-form-item">
            <label class="layui-form-label">雇员名字</label>
            <div class="layui-input-block" style="margin-right: 40px">
                <input type="text" name="ename" lay-verify="required" placeholder="请输入" autocomplete="off" class="layui-input">
            </div>
        </div>
        <div class="layui-form-item">
            <label class="layui-form-label">职位</label>
            <div class="layui-input-block" style="margin-right: 40px">
                <input type="text" name="job"  placeholder="请输入" autocomplete="off" class="layui-input">
            </div>
        </div>
        <div class="layui-form-item">
            <label class="layui-form-label">薪水</label>
            <div class="layui-input-block" style="margin-right: 40px">
                <input type="text" name="sal"  lay-verify="number" placeholder="请输入" autocomplete="off" class="layui-input">
            </div>
        </div>
        <div class="layui-form-item">
            <label class="layui-form-label">邮箱</label>
            <div class="layui-input-block" style="margin-right: 40px">
                <input type="text" name="email" lay-verify="email" placeholder="请输入" autocomplete="off" class="layui-input">
            </div>
        </div>
        <div class="layui-form-item">
            <label class="layui-form-label">电话</label>
            <div class="layui-input-block" style="margin-right: 40px">
                <input type="text" name="phone" lay-verify="phone" placeholder="请输入" autocomplete="off" class="layui-input">
            </div>
        </div>
    
        <div class="layui-form-item">
            <div class="layui-input-block">
                <button class="layui-btn" lay-submit lay-filter="updateForm">保存</button>
                <button type="reset" class="layui-btn layui-btn-primary">重置</button>
            </div>
        </div>
    
    </form>

**（5）配置mybatis的分页插件pageHelper**（ConfigPage）

package cn.ps.conf;
    
    import com.github.pagehelper.PageHelper;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    
    import java.util.Properties;
    
    @Configuration
    public class ConfigPage {
    
        //配置mybatis的分页插件pageHelper
        @Bean
        public PageHelper pageHelper(){
            PageHelper pageHelper = new PageHelper();
            Properties properties = new Properties();
    
            properties.setProperty("dialect","mysql");    //配置mysql数据库的方言
    
            //表示支持从接口中读取pageNum和pageSize
            properties.setProperty("supportMethodArgument","true");
            pageHelper.setProperties(properties);
            return pageHelper;
        }
        
    }

（6）控制层代码

package cn.ps.control;
    
    import cn.ps.entity.Result;
    import cn.ps.entity.Emp;
    import cn.ps.service.EmpService;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.*;
    import javax.validation.Valid;
    
    @RestController
    public class EmpController {
    	@Autowired
    	private EmpService service;
    
    	@GetMapping(value="emps")
    	public Result listEmp(String ename, String page, String limit) throws Exception {
    		try {
    			Result pb=service.queryEmp(ename, page, limit);
    			return pb;
    		} catch (Exception e) {
    			e.printStackTrace();
    		}
    		return  null;
    	}
    	
    	//新增
        @PostMapping(value="emp")
        public Result  saveEmp(@Valid  Emp emp) throws Exception {
         
            Result r=new Result();
            try{
                service.saveEmp(emp);
            }catch(Exception e){
                r.setCode(1);
                r.setMsg("新增出错："+e.getMessage());
            }
            return  r;
        }
    
        //修改
        @PutMapping(value="emp/{empno}")
        public Result  saveEmp(@PathVariable String empno , @Valid  Emp empErrors) throws Exception {
            //设入编号
            empErrors.setEmpno(empno);
            Result r=new Result();
            try{
                service.updateEmp(empErrors);
            }catch(Exception e){
                r.setCode(1);
                r.setMsg("修改出错："+e.getMessage());
            }
            return  r;
            
        }
    
        //删除
        @DeleteMapping(value="emp/{empno}")
        public Result  saveEmp(@PathVariable String empno) throws Exception {
    
            Result r=new Result();
            try{
                service.deleteEmp(empno);
            }catch(Exception e){
                r.setCode(1);
                r.setMsg("删除出错："+e.getMessage());
            }
            return  r;
    
        }
    
    }

（7）MepperInter接口类：

package cn.ps.EmpMepper;
    
    import cn.ps.entity.Emp;
    import org.apache.ibatis.annotations.*;
    import java.util.List;
    
    @Mapper
    public interface MepperInter {
    
        @Select("select * from mynewemp where ename like #{ename}")
        public List<Emp> queryEmp(@Param("ename") String ename,@Param("pageNum") int pageNum,  @Param("pageSize") int pageSize);
    
        @Insert("insert into mynewemp( ename,  sal,job,email,phone) values (#{ename},#{sal},#{job},#{email},#{phone})")
        public void saveEmp(Emp emp);
    
    
        @Delete("delete from mynewemp where empno=#{0}")
        public void deleteEmp(String empno);
    
        @Update("update mynewemp set ename=#{ename}, sal=#{sal}, job=#{job}, email=#{email},phone=#{phone} where empno=#{empno}")
        public void updateEmp(Emp empErrors);
    
    
    }

（8）表单实体类：（没有安装lombok插件）

package cn.ps.entity;
    
    import org.hibernate.validator.constraints.NotBlank;
    
    import javax.validation.constraints.DecimalMin;
    import javax.validation.constraints.Pattern;
    import javax.validation.constraints.Size;
    
    public class Emp {
    	
    	private String empno;
    
    	@NotBlank(message = "用户名不能为空")
    	private String ename;
    	private String deptno;
    
    	@NotBlank(message = "薪水不能为空")
    	@DecimalMin(value = "0",message = "薪水最小不能为0")
    	private String sal;
    	private String job;
    
    	@Pattern(regexp = ".+@.+\\..+",message = "邮箱格式错误")
    	private String email;
    	@Size(min = 11,max = 11,message = "输入的手机号必须为11位")
    	private String phone;
    
    	public String getEmail() {
    		return email;
    	}
    
    	public void setEmail(String email) {
    		this.email = email;
    	}
    	public String getPhone() {
    		return phone;
    	}
    	public void setPhone(String phone) {
    		this.phone = phone;
    	}
    	public String getEmpno() {
    		return empno;
    	}
    	public void setEmpno(String empno) {
    		this.empno = empno;
    	}
    	public String getEname() {
    		return ename;
    	}
    	public void setEname(String ename) {
    		this.ename = ename;
    	}
    	public String getDeptno() {
    		return deptno;
    	}
    	public void setDeptno(String deptno) {
    		this.deptno = deptno;
    	}
    	public String getSal() {
    		return sal;
    	}
    	public void setSal(String sal) {
    		this.sal = sal;
    	}
    	public String getJob() {
    		return job;
    	}
    	public void setJob(String job) {
    		this.job = job;
    	}
    	
    }

（9）Result类：

package cn.ps.entity;
    
    import java.util.List;
    
    
    
    public class Result {
        private int code;
        private String msg;
        private int count;
        private List data;
    
        public int getCode() {
            return code;
        }
    
        public void setCode(int code) {
            this.code = code;
        }
    
        public String getMsg() {
            return msg;
        }
    
        public void setMsg(String msg) {
            this.msg = msg;
        }
    
        public int getCount() {
            return count;
        }
    
        public void setCount(int count) {
            this.count = count;
        }
    
        public List getData() {
            return data;
        }
    
        public void setData(List data) {
            this.data = data;
        }
    }

（10）Empservice实现类：

package cn.ps.service.impl;
    
    import cn.ps.EmpMepper.MepperInter;
    import cn.ps.entity.Emp;
    import cn.ps.service.EmpService;
    import cn.ps.entity.Result;
    import com.github.pagehelper.PageInfo;
    import org.apache.commons.lang.StringUtils;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.stereotype.Service;
    import java.util.List;
    
    @Service
    public class EmpServiceImpl implements EmpService{
    	@Autowired
    	private MepperInter dao;
    
    	public Result queryEmp(String ename, String curPage, String pageNum) throws Exception {
    		//如果第一次没有访问当前页
    		if(StringUtils.isEmpty(curPage)) {
    			curPage="1";
    		}
    		if(StringUtils.isEmpty(pageNum)) {
    			pageNum="10";
    		}
    		
    		//转换为int类型
    		int curPageIn =Integer.parseInt(curPage);
    		int pageNumIn= Integer.parseInt(pageNum);
    
    		if(StringUtils.isEmpty(ename)){
    			ename="%%";
    		}
    
    		List<Emp> emps = dao.queryEmp(ename, curPageIn, pageNumIn);
    
    		PageInfo pi=new PageInfo(emps);
    
    		Result r=new Result();
    		r.setCode(0);
    		r.setCount((int)pi.getTotal());
    		r.setData(emps);
    		return r;
    	}
    
    	public void saveEmp(Emp emp) {
    		dao.saveEmp(emp);
    	}
    
    	public void deleteEmp(String empno) {
    		dao.deleteEmp(empno);
    	}
    
    	public void updateEmp(Emp empErrors) {
    		dao.updateEmp(empErrors);
    	}
    
    
    }

（11）PageBean分页属性类：

package cn.ps.util;
    
    import java.util.List;
    
    /**
     * 分页的帮助类
     * @author 摸摸大白兔
     *时间 2017年10月20日 下午2:14:26
     *
     */
    public class PageBean<T> {
    	
    	public void calc() {
    	
    	}
    	
    	/**
    	 * 构造方法
    	 * @param curPage当前页
    	 * @param pageNum每页显示的条数
    	 * @param total总条数
    	 */
    	
    	public PageBean(int curPage,int pageNum,int total) {
    		//计算上一页
    		this.prePage = curPage==1?1:curPage-1;
    		//计算总页数
    		this.totalPage=total%pageNum==0?total/pageNum:total/pageNum+1;
    		//下一页
    		this.nextPage=curPage==totalPage?totalPage:curPage+1;
    		//当前页数的下标
    		this.startIndex=(curPage-1)*pageNum;
    		
    		this.total=total;
    		this.curPage=curPage;
    		this.pageNum=pageNum;
    		
    	}
    	
    	/**
    	 * 当前查询的默认当前页=1；
    	 * （页面传递参数）
    	 */
    	private int curPage;
    	
    	/**
    	 * 每一页的数据条数默认10条
    	 * 页面传递的参数
    	 */
    	private int pageNum=10;
    	
    	/**
    	 * 上一页
    	 *根据当前页判断
    	 *curPage=1  prePage=1;
    	 *curPage>1  prePage=curPage-1;
    	 */
    	private int prePage;
    	
    	/**
    	 * 下一页
    	 * curPage=totalpage nextPage=totalpage;
    	 * curPage<totalpage nextPage=curPage+1;
    	 */
    	private int nextPage;
    
    	/**
    	 * 总共多少页数(若总条数除以每页条数有余数则页数+1)
    	 * 总条数total/每一页条数pageNum
    	 * total%pageNum==0?total/pageNum:total/pageNum+1;
    	 */
    	private int totalPage;
    	
    	/**
    	 * 总共多少条
    	 * 数据库查询
    	 */
    	private int total;
    	
    	private List<T> data;
    	
    	/**
    	 * 开始的索引
    	 * startIndex = (curPage-1)*pageNum
    	 */
    	private int startIndex;
    	
    
    	public int getCurPage() {
    		return curPage;
    	}
    
    	public int getStartIndex() {
    		return startIndex;
    	}
    
    	public void setStartIndex(int startIndex) {
    		this.startIndex = startIndex;
    	}
    	public void setCurPage(int curPage) {
    		this.curPage = curPage;
    	}
    
    	public int getPageNum() {
    		return pageNum;
    	}
    	public void setPageNum(int pageNum) {
    		this.pageNum = pageNum;
    	}
    	public int getPrePage() {
    		return prePage;
    	}
    	public void setPrePage(int prePage) {
    		this.prePage = prePage;
    	}
    	public int getNextPage() {
    		return nextPage;
    	}
    	public void setNextPage(int nextPage) {
    		this.nextPage = nextPage;
    	}
    	public int getTotalPage() {
    		return totalPage;
    	}
    
    	public void setTotalPage(int totalPage) {
    		this.totalPage = totalPage;
    	}
    
    	public int getTotal() {
    		return total;
    	}
    
    	public void setTotal(int total) {
    		this.total = total;
    	}
    
    	public List<T> getData() {
    		return data;
    	}
    
    	public void setData(List<T> data) {
    		this.data = data;
    	}
    	
    }

**(12)程序运行main方法运行入口：**

package cn.ps;
    
    import org.springframework.boot.SpringApplication;
    import org.springframework.boot.autoconfigure.SpringBootApplication;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    
    @RestController
    @SpringBootApplication
    public class EmpMainDemo {
    
        @GetMapping("/")
        String home() {
            return "Hello World!";
        }
    
        public static void main(String[] args) throws Exception {
            SpringApplication.run(EmpMainDemo.class, args);
        }
    
    }

最后的运行效果：  
![在这里插入图片描述][watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjI0ODc2NA_size_16_color_FFFFFF_t_70 1]  
**这只是主要流程，结果仅供参考！！！**

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjI0ODc2NA_size_16_color_FFFFFF_t_70]: /images/20220413/4a921fb0086944ad91ff575b52e1e1c7.png
[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3dlaXhpbl80MjI0ODc2NA_size_16_color_FFFFFF_t_70 1]: /images/20220413/38777ede0df6405cb5b35e032dd9ab58.png