MyBatis進階--接口代理方式實現Dao 和動態SQL

本文轉載自查看原文 2021-05-23 22:26 294 MyBatis

MyBatis接口代理方式實現Dao層

接口代理方式-實現規則

傳統方式實現Dao層，我們既要寫接口。還要寫實現類。而MyBatis框架可以幫助我們省略寫Dao層接口實現類的步驟。程序員只需要編寫接口，由MyBatis框架根據接口的定義來創

1該接口的動態代理對象。

實現規則：

　　1.映射配置文件中的名稱空間必須和Dao層接口的全類名相同

　　2.映射配置文件中的增刪改查標簽的id屬性必須和Dao層接口的方法名相同

　　3.映射配置文件中的增刪改查標簽的paramrterType屬性必須和Dao層接口方法的參數相同

　　4.映射配置文件中的增刪改查標簽的resultType屬性必須和Dao層接口方法的返回值相同

接口代理方式-代碼實現

1.刪除mapper層接口的實現類

2.修改映射配置文件

3.修改service層接口的實現類，采用接口代理方式實現功能

刪除mapper層接口的實現類

修改映射配置文件

package com.itheima.service.impl;

import com.itheima.bean.Student;
import com.itheima.mapper.StudentMapper;
import com.itheima.service.StudentService;
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 java.io.IOException;
import java.io.InputStream;
import java.util.List;
/*
    業務層實現類
 */
public class StudentServiceImpl implements StudentService {

    @Override
    public List<Student> selectAll() {
        List<Student> list = null;
        SqlSession sqlSession = null;
        InputStream is = null;
        try{
            //1.加載核心配置文件
            is = Resources.getResourceAsStream("MyBatisConfig.xml");

            //2.獲取SqlSession工廠對象
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);

            //3.通過工廠對象獲取SqlSession對象
            sqlSession = sqlSessionFactory.openSession(true);

            //4.獲取StudentMapper接口的實現類對象
            StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl();

            //5.通過實現類對象調用方法，接收結果
            list = mapper.selectAll();

        } catch (Exception e) {

        } finally {
            //6.釋放資源
            if(sqlSession != null) {
                sqlSession.close();
            }
            if(is != null) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

        //7.返回結果
        return list;
    }

    @Override
    public Student selectById(Integer id) {
        Student stu = null;
        SqlSession sqlSession = null;
        InputStream is = null;
        try{
            //1.加載核心配置文件
            is = Resources.getResourceAsStream("MyBatisConfig.xml");

            //2.獲取SqlSession工廠對象
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);

            //3.通過工廠對象獲取SqlSession對象
            sqlSession = sqlSessionFactory.openSession(true);

            //4.獲取StudentMapper接口的實現類對象
            StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl();

            //5.通過實現類對象調用方法，接收結果
            stu = mapper.selectById(id);

        } catch (Exception e) {

        } finally {
            //6.釋放資源
            if(sqlSession != null) {
                sqlSession.close();
            }
            if(is != null) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

        //7.返回結果
        return stu;
    }

    @Override
    public Integer insert(Student stu) {
        Integer result = null;
        SqlSession sqlSession = null;
        InputStream is = null;
        try{
            //1.加載核心配置文件
            is = Resources.getResourceAsStream("MyBatisConfig.xml");

            //2.獲取SqlSession工廠對象
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);

            //3.通過工廠對象獲取SqlSession對象
            sqlSession = sqlSessionFactory.openSession(true);

            //4.獲取StudentMapper接口的實現類對象
            StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl();

            //5.通過實現類對象調用方法，接收結果
            result = mapper.insert(stu);

        } catch (Exception e) {

        } finally {
            //6.釋放資源
            if(sqlSession != null) {
                sqlSession.close();
            }
            if(is != null) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

        //7.返回結果
        return result;
    }

    @Override
    public Integer update(Student stu) {
        Integer result = null;
        SqlSession sqlSession = null;
        InputStream is = null;
        try{
            //1.加載核心配置文件
            is = Resources.getResourceAsStream("MyBatisConfig.xml");

            //2.獲取SqlSession工廠對象
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);

            //3.通過工廠對象獲取SqlSession對象
            sqlSession = sqlSessionFactory.openSession(true);

            //4.獲取StudentMapper接口的實現類對象
            StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl();

            //5.通過實現類對象調用方法，接收結果
            result = mapper.update(stu);

        } catch (Exception e) {

        } finally {
            //6.釋放資源
            if(sqlSession != null) {
                sqlSession.close();
            }
            if(is != null) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

        //7.返回結果
        return result;
    }

    @Override
    public Integer delete(Integer id) {
        Integer result = null;
        SqlSession sqlSession = null;
        InputStream is = null;
        try{
            //1.加載核心配置文件
            is = Resources.getResourceAsStream("MyBatisConfig.xml");

            //2.獲取SqlSession工廠對象
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);

            //3.通過工廠對象獲取SqlSession對象
            sqlSession = sqlSessionFactory.openSession(true);

            //4.獲取StudentMapper接口的實現類對象
            StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl();

            //5.通過實現類對象調用方法，接收結果
            result = mapper.delete(id);

        } catch (Exception e) {

        } finally {
            //6.釋放資源
            if(sqlSession != null) {
                sqlSession.close();
            }
            if(is != null) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

        //7.返回結果
        return result;
    }
}

修改service層接口的實現類，采用接口代理方式實現功能

接口代理方式-源碼分析

分析動態代理對象如何生成的？

　　通過動態代理開發的模式，我們只需要編寫一個接口，不寫實現類，我們通過getMapper()方法最終獲取到

org.apache.ibatis.binding.MapperProxy代理對象，然后執行功能，而這個代理對象正是MyBatis使用了JDK的動態代理技術，幫助我們生成了代理實現類對象。從而可以進行相關持久化操作。

分析方法是如何執行的？

　　動態代理的實現類對象再執行方法的時候最終調用了maperMethod.execute()方法，這個方法中通過switch語句根據操作類型來判斷是新增，修改，刪除，查詢操作，最后一步回到了MMyBatis最原生的SqlSession方式來執行增刪改查。

接口代理方式小結

接口代理方式可以讓我們只編寫接口即可，而實現類對象由MyBatis生成。

實現規則：

　　1.映射配置文件中的名稱空間必須和Dao層接口的全類名相同

　　2.映射配置文件中的增刪改查標簽的id屬性必須和Dao層接口的方法名相同

　　3.映射配置文件中的增刪改查標簽的paramrterType屬性必須和Dao層接口方法的參數相同

　　4.映射配置文件中的增刪改查標簽的resultType屬性必須和Dao層接口方法的返回值相同

獲取動態代理對象

　　SqlSession功能類中的getMapper()方法

刪除mapper中的實現類，保留接口

在StudentMapper.xml中修改 <mapper namespace="com.itheima.mapper.StudentMapper">

更改service包下 StudentServiceImpl文件

package com.itheima.service.impl;

import com.itheima.bean.Student;
import com.itheima.mapper.StudentMapper;
import com.itheima.service.StudentService;
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 java.io.IOException;
import java.io.InputStream;
import java.util.List;
/*
    業務層實現類
 */
public class StudentServiceImpl implements StudentService {

    @Override
    public List<Student> selectAll() {
        List<Student> list = null;
        SqlSession sqlSession = null;
        InputStream is = null;
        try{
            //1.加載核心配置文件
            is = Resources.getResourceAsStream("MyBatisConfig.xml");

            //2.獲取SqlSession工廠對象
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);

            //3.通過工廠對象獲取SqlSession對象
            sqlSession = sqlSessionFactory.openSession(true);

            //4.獲取StudentMapper接口的實現類對象
            StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl();

            //5.通過實現類對象調用方法，接收結果
            list = mapper.selectAll();

        } catch (Exception e) {

        } finally {
            //6.釋放資源
            if(sqlSession != null) {
                sqlSession.close();
            }
            if(is != null) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

        //7.返回結果
        return list;
    }

    @Override
    public Student selectById(Integer id) {
        Student stu = null;
        SqlSession sqlSession = null;
        InputStream is = null;
        try{
            //1.加載核心配置文件
            is = Resources.getResourceAsStream("MyBatisConfig.xml");

            //2.獲取SqlSession工廠對象
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);

            //3.通過工廠對象獲取SqlSession對象
            sqlSession = sqlSessionFactory.openSession(true);

            //4.獲取StudentMapper接口的實現類對象
            StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl();

            //5.通過實現類對象調用方法，接收結果
            stu = mapper.selectById(id);

        } catch (Exception e) {

        } finally {
            //6.釋放資源
            if(sqlSession != null) {
                sqlSession.close();
            }
            if(is != null) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

        //7.返回結果
        return stu;
    }

    @Override
    public Integer insert(Student stu) {
        Integer result = null;
        SqlSession sqlSession = null;
        InputStream is = null;
        try{
            //1.加載核心配置文件
            is = Resources.getResourceAsStream("MyBatisConfig.xml");

            //2.獲取SqlSession工廠對象
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);

            //3.通過工廠對象獲取SqlSession對象
            sqlSession = sqlSessionFactory.openSession(true);

            //4.獲取StudentMapper接口的實現類對象
            StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl();

            //5.通過實現類對象調用方法，接收結果
            result = mapper.insert(stu);

        } catch (Exception e) {

        } finally {
            //6.釋放資源
            if(sqlSession != null) {
                sqlSession.close();
            }
            if(is != null) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

        //7.返回結果
        return result;
    }

    @Override
    public Integer update(Student stu) {
        Integer result = null;
        SqlSession sqlSession = null;
        InputStream is = null;
        try{
            //1.加載核心配置文件
            is = Resources.getResourceAsStream("MyBatisConfig.xml");

            //2.獲取SqlSession工廠對象
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);

            //3.通過工廠對象獲取SqlSession對象
            sqlSession = sqlSessionFactory.openSession(true);

            //4.獲取StudentMapper接口的實現類對象
            StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl();

            //5.通過實現類對象調用方法，接收結果
            result = mapper.update(stu);

        } catch (Exception e) {

        } finally {
            //6.釋放資源
            if(sqlSession != null) {
                sqlSession.close();
            }
            if(is != null) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

        //7.返回結果
        return result;
    }

    @Override
    public Integer delete(Integer id) {
        Integer result = null;
        SqlSession sqlSession = null;
        InputStream is = null;
        try{
            //1.加載核心配置文件
            is = Resources.getResourceAsStream("MyBatisConfig.xml");

            //2.獲取SqlSession工廠對象
            SqlSessionFactory sqlSessionFactory = new SqlSessionFactoryBuilder().build(is);

            //3.通過工廠對象獲取SqlSession對象
            sqlSession = sqlSessionFactory.openSession(true);

            //4.獲取StudentMapper接口的實現類對象
            StudentMapper mapper = sqlSession.getMapper(StudentMapper.class); // StudentMapper mapper = new StudentMapperImpl();

            //5.通過實現類對象調用方法，接收結果
            result = mapper.delete(id);

        } catch (Exception e) {

        } finally {
            //6.釋放資源
            if(sqlSession != null) {
                sqlSession.close();
            }
            if(is != null) {
                try {
                    is.close();
                } catch (IOException e) {
                    e.printStackTrace();
                }
            }
        }

        //7.返回結果
        return result;
    }
}

　　創建dynamic下測試類Test01

package com.itheima.dynamic;

import com.itheima.bean.Student;
import com.itheima.mapper.StudentMapper;
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.Test;

import java.io.IOException;
import java.io.InputStream;
import java.util.ArrayList;
import java.util.List;

public class Test01 {
    @Test
    public void selectCondition() throws Exception {
        InputStream is = Resources.getResourceAsStream("MyBatisConfig.xml");

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

        SqlSession sqlSession = sqlSessionFactory.openSession(true);

        StudentMapper mapper = sqlSession.getMapper(StudentMapper.class);

        Student stu=new Student();
        stu.setId(2);
        stu.setName("李四");
        //stu.setAge(23);
        List<Student> list = mapper.selectCondition(stu);

        for (Student student:list){
            System.out.println(student);
        }
        sqlSession.close();
        is.close();
    }
    @Test
    public void selectByIds() throws Exception {
        InputStream is = Resources.getResourceAsStream("MyBatisConfig.xml");

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

        SqlSession sqlSession = sqlSessionFactory.openSession(true);

        StudentMapper mapper = sqlSession.getMapper(StudentMapper.class);

       List<Integer> ids=new ArrayList<>();
       ids.add(1);
       ids.add(2);
        List<Student> list = mapper.selectByIds(ids);

        for (Student student:list){
            System.out.println(student);
        }
        sqlSession.close();
        is.close();
    }
}

MyBatis映射配置文件-----動態sql

動態SQL介紹

　　MyBatis映射配置文件中，前面我們的SQL都是比較簡單的，有些時候業務邏輯復雜時，我們的SQL就時動態變化的，此時在前面學習的SQL就不能滿足要求了。

　　多條件查詢

　　id：3 name：王五 age：25

 select * from Student where id=#{id} and name=#{name} and age=#{age}

　　id：3 name：王五

 select * from Student where id=#{id} and name=#{name}

　　動態sql標簽

<where>:條件標簽。如果有動態條件，則使用該標簽代替where關鍵字。

<if>:條件判斷標簽

<if test="條件判斷">

    查詢條件拼接
</if>

<foreach>:循環遍歷標簽。適用於多個參數或者的關系。

<foreach collection="" open="" close="" item="" separator="">
    獲取參數
</foreach>

　屬性：

　　collection：參數容器類型，（list-集合，array-數組）。

　　open：開始的sql語句

　　close：結束額sql語句

　　item：參數變量名

　　separator：分隔符

Sql片段抽取

我們可以將一些重復的SQL語句進行抽取，以達到復用的效果

<sql>:　　抽取SQL語句標簽

<sql id ="片段唯一標識" >抽取的SQL語句</sql>

<include>:引入SQL片段標簽

StudentMapper.xml

<?xml version="1.0" encoding="UTF-8" ?>
<!--MyBatis的DTD約束-->
<!DOCTYPE mapper
        PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN"
        "http://mybatis.org/dtd/mybatis-3-mapper.dtd">
<!--
    mapper:核心根標簽
    namespace屬性：名稱空間


-->
<mapper namespace="com.itheima.mapper.StudentMapper">
    <sql id="select">Select * FROM Student</sql>
    <!--
        select:查詢功能的標簽
        id屬性:唯一標識
        resultType屬性：指定結果映射對象的類型
        parameterType：指定參數映射對象類型
    -->
    <select id="selectAll" resultType="student">
        <include refid="select"/>
    </select>
    
    <select id="selectById" resultType="student" parameterType="int">
        <include refid="select"/> where id = #{id}
    </select>

    <insert id="insert" parameterType="student">
        Insert into Student values(#{id},#{name},#{age})
    </insert>

    <update id="update" parameterType="student">
        update Student set name =#{name},age=#{age} where id=#{id}
    </update>

    <delete id="delete" parameterType="int">
        delete from Student where id=#{id}
    </delete>
    <select id="selectCondition" resultType="student" parameterType="student">
        <include refid="select"/>
        <where>
            <if test="id!=null">
                id=#{id}
            </if>
            <if test="name!=null">
                and name=#{name}
            </if>
            <if test="age!=null">
                and age=#{age}
            </if>
        </where>
    </select>

    <select id="selectByIds" resultType="student" parameterType="list">
        <include refid="select"/>
        <where>
            <foreach collection="list" open="id in (" close=")" item="id" separator=",">
                #{id}
            </foreach>
        </where>
    </select>

</mapper>

　　動態SQL小結

動態SQL指的就是SQL語句可以根據條件或者參數的不同進行動態的變化

<where>:條件標簽

<if>:里面有個test標簽可以幫我們進行判斷

<foreach>:循環遍歷的標簽 collection="list" open="id in (" close=")" item="id" separator=","

<sql>:抽取SQL片段的標簽

<include>:引入SQL片段的標簽

免責聲明！

本站轉載的文章為個人學習借鑒使用，本站對版權不負任何法律責任。如果侵犯了您的隱私權益，請聯系本站郵箱yoyou2525@163.com刪除。

猜您在找 使用動態代理實現dao接口 Mybatis實現Mapper動態代理方式 MyBatis開發Dao層的兩種方式（Mapper動態代理方式） MyBatis開發Dao的原始Dao開發和Mapper動態代理開發 mybatis源碼學習--spring+mybatis注解方式為什么mybatis的dao接口不需要實現類 java 動態代理代理以及mybatis是如何用動態代理執行沒有實現的接口解析 Mybatis實現DAO層------------自動實現dao接口 mybatis之DAO層自動實現接口重學 Java 設計模式：實戰代理模式「模擬mybatis-spring中定義DAO接口，使用代理類方式操作數據庫原理實現場景」 java動態代理實現--基於接口的動態代理