Mybatis应用简介 / 憋错料

第一章 MyBatis概述：

一、Mybatis介绍

　　MyBatis是一个支持普通SQL查询，存储过程和高级映射的优秀持久层框架。MyBatis消除了几乎所有的JDBC代码和参数的手工设置以及对结果集的检索封装。MyBatis可以使用简单的XML或注解用于配置和原始映射，将接口和Java的POJO（Plain Old Java Objects，普通的Java对象）映射成数据库中的记录。

二、mybatis快速入门

2.1、准备开发环境

1、创建测试项目，普通java项目或者是JavaWeb项目均可，如下图所示：

2、添加相应的jar包

　　【mybatis】

　　mybatis-3.1.1.jar

　　【MYSQL驱动包】
　　　　mysql-connector-java-5.1.7-bin.jar

3、创建数据库和表，针对MySQL数据库

　　SQL脚本如下：

1 create database mybatis;

2 use mybatis;

3 CREATE TABLE users(id INT PRIMARY KEY AUTO_INCREMENT, NAME VARCHAR(20), age INT);

4 INSERT INTO users(NAME, age) VALUES(‘孤傲苍狼‘, 27);

5 INSERT INTO users(NAME, age) VALUES(‘白虎神皇‘, 27);

　　将SQL脚本在MySQL数据库中执行，完成创建数据库和表的操作，如下：

　　到此，前期的开发环境准备工作全部完成。

2.2、使用MyBatis查询表中的数据

　　1、添加Mybatis的配置文件conf.xml

　　在src目录下创建一个conf.xml文件，如下图所示：

　　conf.xml文件中的内容如下：

1 <?xml version="1.0" encoding="UTF-8"?>

2 <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">

3 <configuration>

4 <environments default="development">

5 <environment id="development">

6 <transactionManager type="JDBC" />

7

8 <dataSource type="POOLED">

9 <property name="driver" value="com.mysql.jdbc.Driver" />

10 <property name="url" value="jdbc:mysql://localhost:3306/mybatis" />

11 <property name="username" value="root" />

12 <property name="password" value="XDP" />

13 </dataSource>

14 </environment>

15 </environments>

17 </configuration>

　　2、定义表所对应的实体类，如下图所示：

　　User类的代码如下：

1 package me.gacl.domain;

3 /**

4 * @author gacl

5 * users表所对应的实体类

6 */

7 public class User {

9 //实体类的属性和表的字段名称一一对应

10 private int id;

11 private String name;

12 private int age;

14 public int getId() {

15 return id;

16 }

18 public void setId(int id) {

19 this.id = id;

20 }

22 public String getName() {

23 return name;

24 }

26 public void setName(String name) {

27 this.name = name;

28 }

30 public int getAge() {

31 return age;

32 }

34 public void setAge(int age) {

35 this.age = age;

36 }

38 @Override

39 public String toString() {

40 return "User [id=" + id + ", name=" + name + ", age=" + age + "]";

41 }

42 }

　　3、定义操作users表的sql映射文件userMapper.xml

　　创建一个me.gacl.mapping包，专门用于存放sql映射文件，在包中创建一个userMapper.xml文件，如下图所示：

　　userMapper.xml文件的内容如下：

1 <?xml version="1.0" encoding="UTF-8" ?>

2 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

3 <!-- 为这个mapper指定一个唯一的namespace，namespace的值习惯上设置成包名+sql映射文件名，这样就能够保证namespace的值是唯一的

4 例如namespace="me.gacl.mapping.userMapper"就是me.gacl.mapping(包名)+userMapper(userMapper.xml文件去除后缀)

5 -->

6 <mapper namespace="me.gacl.mapping.userMapper">

7 <!-- 在select标签中编写查询的SQL语句，设置select标签的id属性为getUser，id属性值必须是唯一的，不能够重复

8 使用parameterType属性指明查询时使用的参数类型，resultType属性指明查询返回的结果集类型

9 resultType="me.gacl.domain.User"就表示将查询结果封装成一个User类的对象返回

10 User类就是users表所对应的实体类

11 -->

12 <!--

13 根据id查询得到一个user对象

14 -->

15 <select id="getUser" parameterType="int"

16 resultType="me.gacl.domain.User">

17 select * from users where id=#{id}

18 </select>

19 </mapper>

　　4、在conf.xml文件中注册userMapper.xml文件

1 <?xml version="1.0" encoding="UTF-8"?>

2 <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">

3 <configuration>

4 <environments default="development">

5 <environment id="development">

6 <transactionManager type="JDBC" />

7

8 <dataSource type="POOLED">

9 <property name="driver" value="com.mysql.jdbc.Driver" />

10 <property name="url" value="jdbc:mysql://localhost:3306/mybatis" />

11 <property name="username" value="root" />

12 <property name="password" value="XDP" />

13 </dataSource>

14 </environment>

15 </environments>

17 <mappers>

18 <!-- 注册userMapper.xml文件，

19 userMapper.xml位于me.gacl.mapping这个包下，所以resource写成me/gacl/mapping/userMapper.xml-->

20 <mapper resource="me/gacl/mapping/userMapper.xml"/>

21 </mappers>

23 </configuration>

　　5、编写测试代码：执行定义的select语句

　　创建一个Test1类，编写如下的测试代码：

package me.gacl.test;

import java.io.IOException;

import java.io.InputStream;

import java.io.Reader;

import me.gacl.domain.User;

import org.apache.ibatis.io.Resources;

import org.apache.ibatis.session.SqlSession;

import org.apache.ibatis.session.SqlSessionFactory;

import org.apache.ibatis.session.SqlSessionFactoryBuilder;

public class Test1 {

public static void main(String[] args) throws IOException {

//mybatis的配置文件

String resource = "conf.xml";

//使用类加载器加载mybatis的配置文件（它也加载关联的映射文件）

InputStream is = Test1.class.getClassLoader().getResourceAsStream(resource);

//构建sqlSession的工厂

SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(is);

//使用MyBatis提供的Resources类加载mybatis的配置文件（它也加载关联的映射文件）

//Reader reader = Resources.getResourceAsReader(resource);

//构建sqlSession的工厂

//SqlSessionFactory sessionFactory = new SqlSessionFactoryBuilder().build(reader);

//创建能执行映射文件中sql的sqlSession

SqlSession session = sessionFactory.openSession();

/**

* 映射sql的标识字符串，

* me.gacl.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，

* getUser是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL

String statement = "me.gacl.mapping.userMapper.getUser";//映射sql的标识字符串

//执行查询返回一个唯一user对象的sql

User user = session.selectOne(statement, 1);

System.out.println(user);

}

　　执行结果如下：

　　可以看到，数据库中的记录已经成功查询出来了。

第二章 使用MyBatis对表执行CRUD操作

我们讲了如何使用Mybatis查询users表中的数据，算是对MyBatis有一个初步的入门了，今天讲解一下如何使用MyBatis对users表执行CRUD操作。本文中使用到的测试环境是上一篇博文中的测试环境。

一、使用MyBatis对表执行CRUD操作——基于XML的实现

1、定义sql映射xml文件

　　userMapper.xml文件的内容如下：

1 <?xml version="1.0" encoding="UTF-8" ?>

2 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

3 <!-- 为这个mapper指定一个唯一的namespace，namespace的值习惯上设置成包名+sql映射文件名，这样就能够保证namespace的值是唯一的

4 例如namespace="me.gacl.mapping.userMapper"就是me.gacl.mapping(包名)+userMapper(userMapper.xml文件去除后缀)

5 -->

6 <mapper namespace="me.gacl.mapping.userMapper">

7 <!-- 在select标签中编写查询的SQL语句，设置select标签的id属性为getUser，id属性值必须是唯一的，不能够重复

8 使用parameterType属性指明查询时使用的参数类型，resultType属性指明查询返回的结果集类型

9 resultType="me.gacl.domain.User"就表示将查询结果封装成一个User类的对象返回

10 User类就是users表所对应的实体类

11 -->

12 <!--

13 根据id查询得到一个user对象

14 -->

15 <select id="getUser" parameterType="int"

16 resultType="me.gacl.domain.User">

17 select * from users where id=#{id}

18 </select>

20

21 <insert id="addUser" parameterType="me.gacl.domain.User">

22 insert into users(name,age) values(#{name},#{age})

23 </insert>

25

26 <delete id="deleteUser" parameterType="int">

27 delete from users where id=#{id}

28 </delete>

30

31 <update id="updateUser" parameterType="me.gacl.domain.User">

32 update users set name=#{name},age=#{age} where id=#{id}

33 </update>

35

36 <select id="getAllUsers" resultType="me.gacl.domain.User">

37 select * from users

38 </select>

40 </mapper>

　　单元测试类代码如下：

1 package me.gacl.test;

3 import java.util.List;

4 import me.gacl.domain.User;

5 import me.gacl.util.MyBatisUtil;

6 import org.apache.ibatis.session.SqlSession;

7 import org.junit.Test;

9 public class TestCRUDByXmlMapper {

11 @Test

12 public void testAdd(){

13 //SqlSession sqlSession = MyBatisUtil.getSqlSession(false);

14 SqlSession sqlSession = MyBatisUtil.getSqlSession(true);

15 /**

16 * 映射sql的标识字符串，

17 * me.gacl.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，

18 * addUser是insert标签的id属性值，通过insert标签的id属性值就可以找到要执行的SQL

19 */

20 String statement = "me.gacl.mapping.userMapper.addUser";//映射sql的标识字符串

21 User user = new User();

22 user.setName("用户孤傲苍狼");

23 user.setAge(20);

24 //执行插入操作

25 int retResult = sqlSession.insert(statement,user);

26 //手动提交事务

27 //sqlSession.commit();

28 //使用SqlSession执行完SQL之后需要关闭SqlSession

29 sqlSession.close();

30 System.out.println(retResult);

31 }

33 @Test

34 public void testUpdate(){

35 SqlSession sqlSession = MyBatisUtil.getSqlSession(true);

36 /**

37 * 映射sql的标识字符串，

38 * me.gacl.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，

39 * updateUser是update标签的id属性值，通过update标签的id属性值就可以找到要执行的SQL

40 */

41 String statement = "me.gacl.mapping.userMapper.updateUser";//映射sql的标识字符串

42 User user = new User();

43 user.setId(3);

44 user.setName("孤傲苍狼");

45 user.setAge(25);

46 //执行修改操作

47 int retResult = sqlSession.update(statement,user);

48 //使用SqlSession执行完SQL之后需要关闭SqlSession

49 sqlSession.close();

50 System.out.println(retResult);

51 }

53 @Test

54 public void testDelete(){

55 SqlSession sqlSession = MyBatisUtil.getSqlSession(true);

56 /**

57 * 映射sql的标识字符串，

58 * me.gacl.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，

59 * deleteUser是delete标签的id属性值，通过delete标签的id属性值就可以找到要执行的SQL

60 */

61 String statement = "me.gacl.mapping.userMapper.deleteUser";//映射sql的标识字符串

62 //执行删除操作

63 int retResult = sqlSession.delete(statement,5);

64 //使用SqlSession执行完SQL之后需要关闭SqlSession

65 sqlSession.close();

66 System.out.println(retResult);

67 }

69 @Test

70 public void testGetAll(){

71 SqlSession sqlSession = MyBatisUtil.getSqlSession();

72 /**

73 * 映射sql的标识字符串，

74 * me.gacl.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，

75 * getAllUsers是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL

76 */

77 String statement = "me.gacl.mapping.userMapper.getAllUsers";//映射sql的标识字符串

78 //执行查询操作，将查询结果自动封装成List<User>返回

79 List<User> lstUsers = sqlSession.selectList(statement);

80 //使用SqlSession执行完SQL之后需要关闭SqlSession

81 sqlSession.close();

82 System.out.println(lstUsers);

83 }

84 }

二、使用MyBatis对表执行CRUD操作——基于注解的实现

　　1、定义sql映射的接口

　　UserMapperI接口的代码如下：

1 package me.gacl.mapping;

3 import java.util.List;

4 import me.gacl.domain.User;

5 import org.apache.ibatis.annotations.Delete;

6 import org.apache.ibatis.annotations.Insert;

7 import org.apache.ibatis.annotations.Select;

8 import org.apache.ibatis.annotations.Update;

10 /**

11 * @author gacl

12 * 定义sql映射的接口，使用注解指明方法要执行的SQL

13 */

14 public interface UserMapperI {

16 //使用@Insert注解指明add方法要执行的SQL

17 @Insert("insert into users(name, age) values(#{name}, #{age})")

18 public int add(User user);

20 //使用@Delete注解指明deleteById方法要执行的SQL

21 @Delete("delete from users where id=#{id}")

22 public int deleteById(int id);

24 //使用@Update注解指明update方法要执行的SQL

25 @Update("update users set name=#{name},age=#{age} where id=#{id}")

26 public int update(User user);

28 //使用@Select注解指明getById方法要执行的SQL

29 @Select("select * from users where id=#{id}")

30 public User getById(int id);

32 //使用@Select注解指明getAll方法要执行的SQL

33 @Select("select * from users")

34 public List<User> getAll();

35 }

　　需要说明的是，我们不需要针对UserMapperI接口去编写具体的实现类代码，这个具体的实现类由MyBatis帮我们动态构建出来，我们只需要直接拿来使用即可。

　　2、在conf.xml文件中注册这个映射接口

1 <?xml version="1.0" encoding="UTF-8"?>

2 <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">

3 <configuration>

4 <environments default="development">

5 <environment id="development">

6 <transactionManager type="JDBC" />

7

8 <dataSource type="POOLED">

9 <property name="driver" value="com.mysql.jdbc.Driver" />

10 <property name="url" value="jdbc:mysql://localhost:3306/mybatis" />

11 <property name="username" value="root" />

12 <property name="password" value="XDP" />

13 </dataSource>

14 </environment>

15 </environments>

17 <mappers>

18 <!-- 注册userMapper.xml文件，

19 userMapper.xml位于me.gacl.mapping这个包下，所以resource写成me/gacl/mapping/userMapper.xml-->

20 <mapper resource="me/gacl/mapping/userMapper.xml"/>

21

22 <mapper class="me.gacl.mapping.UserMapperI"/>

23 </mappers>

25 </configuration>

　　单元测试类的代码如下：

1 package me.gacl.test;

3 import java.util.List;

4 import me.gacl.domain.User;

5 import me.gacl.mapping.UserMapperI;

6 import me.gacl.util.MyBatisUtil;

7 import org.apache.ibatis.session.SqlSession;

8 import org.junit.Test;

10 public class TestCRUDByAnnotationMapper {

12 @Test

13 public void testAdd(){

14 SqlSession sqlSession = MyBatisUtil.getSqlSession(true);

15 //得到UserMapperI接口的实现类对象，UserMapperI接口的实现类对象由sqlSession.getMapper(UserMapperI.class)动态构建出来

16 UserMapperI mapper = sqlSession.getMapper(UserMapperI.class);

17 User user = new User();

18 user.setName("用户xdp");

19 user.setAge(20);

20 int add = mapper.add(user);

21 //使用SqlSession执行完SQL之后需要关闭SqlSession

22 sqlSession.close();

23 System.out.println(add);

24 }

26 @Test

27 public void testUpdate(){

28 SqlSession sqlSession = MyBatisUtil.getSqlSession(true);

29 //得到UserMapperI接口的实现类对象，UserMapperI接口的实现类对象由sqlSession.getMapper(UserMapperI.class)动态构建出来

30 UserMapperI mapper = sqlSession.getMapper(UserMapperI.class);

31 User user = new User();

32 user.setId(3);

33 user.setName("孤傲苍狼_xdp");

34 user.setAge(26);

35 //执行修改操作

36 int retResult = mapper.update(user);

37 //使用SqlSession执行完SQL之后需要关闭SqlSession

38 sqlSession.close();

39 System.out.println(retResult);

40 }

42 @Test

43 public void testDelete(){

44 SqlSession sqlSession = MyBatisUtil.getSqlSession(true);

45 //得到UserMapperI接口的实现类对象，UserMapperI接口的实现类对象由sqlSession.getMapper(UserMapperI.class)动态构建出来

46 UserMapperI mapper = sqlSession.getMapper(UserMapperI.class);

47 //执行删除操作

48 int retResult = mapper.deleteById(7);

49 //使用SqlSession执行完SQL之后需要关闭SqlSession

50 sqlSession.close();

51 System.out.println(retResult);

52 }

54 @Test

55 public void testGetUser(){

56 SqlSession sqlSession = MyBatisUtil.getSqlSession();

57 //得到UserMapperI接口的实现类对象，UserMapperI接口的实现类对象由sqlSession.getMapper(UserMapperI.class)动态构建出来

58 UserMapperI mapper = sqlSession.getMapper(UserMapperI.class);

59 //执行查询操作，将查询结果自动封装成User返回

60 User user = mapper.getById(8);

61 //使用SqlSession执行完SQL之后需要关闭SqlSession

62 sqlSession.close();

63 System.out.println(user);

64 }

66 @Test

67 public void testGetAll(){

68 SqlSession sqlSession = MyBatisUtil.getSqlSession();

69 //得到UserMapperI接口的实现类对象，UserMapperI接口的实现类对象由sqlSession.getMapper(UserMapperI.class)动态构建出来

70 UserMapperI mapper = sqlSession.getMapper(UserMapperI.class);

71 //执行查询操作，将查询结果自动封装成List<User>返回

72 List<User> lstUsers = mapper.getAll();

73 //使用SqlSession执行完SQL之后需要关闭SqlSession

74 sqlSession.close();

75 System.out.println(lstUsers);

76 }

77 }

　　用到的MyBatisUtil工具类代码如下：

1 package me.gacl.util;

3 import java.io.InputStream;

5 import org.apache.ibatis.session.SqlSession;

6 import org.apache.ibatis.session.SqlSessionFactory;

7 import org.apache.ibatis.session.SqlSessionFactoryBuilder;

9 public class MyBatisUtil {

11 /**

12 * 获取SqlSessionFactory

13 * @return SqlSessionFactory

14 */

15 public static SqlSessionFactory getSqlSessionFactory() {

16 String resource = "conf.xml";

17 InputStream is = MyBatisUtil.class.getClassLoader().getResourceAsStream(resource);

18 SqlSessionFactory factory = new SqlSessionFactoryBuilder().build(is);

19 return factory;

20 }

22 /**

23 * 获取SqlSession

24 * @return SqlSession

25 */

26 public static SqlSession getSqlSession() {

27 return getSqlSessionFactory().openSession();

28 }

30 /**

31 * 获取SqlSession

32 * @param isAutoCommit

33 * true 表示创建的SqlSession对象在执行完SQL之后会自动提交事务

34 * false 表示创建的SqlSession对象在执行完SQL之后不会自动提交事务，这时就需要我们手动调用sqlSession.commit()提交事务

35 * @return SqlSession

36 */

37 public static SqlSession getSqlSession(boolean isAutoCommit) {

38 return getSqlSessionFactory().openSession(isAutoCommit);

39 }

40 }

　　以上的相关代码是全部测试通过的，关于使用MyBatis对表执行CRUD操作的内容就这么多。

第三章 优化MyBatis配置文件中的配置

一、连接数据库的配置单独放在一个properties文件中

　　之前，我们是直接将数据库的连接配置信息写在了MyBatis的conf.xml文件中，如下：

1 <?xml version="1.0" encoding="UTF-8"?>

2 <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">

3 <configuration>

4 <environments default="development">

5 <environment id="development">

6 <transactionManager type="JDBC" />

7

8 <dataSource type="POOLED">

9 <property name="driver" value="com.mysql.jdbc.Driver" />

10 <property name="url" value="jdbc:mysql://localhost:3306/mybatis" />

11 <property name="username" value="root" />

12 <property name="password" value="XDP" />

13 </dataSource>

14 </environment>

15 </environments>

17 </configuration>

　　其实我们完全可以将数据库的连接配置信息写在一个properties文件中，然后在conf.xml文件中引用properties文件，具体做法如下：

　　1、在src目录下新建一个db.properties文件，如下图所示：

　　在db.properties文件编写连接数据库需要使用到的数据库驱动，连接URL地址，用户名，密码，如下：

1 driver=com.mysql.jdbc.Driver

2 url=jdbc:mysql://localhost:3306/mybatis

3 name=root

4 password=XDP

　　2、在MyBatis的conf.xml文件中引用db.properties文件，如下：

1 <?xml version="1.0" encoding="UTF-8"?>

2 <!DOCTYPE configuration PUBLIC "-//mybatis.org//DTD Config 3.0//EN" "http://mybatis.org/dtd/mybatis-3-config.dtd">

3 <configuration>

5

6 <properties resource="db.properties"/>

7 <!--

8 development : 开发模式

9 work : 工作模式

10 -->

11 <environments default="development">

12 <environment id="development">

13 <transactionManager type="JDBC" />

14

15 <dataSource type="POOLED">

16

17 <property name="driver" value="${driver}" />

18 <property name="url" value="${url}" />

19 <property name="username" value="${name}" />

20 <property name="password" value="${password}" />

21 </dataSource>

22 </environment>

23 </environments>

25 </configuration>

二、为实体类定义别名，简化sql映射xml文件中的引用

　　之前，我们在sql映射xml文件中的引用实体类时，需要写上实体类的全类名(包名+类名)，如下：

insert into users(name,age) values(#{name},#{age})

</insert>

　　parameterType="me.gacl.domain.User"这里写的实体类User的全类名me.gacl.domain.User，每次都写这么一长串内容挺麻烦的，而我们希望能够简写成下面的形式

insert into users(name,age) values(#{name},#{age})

</insert>

　　parameterType="_User"这样写就简单多了，为了达到这种效果，我们需要在conf.xml文件中为实体类="me.gacl.domain.User"定义一个别名为"_User"，具体做法如下：
　　在conf.xml文件中<configuration></configuration>标签中添加如下配置：

</typeAliases>

　　这样就可以为me.gacl.domain.User类定义了一个别名为_User，以后_User就代表了me.gacl.domain.User类，这样sql映射xml文件中的凡是需要引用me.gacl.domain.User类的地方都可以使用_User来代替，这就达到了一个简化实体类引用的目的。

　　除了可以使用<typeAlias type="me.gacl.domain.User" alias="_User"/>这种方式单独为某一个实体类设置别名之外，我们还可以使用如下的方式批量为某个包下的所有实体类设置别名，如下：

<!-- 为me.gacl.domain包下的所有实体类配置别名，MyBatis默认的设置别名的方式就是去除类所在的包后的简单的类名

比如me.gacl.domain.User这个实体类的别名就会被设置成User

-->

</typeAliases>

　　<package name="me.gacl.domain"/>就表示为这个包下面的所有实体类设置别名。MyBatis默认的设置别名的方式就是去除类所在的包后的简单的类名，比如me.gacl.domain.User这个实体类的别名就会被设置成User。

第四章 解决字段名与实体类属性名不相同的冲突

在平时的开发中，我们表中的字段名和表对应实体类的属性名称不一定都是完全相同的，下面来演示一下这种情况下的如何解决字段名与实体类属性名不相同的冲突。

一、准备演示需要使用的表和数据

CREATE TABLE orders(

order_id INT PRIMARY KEY AUTO_INCREMENT,

order_no VARCHAR(20),

order_price FLOAT

);

INSERT INTO orders(order_no, order_price) VALUES(‘aaaa‘, 23);

INSERT INTO orders(order_no, order_price) VALUES(‘bbbb‘, 33);

INSERT INTO orders(order_no, order_price) VALUES(‘cccc‘, 22);

二、定义实体类

1 package me.gacl.domain;

3 /**

4 * @author gacl

5 * 定义orders表对应的实体类

6 */

7 public class Order {

8 /**

9 *

10 CREATE TABLE orders(

11 order_id INT PRIMARY KEY AUTO_INCREMENT,

12 order_no VARCHAR(20),

13 order_price FLOAT

14 );

15 */

17 //Order实体类中属性名和orders表中的字段名是不一样的

18 private int id; //id===>order_id

19 private String orderNo; //orderNo===>order_no

20 private float price; //price===>order_price

22 public int getId() {

23 return id;

24 }

26 public void setId(int id) {

27 this.id = id;

28 }

30 public String getOrderNo() {

31 return orderNo;

32 }

34 public void setOrderNo(String orderNo) {

35 this.orderNo = orderNo;

36 }

38 public float getPrice() {

39 return price;

40 }

42 public void setPrice(float price) {

43 this.price = price;

44 }

46 @Override

47 public String toString() {

48 return "Order [id=" + id + ", orderNo=" + orderNo + ", price=" + price+ "]";

49 }

50 }

三、编写测试代码

3.1、编写SQL的xml映射文件

　　1、创建一个orderMapper.xml文件，orderMapper.xml的内容如下：

1 <?xml version="1.0" encoding="UTF-8" ?>

2 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

3 <!-- 为这个mapper指定一个唯一的namespace，namespace的值习惯上设置成包名+sql映射文件名，这样就能够保证namespace的值是唯一的

4 例如namespace="me.gacl.mapping.orderMapper"就是me.gacl.mapping(包名)+orderMapper(orderMapper.xml文件去除后缀)

5 -->

6 <mapper namespace="me.gacl.mapping.orderMapper">

8 <!--

9 根据id查询得到一个order对象，使用这个查询是查询不到我们想要的结果的，

10 这主要是因为实体类的属性名和数据库的字段名对应不上的原因，因此无法查询出对应的记录

11 -->

12 <select id="getOrderById" parameterType="int"

13 resultType="me.gacl.domain.Order">

14 select * from orders where order_id=#{id}

15 </select>

17 <!--

18 根据id查询得到一个order对象，使用这个查询是可以正常查询到我们想要的结果的，

19 这是因为我们将查询的字段名都起一个和实体类属性名相同的别名，这样实体类的属性名和查询结果中的字段名就可以一一对应上

20 -->

21 <select id="selectOrder" parameterType="int"

22 resultType="me.gacl.domain.Order">

23 select order_id id, order_no orderNo,order_price price from orders where order_id=#{id}

24 </select>

26 <!--

27 根据id查询得到一个order对象，使用这个查询是可以正常查询到我们想要的结果的，

28 这是因为我们通过<resultMap>映射实体类属性名和表的字段名一一对应关系 -->

29 <select id="selectOrderResultMap" parameterType="int" resultMap="orderResultMap">

30 select * from orders where order_id=#{id}

31 </select>

32

33 <resultMap type="me.gacl.domain.Order" id="orderResultMap">

34

35 <id property="id" column="order_id"/>

36

37 <result property="orderNo" column="order_no"/>

38 <result property="price" column="order_price"/>

39 </resultMap>

41 </mapper>

　　2、在conf.xml文件中注册orderMapper.xml映射文件

<!-- 注册orderMapper.xml文件，

orderMapper.xml位于me.gacl.mapping这个包下，所以resource写成me/gacl/mapping/orderMapper.xml-->

</mappers>

3.2、编写单元测试代码

1 package me.gacl.test;

3 import me.gacl.domain.Order;

4 import me.gacl.util.MyBatisUtil;

5 import org.apache.ibatis.session.SqlSession;

6 import org.junit.Test;

8 public class Test2 {

10 @Test

11 public void testGetOrderById(){

12 SqlSession sqlSession = MyBatisUtil.getSqlSession();

13 /**

14 * 映射sql的标识字符串，

15 * me.gacl.mapping.orderMapper是orderMapper.xml文件中mapper标签的namespace属性的值，

16 * getOrderById是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL

17 */

18 String statement = "me.gacl.mapping.orderMapper.getOrderById";//映射sql的标识字符串

19 //执行查询操作，将查询结果自动封装成Order对象返回

20 Order order = sqlSession.selectOne(statement,1);//查询orders表中id为1的记录

21 //使用SqlSession执行完SQL之后需要关闭SqlSession

22 sqlSession.close();

23 System.out.println(order);//打印结果：null，也就是没有查询出相应的记录

24 }

26 @Test

27 public void testGetOrderById2(){

28 SqlSession sqlSession = MyBatisUtil.getSqlSession();

29 /**

30 * 映射sql的标识字符串，

31 * me.gacl.mapping.orderMapper是orderMapper.xml文件中mapper标签的namespace属性的值，

32 * selectOrder是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL

33 */

34 String statement = "me.gacl.mapping.orderMapper.selectOrder";//映射sql的标识字符串

35 //执行查询操作，将查询结果自动封装成Order对象返回

36 Order order = sqlSession.selectOne(statement,1);//查询orders表中id为1的记录

37 //使用SqlSession执行完SQL之后需要关闭SqlSession

38 sqlSession.close();

39 System.out.println(order);//打印结果：Order [id=1, orderNo=aaaa, price=23.0]

40 }

42 @Test

43 public void testGetOrderById3(){

44 SqlSession sqlSession = MyBatisUtil.getSqlSession();

45 /**

46 * 映射sql的标识字符串，

47 * me.gacl.mapping.orderMapper是orderMapper.xml文件中mapper标签的namespace属性的值，

48 * selectOrderResultMap是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL

49 */

50 String statement = "me.gacl.mapping.orderMapper.selectOrderResultMap";//映射sql的标识字符串

51 //执行查询操作，将查询结果自动封装成Order对象返回

52 Order order = sqlSession.selectOne(statement,1);//查询orders表中id为1的记录

53 //使用SqlSession执行完SQL之后需要关闭SqlSession

54 sqlSession.close();

55 System.out.println(order);//打印结果：Order [id=1, orderNo=aaaa, price=23.0]

56 }

57 }

　　执行单元测试的结果：

　　1、testGetOrderById方法执行查询后返回一个null。

　　2、testGetOrderById2方法和testGetOrderById3方法执行查询后可以正常得到想要的结果。

四、总结

　　上面的测试代码演示当实体类中的属性名和表中的字段名不一致时，使用MyBatis进行查询操作时无法查询出相应的结果的问题以及针对问题采用的两种办法：

　　解决办法一: 通过在查询的sql语句中定义字段名的别名，让字段名的别名和实体类的属性名一致，这样就可以表的字段名和实体类的属性名一一对应上了，这种方式是通过在sql语句中定义别名来解决字段名和属性名的映射关系的。

　　解决办法二: 通过<resultMap>来映射字段名和实体类属性名的一一对应关系。这种方式是使用MyBatis提供的解决方式来解决字段名和属性名的映射关系的。

第五章 实现关联表查询

一、一对一关联

1.1、提出需求

　　根据班级id查询班级信息(带老师的信息)

1.2、创建表和数据

　　创建一张教师表和班级表，这里我们假设一个老师只负责教一个班，那么老师和班级之间的关系就是一种一对一的关系。

1 CREATE TABLE teacher(

2 t_id INT PRIMARY KEY AUTO_INCREMENT,

3 t_name VARCHAR(20)

4 );

5 CREATE TABLE class(

6 c_id INT PRIMARY KEY AUTO_INCREMENT,

7 c_name VARCHAR(20),

8 teacher_id INT

9 );

10 ALTER TABLE class ADD CONSTRAINT fk_teacher_id FOREIGN KEY (teacher_id) REFERENCES teacher(t_id);

12 INSERT INTO teacher(t_name) VALUES(‘teacher1‘);

13 INSERT INTO teacher(t_name) VALUES(‘teacher2‘);

15 INSERT INTO class(c_name, teacher_id) VALUES(‘class_a‘, 1);

16 INSERT INTO class(c_name, teacher_id) VALUES(‘class_b‘, 2);

　　表之间的关系如下：

1.3、定义实体类

　　1、Teacher类，Teacher类是teacher表对应的实体类。

1 package me.gacl.domain;

3 /**

4 * @author gacl

5 * 定义teacher表对应的实体类

6 */

7 public class Teacher {

9 //定义实体类的属性，与teacher表中的字段对应

10 private int id; //id===>t_id

11 private String name; //name===>t_name

13 public int getId() {

14 return id;

15 }

17 public void setId(int id) {

18 this.id = id;

19 }

21 public String getName() {

22 return name;

23 }

25 public void setName(String name) {

26 this.name = name;

27 }

29 @Override

30 public String toString() {

31 return "Teacher [id=" + id + ", name=" + name + "]";

32 }

33 }

　　2、Classes类，Classes类是class表对应的实体类

1 package me.gacl.domain;

3 /**

4 * @author gacl

5 * 定义class表对应的实体类

6 */

7 public class Classes {

9 //定义实体类的属性，与class表中的字段对应

10 private int id; //id===>c_id

11 private String name; //name===>c_name

13 /**

14 * class表中有一个teacher_id字段，所以在Classes类中定义一个teacher属性，

15 * 用于维护teacher和class之间的一对一关系，通过这个teacher属性就可以知道这个班级是由哪个老师负责的

16 */

17 private Teacher teacher;

19 public int getId() {

20 return id;

21 }

23 public void setId(int id) {

24 this.id = id;

25 }

27 public String getName() {

28 return name;

29 }

31 public void setName(String name) {

32 this.name = name;

33 }

35 public Teacher getTeacher() {

36 return teacher;

37 }

39 public void setTeacher(Teacher teacher) {

40 this.teacher = teacher;

41 }

43 @Override

44 public String toString() {

45 return "Classes [id=" + id + ", name=" + name + ", teacher=" + teacher+ "]";

46 }

47 }

1.4、定义sql映射文件classMapper.xml

1 <?xml version="1.0" encoding="UTF-8" ?>

2 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd">

3 <!-- 为这个mapper指定一个唯一的namespace，namespace的值习惯上设置成包名+sql映射文件名，这样就能够保证namespace的值是唯一的

4 例如namespace="me.gacl.mapping.classMapper"就是me.gacl.mapping(包名)+classMapper(classMapper.xml文件去除后缀)

5 -->

6 <mapper namespace="me.gacl.mapping.classMapper">

8 <!--

9 根据班级id查询班级信息(带老师的信息)

10 ##1. 联表查询

11 SELECT * FROM class c,teacher t WHERE c.teacher_id=t.t_id AND c.c_id=1;

13 ##2. 执行两次查询

14 SELECT * FROM class WHERE c_id=1; //teacher_id=1

15 SELECT * FROM teacher WHERE t_id=1;//使用上面得到的teacher_id

16 -->

18 <!--

19 方式一：嵌套结果：使用嵌套结果映射来处理重复的联合结果的子集

20 封装联表查询的数据(去除重复的数据)

21 select * from class c, teacher t where c.teacher_id=t.t_id and c.c_id=1

22 -->

23 <select id="getClass" parameterType="int" resultMap="ClassResultMap">

24 select * from class c, teacher t where c.teacher_id=t.t_id and c.c_id=#{id}

25 </select>

26

27 <resultMap type="me.gacl.domain.Classes" id="ClassResultMap">

28 <id property="id" column="c_id"/>

29 <result property="name" column="c_name"/>

30 <association property="teacher" javaType="me.gacl.domain.Teacher">

31 <id property="id" column="t_id"/>

32 <result property="name" column="t_name"/>

33 </association>

34 </resultMap>

36 <!--

37 方式二：嵌套查询：通过执行另外一个SQL映射语句来返回预期的复杂类型

38 SELECT * FROM class WHERE c_id=1;

39 SELECT * FROM teacher WHERE t_id=1 //1 是上一个查询得到的teacher_id的值

40 -->

41 <select id="getClass2" parameterType="int" resultMap="ClassResultMap2">

42 select * from class where c_id=#{id}

43 </select>

44

45 <resultMap type="me.gacl.domain.Classes" id="ClassResultMap2">

46 <id property="id" column="c_id"/>

47 <result property="name" column="c_name"/>

48 <association property="teacher" column="teacher_id" select="getTeacher"/>

49 </resultMap>

51 <select id="getTeacher" parameterType="int" resultType="me.gacl.domain.Teacher">

52 SELECT t_id id, t_name name FROM teacher WHERE t_id=#{id}

53 </select>

55 </mapper>

　　在conf.xml文件中注册classMapper.xml

<!-- 注册classMapper.xml文件，

classMapper.xml位于me.gacl.mapping这个包下，所以resource写成me/gacl/mapping/classMapper.xml-->

</mappers>

1.5、编写单元测试代码

1 package me.gacl.test;

3 import me.gacl.domain.Classes;

4 import me.gacl.util.MyBatisUtil;

5 import org.apache.ibatis.session.SqlSession;

6 import org.junit.Test;

8 public class Test3 {

10 @Test

11 public void testGetClass(){

12 SqlSession sqlSession = MyBatisUtil.getSqlSession();

13 /**

14 * 映射sql的标识字符串，

15 * me.gacl.mapping.classMapper是classMapper.xml文件中mapper标签的namespace属性的值，

16 * getClass是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL

17 */

18 String statement = "me.gacl.mapping.classMapper.getClass";//映射sql的标识字符串

19 //执行查询操作，将查询结果自动封装成Classes对象返回

20 Classes clazz = sqlSession.selectOne(statement,1);//查询class表中id为1的记录

21 //使用SqlSession执行完SQL之后需要关闭SqlSession

22 sqlSession.close();

23 System.out.println(clazz);//打印结果：Classes [id=1, name=class_a, teacher=Teacher [id=1, name=teacher1]]

24 }

26 @Test

27 public void testGetClass2(){

28 SqlSession sqlSession = MyBatisUtil.getSqlSession();

29 /**

30 * 映射sql的标识字符串，

31 * me.gacl.mapping.classMapper是classMapper.xml文件中mapper标签的namespace属性的值，

32 * getClass2是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL

33 */

34 String statement = "me.gacl.mapping.classMapper.getClass2";//映射sql的标识字符串

35 //执行查询操作，将查询结果自动封装成Classes对象返回

36 Classes clazz = sqlSession.selectOne(statement,1);//查询class表中id为1的记录

37 //使用SqlSession执行完SQL之后需要关闭SqlSession

38 sqlSession.close();

39 System.out.println(clazz);//打印结果：Classes [id=1, name=class_a, teacher=Teacher [id=1, name=teacher1]]

40 }

41 }

1.6、MyBatis一对一关联查询总结

　　MyBatis中使用association标签来解决一对一的关联查询，association标签可用的属性如下：

property:对象属性的名称
javaType:对象属性的类型
column:所对应的外键字段名称
select:使用另一个查询封装的结果

二、一对多关联

2.1、提出需求

　　根据classId查询对应的班级信息,包括学生,老师

2.2、创建表和数据

　　在上面的一对一关联查询演示中，我们已经创建了班级表和教师表，因此这里再创建一张学生表

CREATE TABLE student(

s_id INT PRIMARY KEY AUTO_INCREMENT,

s_name VARCHAR(20),

class_id INT

);

INSERT INTO student(s_name, class_id) VALUES(‘student_A‘, 1);

INSERT INTO student(s_name, class_id) VALUES(‘student_B‘, 1);

INSERT INTO student(s_name, class_id) VALUES(‘student_C‘, 1);

INSERT INTO student(s_name, class_id) VALUES(‘student_D‘, 2);

INSERT INTO student(s_name, class_id) VALUES(‘student_E‘, 2);

INSERT INTO student(s_name, class_id) VALUES(‘student_F‘, 2);

2.3、定义实体类

　　1、Student类

1 package me.gacl.domain;

3 /**

4 * @author gacl

5 * 定义student表所对应的实体类

6 */

7 public class Student {

9 //定义属性，和student表中的字段对应

10 private int id; //id===>s_id

11 private String name; //name===>s_name

13 public int getId() {

14 return id;

15 }

17 public void setId(int id) {

18 this.id = id;

19 }

21 public String getName() {

22 return name;

23 }

25 public void setName(String name) {

26 this.name = name;

27 }

29 @Override

30 public String toString() {

31 return "Student [id=" + id + ", name=" + name + "]";

32 }

33 }

　　2、修改Classes类，添加一个List<Student> students属性，使用一个List<Student>集合属性表示班级拥有的学生，如下：

1 package me.gacl.domain;

3 import java.util.List;

5 /**

6 * @author gacl

7 * 定义class表对应的实体类

8 */

9 public class Classes {

11 //定义实体类的属性，与class表中的字段对应

12 private int id; //id===>c_id

13 private String name; //name===>c_name

15 /**

16 * class表中有一个teacher_id字段，所以在Classes类中定义一个teacher属性，

17 * 用于维护teacher和class之间的一对一关系，通过这个teacher属性就可以知道这个班级是由哪个老师负责的

18 */

19 private Teacher teacher;

20 //使用一个List<Student>集合属性表示班级拥有的学生

21 private List<Student> students;

23 public int getId() {

24 return id;

25 }

27 public void setId(int id) {

28 this.id = id;

29 }

31 public String getName() {

32 return name;

33 }

35 public void setName(String name) {

36 this.name = name;

37 }

39 public Teacher getTeacher() {

40 return teacher;

41 }

43 public void setTeacher(Teacher teacher) {

44 this.teacher = teacher;

45 }

47 public List<Student> getStudents() {

48 return students;

49 }

51 public void setStudents(List<Student> students) {

52 this.students = students;

53 }

55 @Override

56 public String toString() {

57 return "Classes [id=" + id + ", name=" + name + ", teacher=" + teacher

58 + ", students=" + students + "]";

59 }

60 }

2.4、修改sql映射文件classMapper.xml

　　添加如下的SQL映射信息

1 <!--

2 根据classId查询对应的班级信息,包括学生,老师

3 -->

4 <!--

5 方式一: 嵌套结果: 使用嵌套结果映射来处理重复的联合结果的子集

6 SELECT * FROM class c, teacher t,student s WHERE c.teacher_id=t.t_id AND c.C_id=s.class_id AND c.c_id=1

7 -->

8 <select id="getClass3" parameterType="int" resultMap="ClassResultMap3">

9 select * from class c, teacher t,student s where c.teacher_id=t.t_id and c.C_id=s.class_id and c.c_id=#{id}

10 </select>

11 <resultMap type="me.gacl.domain.Classes" id="ClassResultMap3">

12 <id property="id" column="c_id"/>

13 <result property="name" column="c_name"/>

14 <association property="teacher" column="teacher_id" javaType="me.gacl.domain.Teacher">

15 <id property="id" column="t_id"/>

16 <result property="name" column="t_name"/>

17 </association>

18

19 <collection property="students" ofType="me.gacl.domain.Student">

20 <id property="id" column="s_id"/>

21 <result property="name" column="s_name"/>

22 </collection>

23 </resultMap>

25 <!--

26 方式二：嵌套查询：通过执行另外一个SQL映射语句来返回预期的复杂类型

27 SELECT * FROM class WHERE c_id=1;

28 SELECT * FROM teacher WHERE t_id=1 //1 是上一个查询得到的teacher_id的值

29 SELECT * FROM student WHERE class_id=1 //1是第一个查询得到的c_id字段的值

30 -->

31 <select id="getClass4" parameterType="int" resultMap="ClassResultMap4">

32 select * from class where c_id=#{id}

33 </select>

34 <resultMap type="me.gacl.domain.Classes" id="ClassResultMap4">

35 <id property="id" column="c_id"/>

36 <result property="name" column="c_name"/>

37 <association property="teacher" column="teacher_id" javaType="me.gacl.domain.Teacher" select="getTeacher2"></association>

38 <collection property="students" ofType="me.gacl.domain.Student" column="c_id" select="getStudent"></collection>

39 </resultMap>

41 <select id="getTeacher2" parameterType="int" resultType="me.gacl.domain.Teacher">

42 SELECT t_id id, t_name name FROM teacher WHERE t_id=#{id}

43 </select>

45 <select id="getStudent" parameterType="int" resultType="me.gacl.domain.Student">

46 SELECT s_id id, s_name name FROM student WHERE class_id=#{id}

47 </select>

2.5、编写单元测试代码

1 package me.gacl.test;

3 import me.gacl.domain.Classes;

4 import me.gacl.util.MyBatisUtil;

5 import org.apache.ibatis.session.SqlSession;

6 import org.junit.Test;

8 public class Test4 {

10 @Test

11 public void testGetClass3(){

12 SqlSession sqlSession = MyBatisUtil.getSqlSession();

13 /**

14 * 映射sql的标识字符串，

15 * me.gacl.mapping.classMapper是classMapper.xml文件中mapper标签的namespace属性的值，

16 * getClass3是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL

17 */

18 String statement = "me.gacl.mapping.classMapper.getClass3";//映射sql的标识字符串

19 //执行查询操作，将查询结果自动封装成Classes对象返回

20 Classes clazz = sqlSession.selectOne(statement,1);//查询class表中id为1的记录

21 //使用SqlSession执行完SQL之后需要关闭SqlSession

22 sqlSession.close();

23 //打印结果：Classes [id=1, name=class_a, teacher=Teacher [id=1, name=teacher1], students=[Student [id=1, name=student_A], Student [id=2, name=student_B], Student [id=3, name=student_C]]]

24 System.out.println(clazz);

25 }

27 @Test

28 public void testGetClass4(){

29 SqlSession sqlSession = MyBatisUtil.getSqlSession();

30 /**

31 * 映射sql的标识字符串，

32 * me.gacl.mapping.classMapper是classMapper.xml文件中mapper标签的namespace属性的值，

33 * getClass4是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL

34 */

35 String statement = "me.gacl.mapping.classMapper.getClass4";//映射sql的标识字符串

36 //执行查询操作，将查询结果自动封装成Classes对象返回

37 Classes clazz = sqlSession.selectOne(statement,1);//查询class表中id为1的记录

38 //使用SqlSession执行完SQL之后需要关闭SqlSession

39 sqlSession.close();

40 //打印结果：Classes [id=1, name=class_a, teacher=Teacher [id=1, name=teacher1], students=[Student [id=1, name=student_A], Student [id=2, name=student_B], Student [id=3, name=student_C]]]

41 System.out.println(clazz);

42 }

43 }

2.6、MyBatis一对多关联查询总结

　　MyBatis中使用collection标签来解决一对多的关联查询，ofType属性指定集合中元素的对象类型。

第六章 调用存储过程

一、提出需求

　　查询得到男性或女性的数量, 如果传入的是0就女性否则是男性

二、准备数据库表和存储过程

1 create table p_user(

2 id int primary key auto_increment,

3 name varchar(10),

4 sex char(2)

5 );

7 insert into p_user(name,sex) values(‘A‘,"男");

8 insert into p_user(name,sex) values(‘B‘,"女");

9 insert into p_user(name,sex) values(‘C‘,"男");

11 -- 创建存储过程(查询得到男性或女性的数量, 如果传入的是0就女性否则是男性)

12 DELIMITER $

13 CREATE PROCEDURE mybatis.ges_user_count(IN sex_id INT, OUT user_count INT)

14 BEGIN

15 IF sex_id=0 THEN

16 SELECT COUNT(*) FROM mybatis.p_user WHERE p_user.sex=‘女‘ INTO user_count;

17 ELSE

18 SELECT COUNT(*) FROM mybatis.p_user WHERE p_user.sex=‘男‘ INTO user_count;

19 END IF;

20 END

21 $

23 -- 调用存储过程

24 DELIMITER ;

25 SET @user_count = 0;

26 CALL mybatis.ges_user_count(1, @user_count);

27 SELECT @user_count;

三、编辑userMapper.xml

　　编辑userMapper.xml文件，添加如下的配置项

1 <!--

2 查询得到男性或女性的数量, 如果传入的是0就女性否则是男性

3 -->

4 <select id="getUserCount" parameterMap="getUserCountMap" statementType="CALLABLE">

5 CALL mybatis.ges_user_count(?,?)

6 </select>

8 <!--

9 parameterMap.put("sexid", 0);

10 parameterMap.put("usercount", -1);

11 -->

12 <parameterMap type="java.util.Map" id="getUserCountMap">

13 <parameter property="sexid" mode="IN" jdbcType="INTEGER"/>

14 <parameter property="usercount" mode="OUT" jdbcType="INTEGER"/>

15 </parameterMap>

四、编写单元测试代码

1 package me.gacl.test;

3 import java.util.HashMap;

4 import java.util.List;

5 import java.util.Map;

7 import me.gacl.custom.model.ConditionUser;

8 import me.gacl.domain.User;

9 import me.gacl.util.MyBatisUtil;

10 import org.apache.ibatis.session.SqlSession;

11 import org.junit.Test;

13 /**

14 * @author gacl

15 * 测试调用存储过程

16 */

17 public class Test6 {

19 @Test

20 public void testGetUserCount(){

21 SqlSession sqlSession = MyBatisUtil.getSqlSession();

22 /**

23 * 映射sql的标识字符串，

24 * me.gacl.mapping.userMapper是userMapper.xml文件中mapper标签的namespace属性的值，

25 * getUserCount是select标签的id属性值，通过select标签的id属性值就可以找到要执行的SQL

26 */

27 String statement = "me.gacl.mapping.userMapper.getUserCount";//映射sql的标识字符串

28 Map<String, Integer> parameterMap = new HashMap<String, Integer>();

29 parameterMap.put("sexid", 1);

30 parameterMap.put("usercount", -1);

31 sqlSession.selectOne(statement, parameterMap);

32 Integer result = parameterMap.get("usercount");

33 System.out.println(result);

34 sqlSession.close();

35 }

36 }

第七章 Mybatis缓存

一、MyBatis缓存介绍

　　正如大多数持久层框架一样，MyBatis 同样提供了一级缓存和二级缓存的支持

一级缓存: 基于PerpetualCache 的 HashMap本地缓存，其存储作用域为 Session，当 Session flush 或 close 之后，该Session中的所有 Cache 就将清空。

　　2. 二级缓存与一级缓存其机制相同，默认也是采用 PerpetualCache，HashMap存储，不同在于其存储作用域为 Mapper(Namespace)，并且可自定义存储源，如 Ehcache。

　　3. 对于缓存数据更新机制，当某一个作用域(一级缓存Session/二级缓存Namespaces)的进行了 C/U/D 操作后，默认该作用域下所有 select 中的缓存将被clear。

1.1、Mybatis一级缓存测试

1 package me.gacl.test;

3 import me.gacl.domain.User;

4 import me.gacl.util.MyBatisUtil;

5 import org.apache.ibatis.session.SqlSession;

6 import org.junit.Test;

8 /**

9 * @author gacl

10 * 测试一级缓存

11 */

12 public class TestOneLevelCache {

14 /*

15 * 一级缓存: 也就Session级的缓存(默认开启)

16 */

17 @Test

18 public void testCache1() {

19 SqlSession session = MyBatisUtil.getSqlSession();

20 String statement = "me.gacl.mapping.userMapper.getUser";

21 User user = session.selectOne(statement, 1);

22 System.out.println(user);

24 /*

25 * 一级缓存默认就会被使用

26 */

27 user = session.selectOne(statement, 1);

28 System.out.println(user);

29 session.close();

30 /*

31 1. 必须是同一个Session,如果session对象已经close()过了就不可能用了

32 */

33 session = MyBatisUtil.getSqlSession();

34 user = session.selectOne(statement, 1);

35 System.out.println(user);

37 /*

38 2. 查询条件是一样的

39 */

40 user = session.selectOne(statement, 2);

41 System.out.println(user);

43 /*

44 3. 没有执行过session.clearCache()清理缓存

45 */

46 //session.clearCache();

47 user = session.selectOne(statement, 2);

48 System.out.println(user);

50 /*

51 4. 没有执行过增删改的操作(这些操作都会清理缓存)

52 */

53 session.update("me.gacl.mapping.userMapper.updateUser",

54 new User(2, "user", 23));

55 user = session.selectOne(statement, 2);

56 System.out.println(user);

58 }

59 }

1.2、Mybatis二级缓存测试

　　1、开启二级缓存，在userMapper.xml文件中添加如下配置

　　2、测试二级缓存

1 package me.gacl.test;

3 import me.gacl.domain.User;

4 import me.gacl.util.MyBatisUtil;

5 import org.apache.ibatis.session.SqlSession;

6 import org.apache.ibatis.session.SqlSessionFactory;

7 import org.junit.Test;

9 /**

10 * @author gacl

11 * 测试二级缓存

12 */

13 public class TestTwoLevelCache {

15 /*

16 * 测试二级缓存

17 * 使用两个不同的SqlSession对象去执行相同查询条件的查询，第二次查询时不会再发送SQL语句，而是直接从缓存中取出数据

18 */

19 @Test

20 public void testCache2() {

21 String statement = "me.gacl.mapping.userMapper.getUser";

22 SqlSessionFactory factory = MyBatisUtil.getSqlSessionFactory();

23 //开启两个不同的SqlSession

24 SqlSession session1 = factory.openSession();

25 SqlSession session2 = factory.openSession();

26 //使用二级缓存时，User类必须实现一个Serializable接口===> User implements Serializable

27 User user = session1.selectOne(statement, 1);

28 session1.commit();//不懂为啥，这个地方一定要提交事务之后二级缓存才会起作用

29 System.out.println("user="+user);

31 //由于使用的是两个不同的SqlSession对象，所以即使查询条件相同，一级缓存也不会开启使用

32 user = session2.selectOne(statement, 1);

33 //session2.commit();

34 System.out.println("user2="+user);

35 }

36 }

1.3、二级缓存补充说明

　　1. 映射语句文件中的所有select语句将会被缓存。

　　2. 映射语句文件中的所有insert，update和delete语句会刷新缓存。

　　3. 缓存会使用Least Recently Used（LRU，最近最少使用的）算法来收回。

　　4. 缓存会根据指定的时间间隔来刷新。

　　5. 缓存会存储1024个对象

cache标签常用属性：

<cache

eviction="FIFO"

flushInterval="60000"

size="512"

readOnly="true"/>

第八章 Mybatis3.x与Spring4.x整合

一、搭建开发环境

1.1、使用Maven创建Web项目

　　执行如下命令：

mvn archetype:create -DgroupId=me.gacl -DartifactId=spring4-mybatis3 -DarchetypeArtifactId=maven-archetype-webapp -DinteractiveMode=false

　　如下图所示：
　　

　　创建好的项目如下：

　　编辑pom.xml文件

1 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

2 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

3 <modelVersion>4.0.0</modelVersion>

4 <groupId>me.gacl</groupId>

5 <artifactId>spring4-mybatis3</artifactId>

6 <packaging>war</packaging>

7 <version>1.0-SNAPSHOT</version>

8 <name>spring4-mybatis3 Maven Webapp</name>

9 <url>http://maven.apache.org</url>

10 <dependencies>

11 <dependency>

12 <groupId>junit</groupId>

13 <artifactId>junit</artifactId>

14 <version>3.8.1</version>

15 <scope>test</scope>

16 </dependency>

17 </dependencies>

18 <build>

19 <finalName>spring4-mybatis3</finalName>

20 </build>

21 </project>

　　修改 <name>spring4-mybatis3 Maven Webapp</name> 部分，把" Maven Webapp"这部分包含空格的内容去掉，否则Maven在编译项目时会因为空格的原因导致一些莫名其妙的错误出现，修改成： <name>spring4-mybatis3</name> 。

　　另外，把以下内容删掉：

1 <dependency>

2 <groupId>junit</groupId>

3 <artifactId>junit</artifactId>

4 <version>3.8.1</version>

5 <scope>test</scope>

6 </dependency>

　　这部分是junit的jar包依赖信息，这个版本太低了，我们不使用这个Junit测试版本，修改过后的pom.xml内容如下：

1 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

2 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

3 <modelVersion>4.0.0</modelVersion>

4 <groupId>me.gacl</groupId>

5 <artifactId>spring4-mybatis3</artifactId>

6 <packaging>war</packaging>

7 <version>1.0-SNAPSHOT</version>

8 <name>spring4-mybatis3</name>

9 <url>http://maven.apache.org</url>

10 <dependencies>

12 </dependencies>

13 <build>

14 <finalName>spring4-mybatis3</finalName>

15 </build>

16 </project>

1.2、将创建好的项目导入MyEclipse中

　　具体操作步骤如下图所示：

　　手动创建【src/main/java】、【src/test/resources】、【src/test/java】这三个source folder，如下图所示：

　　到此，项目搭建的工作就算是全部完成了。

二、创建数据库和表(针对MySQL)

SQL脚本如下：

Create DATABASE spring4_mybatis3;

USE spring4_mybatis3;

DROP TABLE IF EXISTS t_user;

CREATE TABLE t_user (

user_id char(32) NOT NULL,

user_name varchar(30) DEFAULT NULL,

user_birthday date DEFAULT NULL,

user_salary double DEFAULT NULL,

PRIMARY KEY (user_id)

) ENGINE=InnoDB DEFAULT CHARSET=utf8;

　　创建好的数据库和表如下：

三、使用generator工具生成代码

　　在网上找到了一个generator工具可以根据创建好的数据库表生成MyBatis的表对应的实体类，SQL映射文件和dao，找到generator工具根目录下的generator.xml文件，这个文件是用来配置代码生成规则的，如下图所示：

　　编辑generator.xml文件，内容如下：

1 <?xml version="1.0" encoding="UTF-8"?>

2 <!DOCTYPE generatorConfiguration PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN" "http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd">

3 <generatorConfiguration>

4

5 <classPathEntry location="E:\repository\mysql\mysql-connector-java\5.1.34\mysql-connector-java-5.1.34.jar" />

6

7 <context id="DB2Tables" targetRuntime="MyBatis3">

8 <commentGenerator>

9 <property name="suppressAllComments" value="true" />

10 </commentGenerator>

11

12 <jdbcConnection driverClass="com.mysql.jdbc.Driver" connectionURL="jdbc:mysql://localhost:3306/spring4_mybatis3" userId="root" password="XDP">

13

14 </jdbcConnection>

15 <javaTypeResolver>

16 <property name="forceBigDecimals" value="false" />

17 </javaTypeResolver>

18

19 <javaModelGenerator targetPackage="me.gacl.domain" targetProject="C:\Users\gacl\spring4-mybatis3\src\main\java">

20 <property name="enableSubPackages" value="true" />

21 <property name="trimStrings" value="true" />

22 </javaModelGenerator>

23

24 <sqlMapGenerator targetPackage="me.gacl.mapping" targetProject="C:\Users\gacl\spring4-mybatis3\src\main\java">

25 <property name="enableSubPackages" value="true" />

26 </sqlMapGenerator>

27

28 <javaClientGenerator type="XMLMAPPER" targetPackage="me.gacl.dao" targetProject="C:\Users\gacl\spring4-mybatis3\src\main\java">

29 <property name="enableSubPackages" value="true" />

30 </javaClientGenerator>

31

32 <table tableName="t_user" domainObjectName="User" enableCountByExample="false" enableUpdateByExample="false" enableDeleteByExample="false" enableSelectByExample="false" selectByExampleQueryId="false" />

33 </context>

34 </generatorConfiguration>

　　打开命令行窗口，切换到生成工具的根目录下，执行如下命令：

java -jar mybatis-generator-core-1.3.2.jar -configfile generator.xml -overwrite

　　如下图所示：
　　

　　刚才我们在generator.xml文件中配置将生成的代码和SQL映射文件放到"C:\Users\gacl\spring4-mybatis3\src\main\java"这个目录下，这个目录就是我们的spring4-mybatis3项目所在目录，我们刷新一下src/main/java目录，就可以看到生成的代码和映射文件了，如下图所示：

　　生成的代码和映射文件一行都不用改，可以直接应用到项目当中。下面我们看一眼由generator工具生成的代码和映射文件：

　　1、生成的dao类

1 package me.gacl.dao;

3 import me.gacl.domain.User;

5 public interface UserMapper {

6 int deleteByPrimaryKey(String userId);

8 int insert(User record);

10 int insertSelective(User record);

12 User selectByPrimaryKey(String userId);

14 int updateByPrimaryKeySelective(User record);

16 int updateByPrimaryKey(User record);

17 }

　　生成的UserMapper是一个接口，里面定义了一些操作t_user表的增删改查方法。

2、生成的实体类

1 package me.gacl.domain;

3 import java.util.Date;

5 public class User {

6 private String userId;

8 private String userName;

10 private Date userBirthday;

12 private Double userSalary;

14 public String getUserId() {

15 return userId;

16 }

18 public void setUserId(String userId) {

19 this.userId = userId == null ? null : userId.trim();

20 }

22 public String getUserName() {

23 return userName;

24 }

26 public void setUserName(String userName) {

27 this.userName = userName == null ? null : userName.trim();

28 }

30 public Date getUserBirthday() {

31 return userBirthday;

32 }

34 public void setUserBirthday(Date userBirthday) {

35 this.userBirthday = userBirthday;

36 }

38 public Double getUserSalary() {

39 return userSalary;

40 }

42 public void setUserSalary(Double userSalary) {

43 this.userSalary = userSalary;

44 }

45 }

　　User类是t_user表的对应的实体类，User类中定义的属性和t_user表中的字段一一对应。

　　3、生成的SQL映射文件

1 <?xml version="1.0" encoding="UTF-8" ?>

2 <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >

3 <mapper namespace="me.gacl.dao.UserMapper" >

4 <resultMap id="BaseResultMap" type="me.gacl.domain.User" >

5 <id column="user_id" property="userId" jdbcType="CHAR" />

6 <result column="user_name" property="userName" jdbcType="VARCHAR" />

7 <result column="user_birthday" property="userBirthday" jdbcType="DATE" />

8 <result column="user_salary" property="userSalary" jdbcType="DOUBLE" />

9 </resultMap>

10 <sql id="Base_Column_List" >

11 user_id, user_name, user_birthday, user_salary

12 </sql>

13 <select id="selectByPrimaryKey" resultMap="BaseResultMap" parameterType="java.lang.String" >

14 select

15 <include refid="Base_Column_List" />

16 from t_user

17 where user_id = #{userId,jdbcType=CHAR}

18 </select>

19 <delete id="deleteByPrimaryKey" parameterType="java.lang.String" >

20 delete from t_user

21 where user_id = #{userId,jdbcType=CHAR}

22 </delete>

23 <insert id="insert" parameterType="me.gacl.domain.User" >

24 insert into t_user (user_id, user_name, user_birthday,

25 user_salary)

26 values (#{userId,jdbcType=CHAR}, #{userName,jdbcType=VARCHAR}, #{userBirthday,jdbcType=DATE},

27 #{userSalary,jdbcType=DOUBLE})

28 </insert>

29 <insert id="insertSelective" parameterType="me.gacl.domain.User" >

30 insert into t_user

31 <trim prefix="(" suffix=")" suffixOverrides="," >

32 <if test="userId != null" >

33 user_id,

34 </if>

35 <if test="userName != null" >

36 user_name,

37 </if>

38 <if test="userBirthday != null" >

39 user_birthday,

40 </if>

41 <if test="userSalary != null" >

42 user_salary,

43 </if>

44 </trim>

45 <trim prefix="values (" suffix=")" suffixOverrides="," >

46 <if test="userId != null" >

47 #{userId,jdbcType=CHAR},

48 </if>

49 <if test="userName != null" >

50 #{userName,jdbcType=VARCHAR},

51 </if>

52 <if test="userBirthday != null" >

53 #{userBirthday,jdbcType=DATE},

54 </if>

55 <if test="userSalary != null" >

56 #{userSalary,jdbcType=DOUBLE},

57 </if>

58 </trim>

59 </insert>

60 <update id="updateByPrimaryKeySelective" parameterType="me.gacl.domain.User" >

61 update t_user

62 <set >

63 <if test="userName != null" >

64 user_name = #{userName,jdbcType=VARCHAR},

65 </if>

66 <if test="userBirthday != null" >

67 user_birthday = #{userBirthday,jdbcType=DATE},

68 </if>

69 <if test="userSalary != null" >

70 user_salary = #{userSalary,jdbcType=DOUBLE},

71 </if>

72 </set>

73 where user_id = #{userId,jdbcType=CHAR}

74 </update>

75 <update id="updateByPrimaryKey" parameterType="me.gacl.domain.User" >

76 update t_user

77 set user_name = #{userName,jdbcType=VARCHAR},

78 user_birthday = #{userBirthday,jdbcType=DATE},

79 user_salary = #{userSalary,jdbcType=DOUBLE}

80 where user_id = #{userId,jdbcType=CHAR}

81 </update>

82 </mapper>

　　UserMapper.xml这个文件的内容是编写操作t_user表的SQL语句，重点说一下UserMapper.xml配置中需要注意的几个小细节问题：

　　1、UserMapper.xml的<mapper>标签的namespace必须是UserMapper接口的全类名，既<mapper namespace="me.gacl.dao.UserMapper" >

　　2、UserMapper.xml的定义操作数据库的<select><delete><update><insert>这些标签的id属性的值必须和UserMapper接口定义的方法名一致，如下图所示：

　　之所以有上述说的这两点要求，就是为了能够让MyBatis能够根据UserMapper接口和UserMapper.xml文件去自动实现UserMapper接口中定义的相关方法，这样我们就不再需要针对UserMapper接口去编写具体的实现代码了。

四、Spring与MyBatis整合

　　首先我们要在项目中加入我们需要的相关jar包，我们可以到Maven的中央仓库：http://search.maven.org/ 找到我们要的相关jar包，如下图所示：

　　我们只需要在搜索框中输入要找的jar包的名称，点击【SEARCH】按钮，就可以找到我们要的jar包了。

4.1、添加Spring与Mybatis的相关jar包

　　1、添加spring-core，输入spring-core关键字进行查找，如下图所示：

　　找到关于spring-core的依赖描述信息，如下图所示：

　　将

<groupId>org.springframework</groupId>

<artifactId>spring-core</artifactId>

<version>4.1.4.RELEASE</version>

</dependency>

　　复制到项目的pom.xml文件中，如下所示：

<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/maven-v4_0_0.xsd">

<artifactId>spring4-mybatis3</artifactId>

<version>1.0-SNAPSHOT</version>

<name>spring4-mybatis3</name>

<url>http://maven.apache.org</url>

<groupId>org.springframework</groupId>

<artifactId>spring-core</artifactId>

<version>4.1.4.RELEASE</version>

</dependency>

</dependencies>

<build>

<finalName>spring4-mybatis3</finalName>

</build>

</project>

　　这样Maven就会自动帮我们从Maven的中央仓库中下载spring-core这个jar包到我们的本地仓库，然后将spring-core这个jar包以及它的相关依赖包加入到我们的项目当中，如下所示：

　　spring4.x与mybatis3.x所需要的相关jar包都可以采用上述所说的方式进行查找，然后添加到项目当中，添加完spring4.x与mybatis3.x相关jar包后，pom.xml文件内容最终如下：

1 <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

2 xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/maven-v4_0_0.xsd">

3 <modelVersion>4.0.0</modelVersion>

4 <groupId>me.gacl</groupId>

5 <artifactId>spring4-mybatis3</artifactId>

6 <packaging>war</packaging>

7 <version>1.0-SNAPSHOT</version>

8 <name>spring4-mybatis3</name>

9 <url>http://maven.apache.org</url>

10 <dependencies>

11

12 <dependency>

13 <groupId>org.springframework</groupId>

14 <artifactId>spring-core</artifactId>

15 <version>4.1.4.RELEASE</version>

16 </dependency>

17

18 <dependency>

19 <groupId>org.springframework</groupId>

20 <artifactId>spring-context</artifactId>

21 <version>4.1.4.RELEASE</version>

22 </dependency>

23

24 <dependency>

25 <groupId>org.springframework</groupId>

26 <artifactId>spring-tx</artifactId>

27 <version>4.1.4.RELEASE</version>

28 </dependency>

29

30 <dependency>

31 <groupId>org.springframework</groupId>

32 <artifactId>spring-jdbc</artifactId>

33 <version>4.1.4.RELEASE</version>

34 </dependency>

35

36 <dependency>

37 <groupId>org.springframework</groupId>

38 <artifactId>spring-test</artifactId>

39 <version>4.1.4.RELEASE</version>

40 </dependency>

41

42 <dependency>

43 <groupId>org.springframework</groupId>

44 <artifactId>spring-web</artifactId>

45 <version>4.1.4.RELEASE</version>

46 </dependency>

47

48 <dependency>

49 <groupId>org.aspectj</groupId>

50 <artifactId>aspectjweaver</artifactId>

51 <version>1.8.5</version>

52 </dependency>

53

54 <dependency>

55 <groupId>org.mybatis</groupId>

56 <artifactId>mybatis</artifactId>

57 <version>3.2.8</version>

58 </dependency>

59

60 <dependency>

61 <groupId>org.mybatis</groupId>

62 <artifactId>mybatis-spring</artifactId>

63 <version>1.2.2</version>

64 </dependency>

65

66 <dependency>

67 <groupId>javax.servlet</groupId>

68 <artifactId>javax.servlet-api</artifactId>

69 <version>3.0.1</version>

70 </dependency>

71 <dependency>

72 <groupId>javax.servlet.jsp</groupId>

73 <artifactId>javax.servlet.jsp-api</artifactId>

74 <version>2.3.2-b01</version>

75 </dependency>

76

77 <dependency>

78 <groupId>javax.servlet</groupId>

79 <artifactId>jstl</artifactId>

80 <version>1.2</version>

81 </dependency>

82

83 <dependency>

84 <groupId>mysql</groupId>

85 <artifactId>mysql-connector-java</artifactId>

86 <version>5.1.34</version>

87 </dependency>

88

89 <dependency>

90 <groupId>com.alibaba</groupId>

91 <artifactId>druid</artifactId>

92 <version>1.0.12</version>

93 </dependency>

94

95 <dependency>

96 <groupId>junit</groupId>

97 <artifactId>junit</artifactId>

98 <version>4.12</version>

99 <scope>test</scope>

100 </dependency>

101 </dependencies>

102 <build>

103 <finalName>spring4-mybatis3</finalName>

104 </build>

105 </project>

4.2、编写相关配置文件

　　1、dbconfig.properties

　　在src/main/resources目录下创建一个dbconfig.properties文件，用于编写连接MySQL数据库的相关信息，dbconfig.properties的内容如下：

driverClassName=com.mysql.jdbc.Driver

validationQuery=SELECT 1

jdbc_url=jdbc:mysql://localhost:3306/spring4_mybatis3?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=convertToNull

jdbc_username=root

jdbc_password=XDP

　　2、spring.xml(spring框架的配置文件)

　　在src/main/resources目录下创建一个spring.xml文件，spring.xml文件就是针对Spring框架编写的核心配置文件，spring.xml的内容如下：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans"

xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:context="http://www.springframework.org/schema/context"

xsi:schemaLocation="

http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

http://www.springframework.org/schema/context

http://www.springframework.org/schema/context/spring-context-3.0.xsd">

<context:property-placeholder location="classpath:dbconfig.properties" />

<context:component-scan base-package="me.gacl.service" />

</beans>

　　我们的spring.xml文件的配置非常简单，就两个配置。
　　3、spring-mybatis.xml(spring与mybatis整合的配置文件)

　　在src/main/resources目录下创建一个spring-mybatis.xml文件，spring-mybatis.xml文件就是针对Spring框架与Mybatis框架整合编写的配置文件，spring-mybatis.xml的内容如下：

<?xml version="1.0" encoding="UTF-8"?>

<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:tx="http://www.springframework.org/schema/tx" xmlns:aop="http://www.springframework.org/schema/aop" xsi:schemaLocation="

http://www.springframework.org/schema/beans

http://www.springframework.org/schema/beans/spring-beans-3.0.xsd

http://www.springframework.org/schema/tx

http://www.springframework.org/schema/tx/spring-tx-3.0.xsd

http://www.springframework.org/schema/aop

http://www.springframework.org/schema/aop/spring-aop-3.0.xsd

<!--

-->

</bean>

<!-- 自动扫描me/gacl/mapping/目录下的所有SQL映射的xml文件, 省掉Configuration.xml里的手工配置

value="classpath:me/gacl/mapping/*.xml"指的是classpath(类路径)下me.gacl.mapping包中的所有xml文件

UserMapper.xml位于me.gacl.mapping包下，这样UserMapper.xml就可以被自动扫描

-->

</bean>

</bean>

</bean>

<tx:advice id="transactionAdvice" transaction-manager="transactionManager">

<tx:attributes>

<tx:method name="add*" propagation="REQUIRED" />

<tx:method name="append*" propagation="REQUIRED" />

<tx:method name="insert*" propagation="REQUIRED" />

<tx:method name="save*" propagation="REQUIRED" />

<tx:method name="update*" propagation="REQUIRED" />

<tx:method name="modify*" propagation="REQUIRED" />

<tx:method name="edit*" propagation="REQUIRED" />

<tx:method name="delete*" propagation="REQUIRED" />

<tx:method name="remove*" propagation="REQUIRED" />

<tx:method name="repair" propagation="REQUIRED" />

<tx:method name="delAndRepair" propagation="REQUIRED" />

<tx:method name="get*" propagation="SUPPORTS" />

<tx:method name="find*" propagation="SUPPORTS" />

<tx:method name="load*" propagation="SUPPORTS" />

<tx:method name="search*" propagation="SUPPORTS" />

<tx:method name="datagrid*" propagation="SUPPORTS" />

<tx:method name="*" propagation="SUPPORTS" />

</tx:attributes>

</tx:advice>

<aop:config>

<aop:pointcut id="transactionPointcut" expression="execution(* me.gacl.service..*Impl.*(..))" />

<aop:advisor pointcut-ref="transactionPointcut" advice-ref="transactionAdvice" />

</aop:config>

</bean>

<list>

<value>me.gacl.service.*</value>

</list>

</property>

</bean>

<aop:config>

<aop:advisor advice-ref="druid-stat-interceptor" pointcut-ref="druid-stat-pointcut" />

</aop:config>

</beans>

　　到此，相关的配置文件算是编写完成了，如下图所示：

4.3、进行单元测试

　　经过以上两个步骤，spring4与mybatis3的整合算是全部完成了。接下来我们要做的工作就算进行单元测试，测试一下spring4与mybatis3的整合是否成功。

　　1、在src/main/java目录下创建一个me.gacl.service包，然后在me.gacl.service包创建一个UserServiceI接口，如下所示：

1 package me.gacl.service;

3 import me.gacl.domain.User;

5 public interface UserServiceI {

7 /**

8 * 添加用户

9 * @param user

10 */

11 void addUser(User user);

13 /**

14 * 根据用户id获取用户

15 * @param userId

16 * @return

17 */

18 User getUserById(String userId);

19 }

　　2、在src/main/java目录下创建一个me.gacl.service.impl包，然后在me.gacl.service.impl包创建一个针对UserServiceI接口的实现类：UserServiceImpl，如下所示：

1 package me.gacl.service.impl;

3 import org.springframework.beans.factory.annotation.Autowired;

4 import org.springframework.stereotype.Service;

5 import me.gacl.dao.UserMapper;

6 import me.gacl.domain.User;

7 import me.gacl.service.UserServiceI;

9 /**

10 * @author gacl

11 * 使用@Service注解将UserServiceImpl类标注为一个service

12 * service的id是userService

13 */

14 @Service("userService")

15 public class UserServiceImpl implements UserServiceI {

17 /**

18 * 使用@Autowired注解标注userMapper变量，

19 * 当需要使用UserMapper时，Spring就会自动注入UserMapper

20 */

21 @Autowired

22 private UserMapper userMapper;//注入dao

24 @Override

25 public void addUser(User user) {

26 userMapper.insert(user);

27 }

29 @Override

30 public User getUserById(String userId) {

31 return userMapper.selectByPrimaryKey(userId);

32 }

33 }

　　创建好的两个类如下所示：

　　3、在src/test/java目录下编写单元测试类，新建一个me.gacl.test包，然后在这个包下创建一个MyBatisTest类，代码如下：

1 package me.gacl.test;

3 import java.util.Date;

4 import java.util.UUID;

5 import me.gacl.domain.User;

6 import me.gacl.service.UserServiceI;

7 //import me.gacl.service.UserServiceI;

8 import org.junit.Before;

9 import org.junit.Test;

10 import org.springframework.context.ApplicationContext;

11 import org.springframework.context.support.ClassPathXmlApplicationContext;

13 public class MyBatisTest {

15 private UserServiceI userService;

17 /**

18 * 这个before方法在所有的测试方法之前执行，并且只执行一次

19 * 所有做Junit单元测试时一些初始化工作可以在这个方法里面进行

20 * 比如在before方法里面初始化ApplicationContext和userService

21 */

22 @Before

23 public void before(){

24 //使用"spring.xml"和"spring-mybatis.xml"这两个配置文件创建Spring上下文

25 ApplicationContext ac = new ClassPathXmlApplicationContext(new String[]{"spring.xml","spring-mybatis.xml"});

26 //从Spring容器中根据bean的id取出我们要使用的userService对象

27 userService = (UserServiceI) ac.getBean("userService");

28 }

30 @Test

31 public void testAddUser(){

32 //ApplicationContext ac = new ClassPathXmlApplicationContext(new String[]{"spring.xml","spring-mybatis.xml"});

33 //UserServiceI userService = (UserServiceI) ac.getBean("userService");

34 User user = new User();

35 user.setUserId(UUID.randomUUID().toString().replaceAll("-", ""));

36 user.setUserName("白虎神皇xdp");

37 user.setUserBirthday(new Date());

38 user.setUserSalary(10000D);

39 userService.addUser(user);

40 }

42 }

　　执行单元测试代码，这时候会报如下错误：

　　错误提示是说没有找到"me.gacl.test.MyBatisTest"这个类，这是因为我们没有使用maven编译项目中的类的缘故。

　　下面我们使用Maven编译项目，选中项目的pom.xml文件→【Debug As】→【maven install】，如下所示：

编译结果如下：

　　在这里说一下我执行Maven install之后遇到的问题，第一次执行Maven install命令时，就出现了如下一堆乱七八糟的错误：

　　后来我把项目删掉，再重新导入项目，然后再执行Clean项目操作之后，如下图所示：

　　再执行Maven install操作又可以正常编译通过了，这让我郁闷了好久，这应该不是我项目配置的原因，而是Maven的原因，具体也不知道为啥会这样。反正这算是一种解决办法吧，如果遇到执行Maven install操作不能正常编译通过的情况：可以尝试采用：Maven clean→Clean项目→Maven install这三个步骤去解决问题。

　　除了可以用常规的Junit进行单元测试之外，我们还可以使用Spring提供的Junit测试框架进行单元测试，在me.gacl.test下新建一个MyBatisTestBySpringTestFramework类，代码如下：

1 package me.gacl.test;

3 import java.util.Date;

4 import java.util.UUID;

5 import me.gacl.domain.User;

6 import me.gacl.service.UserServiceI;

7 import org.junit.Test;

8 import org.junit.runner.RunWith;

9 import org.springframework.beans.factory.annotation.Autowired;

10 import org.springframework.test.context.ContextConfiguration;

11 import org.springframework.test.context.junit4.SpringJUnit4ClassRunner;

13 @RunWith(SpringJUnit4ClassRunner.class)

14 //配置了@ContextConfiguration注解并使用该注解的locations属性指明spring和配置文件之后，

15 @ContextConfiguration(locations = {"classpath:spring.xml", "classpath:spring-mybatis.xml" })

16 public class MyBatisTestBySpringTestFramework {

18 //注入userService

19 @Autowired

20 private UserServiceI userService;

22 @Test

23 public void testAddUser(){

24 User user = new User();

25 user.setUserId(UUID.randomUUID().toString().replaceAll("-", ""));

26 user.setUserName("xdp_gacl_白虎神皇");

27 user.setUserBirthday(new Date());

28 user.setUserSalary(10000D);

29 userService.addUser(user);

30 }

32 @Test

33 public void testGetUserById(){

34 String userId = "fb1c5941094e400b975f10d9a9d602a3";

35 User user = userService.getUserById(userId);

36 System.out.println(user.getUserName());

37 }

38 }

　　执行这两个测试方法，是可以正常测试通过的，如下所示：

　　到此，我们框架的整合测试工作就算是全部通过了，整合成功。

4.4、在web服务器中进行测试

　　1、编辑web.xml文件，添加spring监听器配置项，内容如下：

<?xml version="1.0" encoding="UTF-8"?>

<web-app xmlns="http://java.sun.com/xml/ns/javaee" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

xsi:schemaLocation="http://java.sun.com/xml/ns/javaee

http://java.sun.com/xml/ns/javaee/web-app_3_0.xsd"

version="3.0">

<welcome-file-list>

<welcome-file>index.jsp</welcome-file>

</welcome-file-list>

<description>Spring监听器</description>

<listener-class>org.springframework.web.context.ContextLoaderListener</listener-class>

</listener>

<context-param>

<param-name>contextConfigLocation</param-name>

<param-value>classpath:spring.xml,classpath:spring-mybatis.xml</param-value>

</context-param>

</web-app>

　　2、在UserMapper接口中添加一个获取所有用户信息的getAllUser()方法，如下所示：

1 package me.gacl.dao;

3 import java.util.List;

5 import me.gacl.domain.User;

7 public interface UserMapper {

8 int deleteByPrimaryKey(String userId);

10 int insert(User record);

12 int insertSelective(User record);

14 User selectByPrimaryKey(String userId);

16 int updateByPrimaryKeySelective(User record);

18 int updateByPrimaryKey(User record);

20 /**获取所有用户信息

21 * @return List<User>

22 */

23 List<User> getAllUser();

24 }

　　3、在UserMapper.xml文件中编写getAllUser()方法要执行的SQL语句，如下所示：

<?xml version="1.0" encoding="UTF-8" ?>

<!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd" >

</resultMap>

user_id, user_name, user_birthday, user_salary

</sql>

select

from t_user

where user_id = #{userId,jdbcType=CHAR}

</select>

delete from t_user

where user_id = #{userId,jdbcType=CHAR}

</delete>

insert into t_user (user_id, user_name, user_birthday,

user_salary)

values (#{userId,jdbcType=CHAR}, #{userName,jdbcType=VARCHAR}, #{userBirthday,jdbcType=DATE},

#{userSalary,jdbcType=DOUBLE})

</insert>

insert into t_user

user_id,

</if>

user_name,

</if>

user_birthday,

</if>

user_salary,

</if>

</trim>

#{userId,jdbcType=CHAR},

</if>

#{userName,jdbcType=VARCHAR},

</if>

#{userBirthday,jdbcType=DATE},

</if>

#{userSalary,jdbcType=DOUBLE},

</if>

</trim>

</insert>

update t_user

<set >

user_name = #{userName,jdbcType=VARCHAR},

</if>

user_birthday = #{userBirthday,jdbcType=DATE},

</if>

user_salary = #{userSalary,jdbcType=DOUBLE},

</if>

</set>

where user_id = #{userId,jdbcType=CHAR}

</update>

update t_user

set user_name = #{userName,jdbcType=VARCHAR},

user_birthday = #{userBirthday,jdbcType=DATE},

user_salary = #{userSalary,jdbcType=DOUBLE}

where user_id = #{userId,jdbcType=CHAR}

</update>

select user_id, user_name, user_birthday, user_salary from t_user

</select>

</mapper>

　　4、在UserServiceI接口中也添加一个getAllUser()方法，如下：

1 package me.gacl.service;

3 import java.util.List;

5 import me.gacl.domain.User;

7 public interface UserServiceI {

9 /**

10 * 添加用户

11 * @param user

12 */

13 void addUser(User user);

15 /**

16 * 根据用户id获取用户

17 * @param userId

18 * @return

19 */

20 User getUserById(String userId);

22 /**获取所有用户信息

23 * @return List<User>

24 */

25 List<User> getAllUser();

26 }

　　5、在UserServiceImpl类中实现getAllUser方法，如下：

1 package me.gacl.service.impl;

3 import java.util.List;

5 import org.springframework.beans.factory.annotation.Autowired;

6 import org.springframework.stereotype.Service;

7 import me.gacl.dao.UserMapper;

8 import me.gacl.domain.User;

9 import me.gacl.service.UserServiceI;

11 /**

12 * @author gacl

13 * 使用@Service注解将UserServiceImpl类标注为一个service

14 * service的id是userService

15 */

16 @Service("userService")

17 public class UserServiceImpl implements UserServiceI {

19 /**

20 * 使用@Autowired注解标注userMapper变量，

21 * 当需要使用UserMapper时，Spring就会自动注入UserMapper

22 */

23 @Autowired

24 private UserMapper userMapper;//注入dao

26 @Override

27 public void addUser(User user) {

28 userMapper.insert(user);

29 }

31 @Override

32 public User getUserById(String userId) {

33 return userMapper.selectByPrimaryKey(userId);

34 }

36 @Override

37 public List<User> getAllUser() {

38 return userMapper.getAllUser();

39 }

40 }

　　6、在src/main/java目录下创建一个me.gacl.web.controller包，然后在me.gacl.web.controller下创建一个UserServlet，如下：

1 package me.gacl.web.controller;

3 import java.io.IOException;

4 import java.util.List;

6 import javax.servlet.ServletException;

7 import javax.servlet.annotation.WebServlet;

8 import javax.servlet.http.HttpServlet;

9 import javax.servlet.http.HttpServletRequest;

10 import javax.servlet.http.HttpServletResponse;

12 import org.springframework.context.ApplicationContext;

13 import org.springframework.web.context.support.WebApplicationContextUtils;

15 import me.gacl.domain.User;

16 import me.gacl.service.UserServiceI;

18 /**

19 * @author gacl

20 * @WebServlet是Servlet3.0提供的注解，目的是将一个继承了HttpServlet类的普通java类标注为一个Servlet

21 * UserServlet使用了@WebServlet标注之后，就不需要在web.xml中配置了

22 */

23 @WebServlet("/UserServlet")

24 public class UserServlet extends HttpServlet {

26 //处理业务逻辑的userService

27 private UserServiceI userService;

29 public void doGet(HttpServletRequest request, HttpServletResponse response)

30 throws ServletException, IOException {

31 //获取所有的用户信息

32 List<User> lstUsers = userService.getAllUser();

33 request.setAttribute("lstUsers", lstUsers);

34 request.getRequestDispatcher("/index.jsp").forward(request, response);

35 }

37 public void doPost(HttpServletRequest request, HttpServletResponse response)

38 throws ServletException, IOException {

39 this.doGet(request, response);

40 }

42 public void init() throws ServletException {

43 //在Servlet初始化时获取Spring上下文对象(ApplicationContext)

44 ApplicationContext ac = WebApplicationContextUtils.getWebApplicationContext(this.getServletContext());

45 //从ApplicationContext中获取userService

46 userService = (UserServiceI) ac.getBean("userService");

47 }

48 }

　　7、编辑index.jsp页面，用于展示查询到的用户信息，内容如下：

<%@ page language="java" pageEncoding="UTF-8"%>

<%--引入JSTL核心标签库 --%>

<%@ taglib prefix="c" uri="http://java.sun.com/jsp/jstl/core"%>

<!DOCTYPE html>

<html>

<head>

<title>显示用户信息</title>

table,td{

border: 1px solid;

border-collapse: collapse;

}

</style>

</head>

<body>

<table>

<tr>

</tr>

<%--遍历lstUsers集合中的User对象 --%>

<c:forEach var="user" items="${lstUsers}">

<tr>

<td>${user.userId}</td>

<td>${user.userName}</td>

<td>${user.userBirthday}</td>

<td>${user.userSalary}</td>

</tr>

</c:forEach>

</table>

</body>

</html>

　　8、执行maven install命令编译项目，然后将项目部署到tomcat服务器中运行，注意，由于要使用Servlet3.0，所以必须将项目部署到tomcat7.x以上的服务器中去运行，如下所示：

　　输入地址：http://localhost:8080/spring4-mybatis3/UserServlet 访问UserServlet，访问结果如下：

　　可以看到，t_user表中的用户信息全部查询出来显示到页面上了。这样在web服务器中的测试也正常通过了。

　　以上就是Spring4.x与MyBatis3.x整合的全部内容了。编写这个整合例子花了不少时间，使用Maven编译时总是出现莫名其妙的问题，有时候成功，有时候失败，反正很莫名其妙。如果遇到执行Maven install操作不能正常编译通过的情况：可以尝试采用：Maven clean→Clean项目→Maven install这三个步骤去解决问题

（全文完）

时间： 2024-11-04 21:18:25

Mybatis应用简介

Mybatis应用简介的相关文章

Unit07： MyBatis框架简介、 MyBatis基本应用

MyBatis框架简介

MyBatis 框架简介

Java单体应用 - 常用框架 - 08.MyBatis - Druid 简介

mybatis 之简介，开发详细步骤

MyBatis原理简介和小试牛刀

Mybatis架构简介

Mybatis Plus简介

mybatis基础简介