MyBatis 基于Mapper的增删改查示例(Spring IOC注入)

红太狼 2022-06-06 03:29 162阅读 0赞

代码:

#数据模型层

  1. package com.sunline.entity;
  3. import java.io.Serializable;
  5. public class User implements Serializable{
  6.    private Integer user_id;
  7.    private String  user_name;
  8.    private String  user_password;
  9.    private String  user_kind;
  10.    private Double  user_balance;
  11.    private String  user_status;
  12. public Integer getUser_id() {
  13.     return user_id;
  14. }
  15. public void setUser_id(Integer user_id) {
  16.     this.user_id = user_id;
  17. }
  18. public String getUser_name() {
  19.     return user_name;
  20. }
  21. public void setUser_name(String user_name) {
  22.     this.user_name = user_name;
  23. }
  24. public String getUser_password() {
  25.     return user_password;
  26. }
  27. public void setUser_password(String user_password) {
  28.     this.user_password = user_password;
  29. }
  30. public String getUser_kind() {
  31.     return user_kind;
  32. }
  33. public void setUser_kind(String user_kind) {
  34.     this.user_kind = user_kind;
  35. }
  36. public Double getUser_balance() {
  37.     return user_balance;
  38. }
  39. public void setUser_balance(Double user_balance) {
  40.     this.user_balance = user_balance;
  41. }
  42. public String getUser_status() {
  43.     return user_status;
  44. }
  45. public void setUser_status(String user_status) {
  46.     this.user_status = user_status;
  47. }
  48. @Override
  49. public String toString() {
  50.     return "User [user_id=" + user_id + ", user_name=" + user_name + ", user_password=" + user_password + ", user_kind="
  51.             + user_kind + ", user_balance=" + user_balance + ", user_status=" + user_status + "]";
  52. }
  54. }

#数据访问层

@数据操作Mapper映射文件

  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. <!-- namespace指用户自定义的命名空间。 -->  
  4. <mapper namespace="com.sunline.dao.UserMapper">  
  6.  <resultMap id="userResultMap" type="com.sunline.entity.User">  
  7.       <id property="id" column="user_id" />  
  8.       <result property="user_name" column="user_name"/>  
  9.       <result property="user_password" column="user_password"/>  
  10.       <result property="user_kind" column="user_kind"/>  
  11.       <result property="user_balance" column="user_balance"/>  
  12.       <result property="user_status" column="user_status"/>  
  13.  </resultMap>  
  15. <!-- insert操作，parameterType="user"表示该插入语句需要一个user对象作为参数，useGeneratedKeys="true"表示使用自动增长的主键 -->  
  16.   <insert id="saveUser" parameterType="com.sunline.entity.User" useGeneratedKeys="true" keyProperty="user_id">  
  17.         insert into user(user_name,user_password,user_kind,user_balance,user_status)
  18.         values(#{user_name},#{user_password},#{user_kind},#{user_balance},#{user_status})
  19.   </insert>  
  21.   <!-- delete操作 parameterType="int"表示该查询语句需要一个int类型的参数-->  
  22.   <delete id="DeleteUser" parameterType="int"> 
  23.       delete from user where user_id = #{user_id} 
  24.   </delete>  
  26.   <!-- update操作 ,parameterType="user"表示该更新语句需要一个user对象作为参数-->  
  27.   <update id="UpdateUser" parameterType="com.sunline.entity.User">  
  28.       update user set user_name = #{user_name},user_kind = #{user_kind} where user_id = #{user_id}
  29.   </update>  
  31.   <!-- select操作,parameterType="int"表示该查询语句需要一个int类型的参数,resultType="user"表示返回的是一个user对象 -->  
  32.   <select id="selectUser" parameterType="int" resultType="com.sunline.entity.User">  
  33.        select * from user where user_id = #{user_id}
  34.   </select>  
  36.   <!-- select操作 ,resultType="map"表示返回的是一个Map对象,使用列名做key，值做value -->  
  37.   <select id="findAll" resultType="com.sunline.entity.User">  
  38.       select * from user
  39.   </select>  
  41.   <select id="selectByIdLike" resultType="com.sunline.entity.User">
  42.       select * from user where user_status = '正常'
  43.       <!-- 可选条件，如果传进来的参数有user_id属性，则加上user_id查询条件 -->  
  44.       <if test="user_id != null">
  45.          and user_id = #{user_id}
  46.       </if>
  47.   </select>
  49.   <select id="selectUserLikeName"  resultType="com.sunline.entity.User">  
  50.   <bind name="pattern" value="'%' + _parameter.getUser_name() + '%'" />  
  51.         select * from user where user_name like #{pattern}
  52.   </select>  
  54.   <!-- set -->  
  55.   <update id="updateUser" parameterType="com.sunline.entity.User">  
  56.      update user  
  57.       <set>  
  58.           <if test="user_name != null">user_name=#{user_name},</if>  
  59.           <if test="user_password != null">user_password=#{user_password},</if>  
  60.           <if test="user_kind != null">user_kind=#{user_kind},</if>  
  61.           <if test="user_balance != null">user_balance=#{user_balance},</if>  
  62.           <if test="user_status != null">user_status=#{user_status},</if>  
  63.       </set>  
  64.      where user_id=#{user_id}  
  65.   </update> 
  67.   <!-- foreach -->  
  68.   <select id="selectUserIn" resultType="com.sunline.entity.User">  
  69.       select * from user where user_id in
  70.       <!-- 下面的格式是固定的 -->
  71.       <foreach item="item" index="index" collection="list" open="(" separator="," close=")">  
  72.             #{item}  
  73.       </foreach>  
  74.   </select>   
  76.     <!-- choose（when、otherwise） -->  
  77.   <select id="SelectUserChoose" parameterType="hashmap" resultType="com.sunline.entity.User">  
  78.       select * from user where user_status = '正常' 
  79.   <!-- 如果传入了user_id，就根据id查询，没有传入id就根据loginname和password查询，否则查询sex等于男的数据 -->  
  80.    <choose>  
  81.         <when test="user_id != null">  
  82.             and user_id = #{user_id}  
  83.         </when>  
  84.         <when test="user_name != null and user_password != null">  
  85.             and user_name = #{user_name} and user_password = #{user_password}  
  86.         </when>  
  87.         <otherwise>  
  88.             and user_kind = '客户'  
  89.         </otherwise>  
  90.     </choose>  
  91.   </select>  
  92. </mapper>

@动态SQL生产接口

  1. package com.sunline.dao;
  3. import java.util.HashMap;
  4. import java.util.List;
  6. import com.sunline.entity.User;
  8. public interface UserMapper {
  9.     //注意这里的接口命名必须和UserMapper.xml中的id定义完全一致
  10.     List<User> selectByIdLike(HashMap<String, Object> params); 
  11.     List<User> selectUserLikeName(User user);
  12.     void updateUser(User user);
  13.     List<User> selectUserIn(List<Integer> id);//根据传入的id查询员工  
  14.     List<User> SelectUserChoose(HashMap<String, Object> param);
  15. }

@数据访问类

  1. package com.sunline.dao;
  3. import java.util.HashMap;
  4. import java.util.List;
  6. import javax.annotation.Resource;
  8. import org.mybatis.spring.SqlSessionTemplate;
  9. import org.springframework.stereotype.Repository;
  11. import com.sunline.entity.User;
  13. @Repository(value="userDao")
  14. public class UserDao {
  16.    /*
  17.     * 基于注解实现
  18.     */
  19.    @Resource
  20.    public SqlSessionTemplate session;
  21.    public void setSqlSession(SqlSessionTemplate sqlSession) {    
  22.        this.session = sqlSession;    
  23.    }    
  25.    /*
  26.     * 添加用户
  27.     */
  28.    public void SaveUser(User user){
  29.        session.insert("com.sunline.dao.UserMapper.saveUser",user);
  30.    }
  32.    /*
  33.     * 删除指定id的用户
  34.     */
  35.    public void DeleteUser(int user_id){
  36.        session.delete("com.sunline.dao.UserMapper.DeleteUser", user_id);
  37.    }
  39.    /*
  40.     * 修改用户的某些字段
  41.     */
  42.    public void ModifyUser(User user){
  43.        session.update("com.sunline.dao.UserMapper.UpdateUser", user);
  44.    }
  46.    /*
  47.     * 查询指定id的用户
  48.     */
  49.    public User findById(int user_id){
  50.        return session.selectOne("com.sunline.dao.UserMapper.selectUser", user_id);
  51.    }
  53.    /*
  54.     * 查询所有用户
  55.     */
  56.    public List<User> findAll(){
  57.        return session.selectList("com.sunline.dao.UserMapper.findAll");
  58.    }
  60.    /*
  61.     * 动态SQL条件查询一
  62.     */
  63.    public List<User> findByIdLike(HashMap<String, Object> param){
  64.        UserMapper um = session.getMapper(UserMapper.class);
  65.        List<User> list=um.selectByIdLike(param);
  66.        return list;
  67.    }
  69.    /*
  70.     * 动态SQL条件查询二:根据传入的参数进行模糊查询
  71.     */
  72.    public List<User> selectUserLikeName(User user){
  73.        UserMapper um = session.getMapper(UserMapper.class);
  74.        List<User> list=um.selectUserLikeName(user);
  75.        return list;
  76.    }
  78.    /*
  79.     * 动态SQL条件查询三:动态更新员工 
  80.     */
  81.    public void UpdateUser(User user){
  82.        UserMapper um = session.getMapper(UserMapper.class);
  83.        um.updateUser(user);
  84.    }
  86.    /*
  87.     * 动态SQL条件查询四:foreach集合遍历查询
  88.     */
  89.    public List<User> SelectUserIn(List<Integer> ids){
  90.        UserMapper um = session.getMapper(UserMapper.class);
  91.        List<User> list = um.selectUserIn(ids);
  92.        return list;
  93.    }
  95.    /*
  96.     * 动态SQL条件查询五:choose条件查询
  97.     */
  98.    public List<User> SelectUserChoose(HashMap<String, Object> param){
  99.        UserMapper um = session.getMapper(UserMapper.class);
  100.        List<User> list = um.SelectUserChoose(param);
  101.        return list;
  102.    }
  103. }

#业务逻辑层

  1. package com.sunline.biz;
  3. import java.util.HashMap;
  4. import java.util.List;
  6. import org.springframework.beans.factory.annotation.Autowired;
  7. import org.springframework.beans.factory.annotation.Qualifier;
  8. import org.springframework.stereotype.Service;
  10. import com.sunline.dao.UserDao;
  11. import com.sunline.entity.User;
  13. @Service(value="userBiz")  
  14. public class UserBiz {
  15.     @Autowired  
  16.     @Qualifier("userDao")            //使用@Qualifier注解来说明使用哪一个实现类  
  17.     UserDao userDao;  
  19.     /*
  20.      * 添加用户
  21.      */
  22.     public void SaveUser(User user){
  23.         userDao.SaveUser(user);
  24.     }
  26.     /*
  27.      * 删除指定id的用户
  28.      */
  29.     public void DeleteUser(int user_id){
  30.         userDao.DeleteUser(user_id);
  31.     }
  33.     /*
  34.      * 修改用户的某些字段
  35.      */
  36.     public void ModifyUser(User user){
  37.         userDao.ModifyUser(user);
  38.     }
  40.     /*
  41.      * 查询指定id的用户
  42.      */
  43.     public User findById(int user_id){
  44.         return userDao.findById(user_id);
  45.     }
  47.     /*
  48.      * 查询所有用户
  49.      */
  50.     public List<User> findAll(){
  51.         return userDao.findAll();
  52.     }
  54.     /*
  55.      * 动态SQL条件查询一
  56.      */
  57.     public List<User> findByIdLike(HashMap<String, Object> param){
  58.         return userDao.findByIdLike(param);
  59.     }
  61.     /*
  62.      * 动态SQL条件查询二:根据传入的参数进行模糊查询
  63.      */
  64.     public List<User> selectUserLikeName(User user){
  65.         return userDao.selectUserLikeName(user);
  66.     }
  68.     /*
  69.      * 动态SQL条件查询三:动态更新员工 
  70.      */
  71.     public void UpdateUser(User user){
  72.         userDao.UpdateUser(user);
  73.     }
  75.     /*
  76.      * 动态SQL条件查询四:foreach集合遍历查询
  77.      */
  78.     public List<User> SelectUserIn(List<Integer> ids){
  79.         return userDao.SelectUserIn(ids);
  80.     }
  82.     /*
  83.      * 动态SQL条件查询五:choose条件查询
  84.      */
  85.     public List<User> SelectUserChoose(HashMap<String, Object> param){
  86.         return userDao.SelectUserChoose(param);
  87.     }
  88. }

#测试类

  1. package com.sunline.test;
  3. import java.util.ArrayList;
  4. import java.util.HashMap;
  5. import java.util.List;
  7. import org.springframework.context.ApplicationContext;
  8. import org.springframework.context.support.ClassPathXmlApplicationContext;
  10. import com.sunline.biz.UserBiz;
  11. import com.sunline.entity.User;
  13. public class Test {
  15.     public static void main(String[] args) {
  16.         // TODO Auto-generated method stub
  17.         ApplicationContext ctx = new ClassPathXmlApplicationContext("applicationContext.xml");
  18.         UserBiz userBiz = (UserBiz) ctx.getBean("userBiz");
  20.         /*
  21.          * 1.添加用户 
  22.          */
  23.         User user = new User();
  24.         user.setUser_name("张宇");
  25.         user.setUser_password("123456");
  26.         user.setUser_kind("客户");
  27.         user.setUser_status("正常");
  28.         user.setUser_balance(6500.0);
  30.         userBiz.SaveUser(user);
  32.         /*
  33.          * 2.删除指定id的用户
  34.          */
  35.         userBiz.DeleteUser(11);
  37.         /*
  38.          * 3.修改用户的某些字段
  39.          */
  40.         User user = new User();
  41.         user.setUser_id(10);
  42.         user.setUser_name("张恒宇");
  43.         user.setUser_kind("客户");
  44.         userBiz.ModifyUser(user);
  46.         /*
  47.          * 4.查询指定id的用户
  48.          */
  49.         User user = userBiz.findById(10);
  50.         System.out.println("用户信息为: "+user.getUser_name()+" "+user.getUser_password()
  51.                             +" "+user.getUser_status()+" "+user.getUser_kind()+" "+user.getUser_balance());
  53.         /*
  54.          * 5.查询所有用户
  55.          */
  56.         List<User> list = userBiz.findAll();
  57.         for(User user : list){
  58.         System.out.println("用户信息为: "+user.getUser_name()+" "+user.getUser_password()
  59.                            +" "+user.getUser_status()+" "+user.getUser_kind()+" "+user.getUser_balance());
  60.         }
  62.         /*
  63.          * 6.动态SQL条件查询一
  64.          */
  65.         HashMap<String, Object> params=new HashMap<String,Object>();  // 创建一个HashMap存储参数  
  66.         params.put("user_id", 10);
  67.         List<User> list = userBiz.findByIdLike(params);
  68.         for(User user : list){
  69.         System.out.println("用户信息为: "+user.getUser_name()+" "+user.getUser_password()
  70.                            +" "+user.getUser_status()+" "+user.getUser_kind()+" "+user.getUser_balance());
  71.         }
  73.         /*
  74.          * 7.动态SQL条件查询二:根据传入的参数进行模糊查询
  75.          */
  76.         User user = new User();
  77.         user.setUser_name("张");
  78.         List<User> list = userBiz.selectUserLikeName(user);
  79.         for(User us : list){
  80.         System.out.println("用户信息为: "+us.getUser_name()+" "+us.getUser_password()
  81.                            +" "+us.getUser_status()+" "+us.getUser_kind()+" "+us.getUser_balance());
  82.         }
  84.         /*
  85.          * 8.修改用户信息
  86.          */
  87.         User user = new User();
  88.         user.setUser_id(10);
  89.         user.setUser_name("张丰宇");
  90.         user.setUser_balance(12000.0);
  91.         userBiz.UpdateUser(user);
  93.         /*
  94.          * 9.foreach集合遍历查询
  95.          */
  96.         List<Integer> ids = new ArrayList<Integer>();
  97.         ids.add(8);
  98.         ids.add(9);
  99.         List<User> list = userBiz.SelectUserIn(ids);
  100.         for(User us : list){
  101.         System.out.println("用户信息为: "+us.getUser_name()+" "+us.getUser_password()
  102.                            +" "+us.getUser_status()+" "+us.getUser_kind()+" "+us.getUser_balance());
  103.         }
  105.         /*
  106.          * 10.choose条件查询
  107.          */
  108.         HashMap<String, Object> param = new HashMap<String, Object>();
  109.         param.put("user_id", 8);  
  110.         param.put("user_name", "张宇");  
  111.         param.put("user_password", "123456");
  112.         List<User> list = userBiz.SelectUserChoose(param);
  113.         for(User us : list){
  114.         System.out.println("用户信息为: "+us.getUser_name()+" "+us.getUser_password()
  115.                            +" "+us.getUser_status()+" "+us.getUser_kind()+" "+us.getUser_balance());
  116.         }
  117.     }
  119. }

发表评论

表情：
评论列表 （有 0 条评论，162人围观）

还没有评论，来说两句吧...

相关阅读