通用Mapper快速开发,搭建项目

不一样的菜鸟

共 2791字,需浏览 6分钟

 · 2021-01-28



搭建环境

配置maven依赖的架包

 
        
            tk.mybatis
            mapper
            4.0.0-beta3
        

        
            junit
            junit
            4.9
        

        
            log4j
            log4j
            1.2.17
        

        
            cglib
            cglib
            2.2
        

        
            org.aspectj
            aspectjweaver
            1.6.8
        

        
            org.slf4j
            slf4j-api
            1.7.7
        

        
            org.slf4j
            slf4j-log4j12
            1.7.7
        

        
            org.mybatis
            mybatis
            3.2.8
        

        
            org.mybatis
            mybatis-spring
            1.2.2
        

        
            com.mchange
            c3p0
            0.9.2
        

        
            org.springframework
            spring-context
            4.3.10.RELEASE
        

        
            mysql
            mysql-connector-java
            5.1.37
        

        
            org.springframework
            spring-orm
            4.3.10.RELEASE
        

    

Spring整合mybatis

"1.0" encoding="UTF-8"?>
"-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">



Spring的配置文件

"1.0" encoding="UTF-8"?>
"http://www.springframework.org/schema/beans"
 xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
 xmlns:aop="http://www.springframework.org/schema/aop"
 xmlns:context="http://www.springframework.org/schema/context"
 xmlns:tx="http://www.springframework.org/schema/tx"
 xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans.xsd
  http://www.springframework.org/schema/context http://www.springframework.org/schema/context/spring-context-4.3.xsd
  http://www.springframework.org/schema/aop http://www.springframework.org/schema/aop/spring-aop-4.3.xsd
  http://www.springframework.org/schema/tx http://www.springframework.org/schema/tx/spring-tx-4.3.xsd"
>
 
 "classpath:jdbc.properties"/>
 "dataSource" class="com.mchange.v2.c3p0.ComboPooledDataSource">
  "user" value="${jdbc.user}"/>
  "password" value="${jdbc.password}"/>
  "jdbcUrl" value="${jdbc.url}"/>
  "driverClass" value="${jdbc.driver}"/>
 

 
 "sqlSessionFactoryBean" class="org.mybatis.spring.SqlSessionFactoryBean">
  "configLocation" value="classpath:mybatis-config.xml"/>
  "dataSource" ref="dataSource"/>
 
 
 
 
 
 class="tk.mybatis.spring.mapper.MapperScannerConfigurer">
  "basePackage" value="com.yang.mapper.mappers"/>
 

 
 package="com.yang.mapper.services"/>

 
 "dataSourceTransactionManager" class="org.springframework.jdbc.datasource.DataSourceTransactionManager">
  "dataSource" ref="dataSource"/>
 
 
  "txAdvice" pointcut="execution(* *..*Service.*(..))"/>
 

 "txAdvice" transaction-manager="dataSourceTransactionManager">
  
   "get*" read-only="true"/>
   "save*" rollback-for="java.lang.Exception" propagation="REQUIRES_NEW"/>
   "remove*" rollback-for="java.lang.Exception" propagation="REQUIRES_NEW"/>
   "update*" rollback-for="java.lang.Exception" propagation="REQUIRES_NEW"/>
  

 

整合log4j.properties配置文件

log4j.rootLogger=DEBUG,myConsole
log4j.appender.myConsole=org.apache.log4j.ConsoleAppender
log4j.appender.myConsole.ImmediateFlush=true
log4j.appender.myConsole.Target=System.out
log4j.appender.myConsole.layout=org.apache.log4j.PatternLayout
log4j.appender.myConsole.layout.ConversionPattern=[%-5p] %d(%r) --> [%t] %l: %m %x %n
log4j.logger.com.mchange.v2=ERROR

数据库jdbc.properties配置文件

jdbc.user=root
jdbc.password=root
jdbc.url=jdbc:mysql://localhost:3306/girls?useUnicode=true&characterEncoding=utf8
jdbc.driver=com.mysql.jdbc.Driver

数据库表的设计

CREATE TABLE `tabple_emp` (
`emp_id` int NOT NULL AUTO_INCREMENT , 
`emp_name` varchar(500) NULL ,
`emp_salary` double(15,5) NULL ,
`emp_age` int NULL , PRIMARY KEY (`emp_id`) 
)
;
INSERT INTO `tabple_emp` (`emp_name`, `emp_salary`, `emp_age`) VALUES ('tom''1254.37''27');
INSERT INTO `tabple_emp` (`emp_name`, `emp_salary`, `emp_age`) VALUES ('jerry''6635.42''38'); 
INSERT INTO `tabple_emp` (`emp_name`, `emp_salary`, `emp_age`) VALUES ('bob''5560.11''40'); 
INSERT INTO `tabple_emp` (`emp_name`, `emp_salary`, `emp_age`) VALUES ('kate''2209.11''22');
INSERT INTO `tabple_emp` (`emp_name`, `emp_salary`, `emp_age`) VALUES ('justin''4203.15''30');

建立实体类

@Table(name = "tabple_emp")
public class Employee {
     //   @Transient当数据库里面没有某个字段的时候可以用此注解
    private Integer empId;
    //    当数据字段和实体类字段不一致时可以用该字段
    @Column(name = "emp_name")
    private String empName;
    private Double empSalary;
    private Integer empAge;
    get,set方法省略.......
    }

建立mapper的dao层

package com.yang.mapper.dao;

import com.yang.mapper.entity.Employee;
import tk.mybatis.mapper.common.Mapper;

/**
 * 继承Mapper<实体类
 *
 */

public interface EmployeeMapper extends Mapper<Employee{

}

简单的测试

package com.yang.mapper.services;

import com.yang.mapper.entity.Employee;
import org.apache.ibatis.session.RowBounds;
import org.junit.Test;
import org.springframework.context.ApplicationContext;
import org.springframework.context.support.ClassPathXmlApplicationContext;
import tk.mybatis.mapper.entity.Example;

import java.util.List;

import static org.junit.Assert.*;

public class EmployeeServiceTest {

    private ApplicationContext iocContainer = new ClassPathXmlApplicationContext("spring-context.xml");
    private EmployeeService employeeService = iocContainer.getBean(EmployeeService.class);

    @Test
    public void testSelectOne() {

        //1.创建封装查询条件的实体类对象
        Employee employeeQueryCondition = new Employee(null"bob"5560.11null);

        //2.执行查询
        Employee employeeQueryResult = employeeService.getOne(employeeQueryCondition);

        //3.打印
        System.out.println(employeeQueryResult);
    }
    @Test
    public void testSelectByPrimaryKey() {

        //1.提供id值
        Integer empId = 3;

        //2.执行根据主键进行的查询
        Employee employee = employeeService.getEmployeeById(empId);

        //3.打印结果
        System.out.println(employee);

    }

    @Test
    public void testExistsWithPrimaryKey() {

        //1.提供主键值
        Integer empId = 33;

        //2.执行查询
        boolean exists = employeeService.isExists(empId);

        //3.打印结果
        System.out.println(exists);

    }

    @Test
    public void testInsert() {

        //1.创建实体类对象封装要保存到数据库的数据
        Employee employee = new Employee(null"emp03"3000.0023);

        //2.执行插入操作
        employeeService.saveEmployee(employee);

        //3.获取employee对象的主键字段值
        Integer empId = employee.getEmpId();
        System.out.println("empId="+empId);

    }

    @Test
    public void testInsertSelective() {

        //1.创建实体类对象封装要保存到数据库的数据
        Employee employee = new Employee(null"emp04"null23);

        //2.执行插入操作
        employeeService.saveEmployeeSelective(employee);

    }

    @Test
    public void testUpdateByPrimaryKeySelective() {

        //1.创建用于测试的实体类
        Employee employee = new Employee(7"empNewName"nullnull);

        //2.执行更新
        employeeService.updateEmployeeSelective(employee);

    }

    @Test
    public void testDelete() {

        //1.声明实体类变量作为查询条件
        Employee employee = null;

        //2.执行删除
        employeeService.removeEmployee(employee);

    }

    @Test
    public void testDeleteByPrimaryKey() {

        //1.提供主键值
        Integer empId = 13;

        //2.执行删除
        employeeService.removeEmployeeById(empId);

    }

    @Test
    public void testSelectByExample() {

        //目标:WHERE (emp_salary>? AND emp_age?)
        //1.创建Example对象
        Example example = new Example(Employee.class);

        //***********************
        //i.设置排序信息
        example.orderBy("empSalary").asc().orderBy("empAge").desc();

        //ii.设置“去重”
        example.setDistinct(true);

        //iii.设置select字段
        example.selectProperties("empName","empSalary");

        //***********************

        //2.通过Example对象创建Criteria对象
        Example.Criteria criteria01 = example.createCriteria();
        Example.Criteria criteria02 = example.createCriteria();

        //3.在两个Criteria对象中分别设置查询条件
        //property参数:实体类的属性名
        //value参数:实体类的属性值
        criteria01.andGreaterThan("empSalary"3000)
                .andLessThan("empAge"25);

        criteria02.andLessThan("empSalary"5000)
                .andGreaterThan("empAge"30);

        //4.使用OR关键词组装两个Criteria对象
        example.or(criteria02);

        //5.执行查询
        List empList = employeeService.getEmpListByExample(example);

        for (Employee employee : empList) {
            System.out.println(employee);
        }
    }

    @Test
    public void testSelectByRowBounds() {

        int pageNo = 3;
        int pageSize = 5;

        int index = (pageNo - 1) * pageSize;

        RowBounds rowBounds = new RowBounds(index, pageSize);

        List empList = employeeService.getEmpListByRowBounds(rowBounds);
        for (Employee employee : empList) {
            System.out.println(employee);
        }

    }

}
e173ca99153aaa2d59141851502d75e9.webp

当数据库为空时可以加个注解@Id1303fa75d9a6881a40626838d280d3fd.webp

package com.yang.mapper.entity;


import javax.persistence.Column;
import javax.persistence.Id;
import javax.persistence.Table;
//指定数据库表名
@Table(name = "tabple_emp")
public class Employee {
    @Id
    @GeneratedValue(strategy = GenerationType.IDENTITY)
    private Integer empId;
    private Integer empId;
//    当数据字段和实体类字段不一致时可以用该字段
    @Column(name = "emp_name")
    private String empName;
    private Double empSalary;
    private Integer empAge;
90be5a377492578f82e1de20cf9be613.webp
浏览 42
点赞
评论
收藏
分享

手机扫一扫分享

举报
评论
图片
表情
推荐
点赞
评论
收藏
分享

手机扫一扫分享

举报