Mybatis-Dao层开发之Mapper接口

<?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">
 
<!-- 命名空间，对sql进行分类化管理（sql隔离） -->
<mapper namespace="com.sw.mapper.UserMapper">
    <!-- 在映射文件中配置sql语句 -->
    <!-- 通过select执行查询，id用于标识映射文件中的sql(Statement-id)
    将sql语句封装到mappedstatement中
    #{}表示占位符
    parameterType-指定输入参数的类型
    #{id}-id表示输入的参数，参数名称就是id,如果输入参数是简单类型，#{}中的参数可以任意
    resultType-指定sql输出结果所映射的java对象类型
    -->
    <!-- 通过id查询用户表的记录 -->
    <select id="findUserById" parameterType="int" resultType="com.sw.po.User">
        select *from user where id=#{id}
    </select>
    
    <!-- 根据用户名称模糊查询用户信息 -->
    <!-- resultType-指定单条记录所映射的对象类型 
    ${}拼接sql串，接收参数的内容，不加任何修饰，拼接在sql中(存在sql漏洞)
    ${}接收输入参数的内容，如果传入的类型是简单类型，${}中只能使用value
    -->
    <select id="findUserByName" parameterType="java.lang.String" resultType="com.sw.po.User">
        SELECT *FROM USER WHERE username LIKE ‘%${value}%‘
    </select>
    
    <!-- 添加用户 -->
    <!-- 指定输入参数类型是pojo(包括用户信息)
        #{}中指定pojo（User）属性名,接收到pojo的属性值
        Mybatis通过OGNL获取对象的属性值
     -->
    <insert id="insertUser" parameterType="com.sw.po.User">
        <!-- 获取刚增加的记录主键 
            返回id到poio对象（User）
            SELECT LAST_INSERT_ID():得到刚插入金进去记录的主键值，只适用于自增逐主键
            keyProperty：将查询到的主键值设置到parameterType指定的对象User里面的用来做id的属性，这里是：id,
　　　　　　　　　　　　　　然后在执行插入的时候，从parameterType（也就是这里的User）的Id里面取出来，进行插入
            order:指SELECT LAST_INSERT_ID()的执行顺序，相对于insert来说（before/after）
            resultType:指定SELECT LAST_INSERT_ID()的结果类型
        -->
        <selectKey keyProperty="id" order="AFTER" resultType="java.lang.Integer">
            SELECT LAST_INSERT_ID()
</selectKey>
        INSERT INTO USER (id,username,birthday,sex,address) VALUES(#{id},#{username},#{birthday},#{sex},#{address})
       
        <!-- 使用mysql的uuid生成主键返回
             执行过程：
                首先通过uuid得到主键，然后将主键设置到id属性中
                其次在Inster执行的时候从User对象中取出id的属性值
         -->
       <!--   
　　　　  <selectKey keyProperty="id" order="BEFORE" resultType="java.lang.String">
             SELECT UUID()
         </selectKey>
       　INSERT INTO USER (id,username,birthday,sex,address) VALUES(#{id},#{username},#{birthday},#{sex},#{address})  
　　　　-->
    </insert>
    
    <!-- 根据id删除用户 -->
    <delete id="deleteUser" parameterType="java.lang.Integer">
        DELETE FROM USER WHERE id=#{id}
    </delete>
    
    <!-- 根据id更新用户 
        传入用户id以及相关更新信息
        #{id}:从输入的user对象中获取user的属性值
    -->
    <update id="updateUser" parameterType="com.sw.po.User">
        UPDATE USER SET username=#{username},birthday=#{birthday},sex=#{sex},address=#{address} WHERE id=#{id}
    </update>
</mapper>

package com.sw.mapper;
 
import java.util.List;
 
import com.sw.po.User;
 
/*
 *@Author swxctx
 *@time 2016年12月1日
 *@Explain:使用mapper接口（用户管理）,相当于dao接口
 */
public interface UserMapper {
    //根据id查询用户的信息
    public  User findUserById(int id)throws Exception;
    //根据用户名查看用户列表
    public List<User> findUserByName(String username)throws Exception;
    //添加用户
    public void insertUser(User user)throws Exception;
    //删除用户
    public void deleteUser(int id)throws Exception;
}

package com.sw.mapper.test;
 
import java.io.InputStream;
import java.util.Date;
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 org.junit.Before;
import org.junit.Test;
 
import com.sw.mapper.UserMapper;
import com.sw.po.User;
 
/*
 *@Author swxctx
 *@time 2016年12月1日
 *@Explain:
 */
public class UserMapperTest {
 
     private SqlSessionFactory sqlSessionFactory;
        @Before
        public void setUpBefore() throws Exception {
            //执行其他方法前需要创建SqlSessionFactory
            // mybatis配置文件
            String resource = "SqlMapConfig.xml";
            // 得到配置文件流
            InputStream inputStream = Resources.getResourceAsStream(resource);
 
            // 创建会话工厂，传入mybatis的配置文件信息
            sqlSessionFactory = new SqlSessionFactoryBuilder()
                    .build(inputStream);
        }
    
    @Test
    public void testFindUserById() throws Exception{
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //创建UserMapper对象，mybatis自动生成mapper代理对象
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
        //调用UserMapper方法
        User user = userMapper.findUserById(27);
        sqlSession.close();
        
        System.out.println(user);
    }
    
    @Test
    public void testFindUserByName() throws Exception{
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //创建UserMapper对象，mybatis自动生成mapper代理对象
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
        //调用UserMapper方法
        List<User> user = userMapper.findUserByName("王");
        
        sqlSession.close();
        
        System.out.println(user);
    }
 
    @Test
    public void testInsertUser()throws Exception{
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //创建UserMapper
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
        User user = new User();
        user.setUsername("李小二");
        user.setSex("1");
        user.setBirthday(new Date());
        user.setAddress("广州");
        
        //调用方法
        userMapper.insertUser(user);
        //提交事务
        sqlSession.commit();
        //释放资源
        sqlSession.close();
    }
    
    @Test
    public void testDeleteUser() throws Exception{
        SqlSession sqlSession = sqlSessionFactory.openSession();
        //创建UserMapper对象，mybatis自动生成mapper代理对象
        UserMapper userMapper = sqlSession.getMapper(UserMapper.class);
        //调用UserMapper方法
        userMapper.deleteUser(44);
        sqlSession.commit();
        sqlSession.close();
    }
}