spring mvc与Mybatis整合——（三）增删改查

有了上篇文章中的环境基础，这里进一步做一些增删改查的实例。并附带源码下载链接。

一、配置文件的语法约束：

1、Mybatis的配置文件和接口的定义要有一定的规范约束，也是约定大于配置的一种表现，那就是配置文件中，增删改查的每一个方法的id要和接口中的方法一致，且大小写敏感。

2、在配置文件中增删改查方法有各自对应的标签：insert、delete、update、select。通常情况下都会有一个parameterType标签表示传入的参数类型。传递多个参数的时候，可以不在配置文件中使用该标签，但需在接口中配合注解。

3、多个参数的传递，还有两种方法：利用hashMap 、实体封装；mybatis 自身的多个参数传递方式。这里不做重点，后面会有介绍。

4、参数使用ognl的表达式语法，如：#{userName},#{userAge},#{userAddress}。

5、对于结果是集合类型的返回值使用resultMap标签标示。

6、association标签相当于一个component，可以打到复用的目的。

二、增删改查实例：

实例中包含了单表的增删改查和多表的联合查询，针对联合查询和hibernate的对象导航语法查询很类似，这里不用做过多解释，重点是具体语法的体会。



在上篇文章的基础上添加了Article实体，在接口中添加了单表增删改查的方法以及两个实体的联合查询，以及返回集合类型的方法。

1、接口的定义：

[java] view
plaincopy





/**

* 规则：接口中的方法名和参数和配置文件中的id和parameterType分别对应，sql写在配置文件中，参数和调用的类test中的方法一致

* sql语句中的参数和实体中的字段名一致，

* @author limin

*

*/

public interface IUserOperation {

/*

* 这里面有一个方法名 selectUserByID 必须与 User.xml 里面配置的 select 的id 对应（<select

* id="selectUserByID"）

*/

public User selectUserByID(int id);

//根据用户名查询用户列表

public List<User> selectUsers(String userName);

public void addUser(User user);

public void updateUser(User user);

public void deleteUser(int id);

public List<Article> getUserArticles(int id);

}

2、配置文件：

[html] view
plaincopy





<?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">

<mapper namespace="com.tgb.mybatis.inter.IUserOperation">

<!-- com.yihaomen.mybatis.model.UserMapper -->

<!-- resultType的值要和Configuration.xml中的实体User的别名相同 -->

<select id="selectUserByID" parameterType="int" resultType="User">

select * from user where id = #{id}

</select>

<!-- 为了返回list 类型而定义的returnMap -->

<resultMap type="User" id="resultListUser">

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

<result column="userName" property="userName" />

<result column="userAge" property="userAge" />

<result column="userAddress" property="userAddress" />

</resultMap>

<!-- 返回list 的select 语句，注意 resultMap 的值是指向前面定义好的 -->

<select id="selectUsers" parameterType="string" resultMap="resultListUser">

select * from user where userName like #{userName}

</select>

<!-- 执行增加操作的SQL语句。id和parameterType分别与IUserOperation接口中的addUser方法的名字和 参数类型一致。以#{name}的形式引用Student参数的name属性，MyBatis将使用反射读取Student参数

的此属性。#{name}中name大小写敏感。引用其他的gender等属性与此一致。useGeneratedKeys设置 为"true"表明要MyBatis获取由数据库自动生成的主

键；keyProperty="id"指定把获取到的主键值注入 到Student的id属性 -->

<insert id="addUser" parameterType="User" useGeneratedKeys="true"

keyProperty="id">

insert into user(userName,userAge,userAddress)

values(#{userName},#{userAge},#{userAddress})

</insert>

<!-- 更新的配置 -->

<update id="updateUser" parameterType="User">

update user set

userName=#{userName},userAge=#{userAge},userAddress=#{userAddress}

where id=#{id}

</update>

<!-- 删除配置 -->

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

delete from user where id=#{id}

</delete>

<!-- 多对一方法二：将 association 中对应的映射独立抽取出来，可以达到复用的目的。 -->

<!-- User 联合文章进行查询 方法之二的配置 (多对一的方式) -->

<resultMap id="resultUserArticleList" type="Article">

<id property="id" column="aid" />

<result property="title" column="title" />

<result property="content" column="content" />

<association property="user" javaType="User" resultMap="resultListUser" />

</resultMap>

<!-- 多对一的配置方法一： 根据用户id查询多个Article -->

<!-- <resultMap id="resultUserArticleList" type="Article">

<id property="id" column="aid" />

<result property="title" column="title" />

<result property="content" column="content" />

<association property="user" javaType="User">

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

<result property="userName" column="userName" />

<result property="userAddress" column="userAddress" />

</association>

</resultMap>

-->

<select id="getUserArticles" parameterType="int"

resultMap="resultUserArticleList">

select user.id,user.username,user.useraddress,article.id aid,article.title,article.content

from user,article

where user.id=article.userid and user.id=#{id}

</select>

</mapper>

同时需要在Configuration.xml中，增加了Article的部分，参照user即可。

对多对一的配置有两种方法，区别在于是否在association标签中复用resultMap标签，resultMap标签配置了一个list集合。

3、最后再给出测试文件：

[java] view
plaincopy





package com.tgb.test;

import java.io.Reader;

import java.util.List;

import org.apache.ibatis.io.Resources;

import org.apache.ibatis.session.SqlSession;

import org.apache.ibatis.session.SqlSessionFactory;

import org.apache.ibatis.session.SqlSessionFactoryBuilder;

import com.tgb.mybatis.inter.IUserOperation;

import com.tgb.mybatis.model.Article;

import com.tgb.mybatis.model.User;

/**

* 增加：天机后，必须提交事务，否则不会写入到数据库

* 更新：类似hibernate，要先查出后，之后再更新

* 也有类似的session.commit()

* @author limin

*

*/

public class Test {

private static SqlSessionFactory sqlSessionFactory;

private static Reader reader;

static {

try {

// 最终实现了从配置文件中配置工厂的初始化

reader = Resources.getResourceAsReader("Configuration.xml");

sqlSessionFactory = new SqlSessionFactoryBuilder().build(reader);

} catch (Exception e) {

e.printStackTrace();

}

}

public static SqlSessionFactory getSession() {

return sqlSessionFactory;

}

public void getUserList(String userName){

SqlSession session = sqlSessionFactory.openSession();

try {

IUserOperation userOperation=session.getMapper(IUserOperation.class);

List<User> users = userOperation.selectUsers(userName);

for(User user:users){

System.out.println(user.getId()+":"+user.getUserName()+":"+user.getUserAddress());

}

} finally {

session.close();

}

}

//增加后，必须提交事务，否则不会写入到数据库.

public void addUser(){

User user=new User();

user.setUserAddress("万达广场");

user.setUserName("陆逊");

user.setUserAge(80);

SqlSession session = sqlSessionFactory.openSession();

try {

IUserOperation userOperation=session.getMapper(IUserOperation.class);

userOperation.addUser(user);

session.commit();

System.out.println("当前增加的用户 id为:"+user.getId());

} finally {

session.close();

}

}

//类似hibernate，要先查出后，之后再更新

public void updateUser(){

//先得到用户,然后修改，提交。

SqlSession session = sqlSessionFactory.openSession();

try {

IUserOperation userOperation=session.getMapper(IUserOperation.class);

User user = userOperation.selectUserByID(2);

user.setUserAddress("上海东方明珠宝塔");

userOperation.updateUser(user);

session.commit();

} finally {

session.close();

}

}

/**

* 删除数据，删除一定要 commit.

* @param id

*/

public void deleteUser(int id){

SqlSession session = sqlSessionFactory.openSession();

try {

IUserOperation userOperation=session.getMapper(IUserOperation.class);

userOperation.deleteUser(id);

session.commit();

} finally {

session.close();

}

}

public void getUserArticles(int userid){

SqlSession session = sqlSessionFactory.openSession();

try {

IUserOperation userOperation=session.getMapper(IUserOperation.class);

List<Article> articles = userOperation.getUserArticles(userid);

for(Article article:articles){

System.out.println(article.getTitle()+":"+article.getContent()+

":作者是:"+article.getUser().getUserName()+":地址:"+

article.getUser().getUserAddress());

}

} finally {

session.close();

}

}

public static void main(String[] args) {

//测试接口返回用户list列表

Test testUser=new Test();

testUser.getUserList("%");

testUser.addUser();

testUser.updateUser();

testUser.deleteUser(2);

testUser.getUserArticles(1);

/*

SqlSession session = sqlSessionFactory.openSession();

try {

// 1、没有使用接口的测试

// 这里传入的参数是从User.xml文件中配置的

//User user = (User) session.selectOne("com.yihaomen.mybatis.model.UserMapper.selectUserByID", 1);

// 2、基于接口的测试:在接口的定义中，selectUserByID方法和配置文件中的方法名要一致，这里传入的是参数

IUserOperation userOperation = session.getMapper(IUserOperation.class);

User user = userOperation.selectUserByID(1);

System.out.println(user.getUserAddress());

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

} finally {

session.close();

} */

}

}

结果如图：



三、总结：

这篇文章主要是增删改查的一个实例，也包含了联合查询，重点是几种xml标签的使用，在使用的时候，可以从照猫画虎开始，有hibernate基础，理解Mybatis是很容易的。

相关源码可以从这里下载，自行测试。

版权声明：本文为博主原创文章，未经博主允许不得转载。