原始Dao开发方法

dao接口

package dao;

import po.Items;

import java.util.List;

/**
 * Created by admin on 2017/7/1.
 */
public interface ItemsDao {

    //根据id查询商品信息
    public Items findItemsById(int id) throws Exception;

    //根据商品名列查询商品列表
    public List<Items> findItemsByName(String name) throws Exception;

    //添加商品信息
    public void insertItems(Items items) throws Exception;

    //删除商品信息
    public void deleteItems(int id) throws Exception;
}

dao接口实现类

package dao.impl;

import dao.ItemsDao;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import po.Items;

import java.util.List;

/**
 * Created by admin on 2017/7/1.
 */
public class ItemsDaoImpl implements ItemsDao {

    // 需要向dao实现类中注入SqlSessionFactory
    // 这里通过构造方法注入
    private SqlSessionFactory sqlSessionFactory;

    public ItemsDaoImpl(SqlSessionFactory sqlSessionFactory){
        this.sqlSessionFactory = sqlSessionFactory;
    }


    @Override
    public Items findItemsById(int id) throws Exception {
        SqlSession sqlSession = sqlSessionFactory.openSession();
        Items items = sqlSession.selectOne("mapper.ItemsMapper.findItemsById", id);
        //释放资源
        sqlSession.close();
        return items;
    }

    @Override
    public List<Items> findItemsByName(String name) throws Exception {
        SqlSession sqlSession = sqlSessionFactory.openSession();
        List<Items> list = sqlSession.selectList("mapper.ItemsMapper.findItemsByName", name);
        //释放资源
        sqlSession.close();
        return list;
    }

    @Override
    public void insertItems(Items items) throws Exception {

        SqlSession sqlSession = sqlSessionFactory.openSession();
        sqlSession.insert("mapper.ItemsMapper.insertItems", items);

        //提交事务
        sqlSession.commit();

        //释放资源
        sqlSession.close();
    }

    @Override
    public void deleteItems(int id) throws Exception {

        SqlSession sqlSession = sqlSessionFactory.openSession();
        sqlSession.delete("mapper.ItemsMapper.deleteItems",id);

        sqlSession.commit();
        sqlSession.close();
    }
}

映射文件ItensMapper.xml

<?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">
<!--
 namespace 命名空间，作用就是对sql进行分类化管理,理解为sql隔离
 注意：使用mapper代理方法开发，namespace有特殊重要的作用
 -->
<mapper namespace="mapper.ItemsMapper">

    <!-- 通过select执行数据库查询
    id:标识映射文件中的sql，称为statement的id
    将sql语句封装到mappedStatement对象中，所以将id称为statement的id
    parameterType:指定输入参数的类型
    #{}标示一个占位符,
    #{value}其中value表示接收输入参数的名称，如果输入参数是简单类型，那么#{}中的值可以任意。

    resultType：指定sql输出结果的映射的java对象类型，select指定resultType表示将单条记录映射成java对象
    -->
    <!-- public List<Items> queryItemsById(Integer id);-->
    <select id="queryItemsById" parameterType="int" resultType="po.Items">
        SELECT * FROM items WHERE id = #{id}
    </select>

    <!--    public Items findItemsById(int id) throws Exception;-->
    <select id="findItemsById" parameterType="int" resultType="po.Items">
        SELECT * FROM items WHERE id = #{id}
    </select>

    <!-- 根据商品名称模糊查询商品信息，可能返回多条
    resultType：指定就是单条记录所映射的java对象类型
    ${}:表示拼接sql串，将接收到参数的内容不加任何修饰拼接在sql中。
    使用${}拼接sql，引起 sql注入
    ${value}：接收输入参数的内容，如果传入类型是简单类型，${}中只能使用value
     -->
    <!--    public List<Items> findItemsByName(String name) throws Exception;-->
    <select id="findItemsByName" parameterType="string" resultType="po.Items">
        SELECT * FROM items WHERE name LIKE '%#{name}%'
    </select>
    
    <!--    public void insertItems(Items items) throws Exception;-->
    <select id="insertItesm" parameterType="po.Items">
        INSERT INTO items(name, price, detail, pic) VALUES (#{name},#{price},#{detail},#{pic})
    </select>

    <!--    public void deleteItems(int id) throws Exception;-->
    <select id="deleteItems" parameterType="int">
        DELETE FROM items WHERE  id = #{id}
    </select>
</mapper>

测试类Test02.java

package test;

/**
 * Created by admin on 2017/7/1.
 */
public class Test02 {

    private SqlSessionFactory sqlSessionFactory;
    // 此方法是在执行testFindUserById之前执行
    @Before
    public void setUp() throws IOException {
        // 创建sqlSessionFactory

        // mybatis配置文件
        String resource = "SqlMapConfig.xml";
        // 得到配置文件流
        InputStream inputStream = Resources.getResourceAsStream(resource);

        // 创建会话工厂，传入mybatis的配置文件信息
        sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
    }

    @org.junit.Test
    public void testFindItemsById() throws Exception {

        //创建ItemsDao对象
        ItemsDao itemsDao = new ItemsDaoImpl(sqlSessionFactory);

        //调用ItemsDao方法
        Items itemsById = itemsDao.findItemsById(2);

        System.out.println(itemsById);
    }
}

运行结果

图片.png

总结原始dao开发问题

1.dao接口实现类方法中存在大量模板方法，设想能否将这些代码提取出来，大大减轻程序员的工作量。

2.调用sqlsession方法时将statement的id硬编码了

3.调用sqlsession方法时传入的变量，由于sqlsession方法使用泛型，即使变量类型传入错误，在编译阶段也不报错，不利于程序员开发。

mapper代理方法

程序员只需要mapper接口（相当 于dao接口）

程序员还需要编写mapper.xml映射文件

程序员编写mapper接口需要遵循一些开发规范，mybatis可以自动生成mapper接口实现类代理对象。

开发规范

在mapper.xml中namespace等于mapper接口地址

<!--
 namespace 命名空间，作用就是对sql进行分类化管理,理解为sql隔离
 注意：使用mapper代理方法开发，namespace有特殊重要的作用
 -->
<mapper namespace="mapper.ItemsMapper">

• mapper.java接口中的方法名和mapper.xml中statement的id一致
• mapper.java接口中的方法输入参数类型和mapper.xml中statement的parameterType指定的类型一致。
• mapper.java接口中的方法返回值类型和mapper.xml中statement的resultType指定的类型一致。

<select id="findItemsById" parameterType="int" resultType="po.Items">
        SELECT * FROM items WHERE id = #{id}
    </select>

    //根据id查询商品信息
    public Items findItemsById(int id) throws Exception;

以上开发规范主要是对下边的代码进行统一生成：

 SqlSession sqlSession = sqlSessionFactory.openSession();
        Items items = sqlSession.selectOne("mapper.ItemsMapper.findItemsById", id);

代码部分

图片.png

可以在配置文件新建一个同样的mapper文件夹放映射文件，这样就可以和java代码分开

ItemsMapper.xml

<?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="mapper.ItemsMapper">

    <!-- public List<Items> queryItemsById(Integer id);-->
    <select id="queryItemsById" parameterType="int" resultType="po.Items">
        SELECT * FROM items WHERE id = #{id}
    </select>

    <!--    public Items findItemsById(int id) throws Exception;-->
    <select id="findItemsById" parameterType="int" resultType="po.Items">
        SELECT * FROM items WHERE id = #{id}
    </select>

    <!--    public List<Items> findItemsByName(String name) throws Exception;-->
    <select id="findItemsByName" parameterType="string" resultType="po.Items">
        SELECT * FROM items WHERE name LIKE '%#{name}%'
    </select>
    
    <!--    public void insertItems(Items items) throws Exception;-->
    <select id="insertItesm" parameterType="po.Items">
        INSERT INTO items(name, price, detail, pic) VALUES (#{name},#{price},#{detail},#{pic})
    </select>

    <!--    public void deleteItems(int id) throws Exception;-->
    <select id="deleteItems" parameterType="int">
        DELETE FROM items WHERE  id = #{id}
    </select>
</mapper>

SqlMapConfig.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE configuration
        PUBLIC "-//mybatis.org//DTD Config 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-config.dtd">
<configuration>
 <environments default="development">
        <environment id="development">
            <!-- 使用jdbc事务管理，事务控制由mybatis-->
            <transactionManager type="JDBC"/>
            <!-- 数据库连接池,由mybatis管理-->
            <dataSource type="POOLED">
                <property name="driver" value="com.mysql.jdbc.Driver"/>
                <property name="url" value="jdbc:mysql:///mybatis001"/>
                <property name="username" value="root"/>
                <property name="password" value="root"/>
            </dataSource>
        </environment>
    </environments>
   <mappers>
        <mapper resource="mapper/ItemsMapper.xml"/>
    </mappers>
</configuration>

ItemsMapper.java

package dao;

import po.Items;

import java.util.List;

/**
 * Created by admin on 2017/7/1.
 */
public interface ItemsMapper{

    //根据id查询商品信息
    public Items findItemsById(int id) throws Exception;

    //根据商品名列查询商品列表
    public List<Items> findItemsByName(String name) throws Exception;

    //添加商品信息
    public void insertItems(Items items) throws Exception;

    //删除商品信息
    public void deleteItems(int id) throws Exception;
}

Test03.java

package test;

import dao.ItemsDao;
import dao.impl.ItemsDaoImpl;
import mapper.ItemsMapper;
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.*;
import po.Items;

import java.io.InputStream;

/**
 * Created by admin on 2017/7/1.
 */
public class Test03 {
    private SqlSessionFactory sqlSessionFactory;
    //注解Before是在执行本类所有测试方法之前先调用这个方法
    @Before
    public void setup() throws Exception{
        //创建SqlSessionFactory
        String resource="SqlMapConfig.xml";
        //将配置文件加载成流
        InputStream inputStream = Resources.getResourceAsStream(resource);

        //创建会话工厂，传入mybatis配置文件的信息
        sqlSessionFactory=new SqlSessionFactoryBuilder().build(inputStream);
    }

    @org.junit.Test
    public void testFindItemsById() throws Exception{
        SqlSession sqlSession=sqlSessionFactory.openSession();

        //创建ItemsDao代理对象
        ItemsMapper mapper = sqlSession.getMapper(ItemsMapper.class);

        //调用userMapper的方法
        Items items =mapper.findItemsById(1);
        System.out.println(items.getName());
    }
}

运行结果

图片.png