搭建环境

配置maven依赖的架包

 tk.mybatismapper4.0.0-beta3junitjunit4.9log4jlog4j1.2.17cglibcglib2.2org.aspectjaspectjweaver1.6.8org.slf4jslf4j-api1.7.7org.slf4jslf4j-log4j121.7.7org.mybatismybatis3.2.8org.mybatismybatis-spring1.2.2com.mchangec3p00.9.2org.springframeworkspring-context4.3.10.RELEASEmysqlmysql-connector-java5.1.37org.springframeworkspring-orm4.3.10.RELEASE

Spring整合mybatis

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

Spring的配置文件

<?xml  version="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,myConsolelog4j.appender.myConsole=org.apache.log4j.ConsoleAppenderlog4j.appender.myConsole.ImmediateFlush=truelog4j.appender.myConsole.Target=System.outlog4j.appender.myConsole.layout=org.apache.log4j.PatternLayoutlog4j.appender.myConsole.layout.ConversionPattern=[%-5p] %d(%r) --> [%t] %l: %m %x %nlog4j.logger.com.mchange.v2=ERROR

数据库jdbc.properties配置文件

jdbc.user=rootjdbc.password=rootjdbc.url=jdbc:mysql://localhost:3306/girls?useUnicode=true&characterEncoding=utf8jdbc.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.11, null);

        //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.00, 23);

        //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", null, 23);

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

    }

    @Test    public void testUpdateByPrimaryKeySelective() {

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

        //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) OR (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);        }    }@Testpublic 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);        }    }}

当数据库为空时可以加个注解@Id

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;