<三> MyBatis代理模式

概述

    我们首先要理解，代理模式是干什么的？我们知道，代理模式是用于松耦合的，其实代理模式是通过将主要业务与次要业务分开处理实现松耦合的。而代理模式的本质是在监控行为特征。

代理模式

    代理模式主要分两种，静态代理模式和动态代理模式，下面我们通过实现来看看两者的具体区别到底是什么。

静态代理模式

主要角色：

  接口（主题）：定义需要被监控的方法
  被代理类：接口的具体实现类
  代理类：代理被代理类的类

主要角色：

    1. 代理类和被代理类实现同一个主题接口。
    2. 代理类具备一个属性，为被代理类对象。

实现的目的：

    核心业务逻辑由被代理类去实现，非核心需求多变的逻辑，交给代理类实现。

代码实现案例：

接口（主题）
public interface Proxy {
     public abstract void todo();
}
被代理类
public class Reality implements Proxy {
    @Override
    public void todo() {
        System.out.println("我是核心功能......");
    }
}
代理类
public class ProxyReality implements Proxy {
    // 被代理对象
    private Proxy reality;

    //传入一个被代理对象
    public ProxyRole(Proxy proxy) {
        reality = proxy;
    }
    @Override
    public void todo() {
        //1. 代理类的前期准备
        doBefore();
        //2. 执行核心功能
        reality.todo();
        //3. 代理类的收尾工作
        doAfter();
    }
    private void doBefore() {
        System.out.println("我做非核心功能......");
    }
    private void doAfter() {
        System.out.println("我是多变的需求......");
    }
}
案例测试
public static void main(String[] args) {
    //1. 创建被代理对象
    Proxy reality = new RealityRole();
    //2. 创建代理对象，传入被代理对象
    ProxyRole proxyRole = new ProxyRole(reality);
    //3. 代理对象执行
    proxyRole.todo();
}
总结：
  1. 代理类和被代理类实现一样的接口。
  2. 代理类具有一个属性对象，值为被代理类。
  3. 执行时，调用代理类，再由代理类调用被代理类。

动态代理模式

主要角色：

  接口（主题）：定义需要被监控的方法
  被代理类：接口的具体实现类
  通知类：包含次要业务的具体实现和次要与主要的绑定
  监控对象（代理对象）：被监控实例对象，需要被监控的监控行为，具体通知类实例对象

实现的思路：

    1. 采用通知类的方式，通知类具备一个属性，为被代理类对象。
    2. 使用JDK的给通知类分配一个监控对象。
    3. 通知类统一实现InvocationHandler接口。

实现的目的：

    核心业务逻辑由被代理类去实现，非核心需求多变的逻辑，交给通知类实现，不需要一个具体的代理类，而是由JDK动态生成代理对象。

JDK方式代码实现案例：

接口（主题）
public interface Proxy {
     public abstract void todo();
}
被代理类
public class Reality implements Proxy {
    @Override
    public void todo() {
        System.out.println("我是核心功能......");
    }
}
通知类
public class ProxyReality implements InvocationHandler {
    // 被代理对象
    private Proxy reality;

    //传入一个被代理对象
    public ProxyRole(Proxy proxy) {
        reality = proxy;
    }
    /**
     * 在被监控的方法要被执行时，执行该方法
     * @param proxy 代理对象，例如小明.eat()
     * @param method 类似eat方法的封装对象
     * @param args  入参的数组
     */
    public Object invoke(Object proxy, Method method, Object[] args) {
        //0.接受主要业务返回的对象
        Object resultObj;
          //1. 代理类的前期准备
        doBefore();
         //2. 执行核心功能
         resultObj = method.invoke(proxy,args);
        //3. 代理类的收尾工作
        doAfter();
        return resultObj;
    }
    private void doBefore() {
        System.out.println("我做非核心功能......");
    }
    private void doAfter() {
        System.out.println("我是多变的需求......");
    }
}
代理工厂类
public class ProxyFactory {
    /**
     * JDK动态代理模式下，代理对象的数据类型应由监控行为来描述
     * @param obj 监控的类
     * @return
     */
    public static Proxy builder(Class obj) throws IllegalAccessException, InstantiationException {
        //1.实例化被监控对象
        Proxy $proxy= (Proxy) obj.newInstance();
        //2.实例化通知对象，将被监控对象传入
        InvocationHandler adviser = new ProxyReality($proxy);
        //2、向JVM申请一个负责监控被监控对象的代理对象
        Proxy proxy = (Proxy) Proxy.newProxyInstance($proxy.getClass().getClassLoader(),
                        $proxy.getClass().getInterfaces(),adviser);
        return proxy;
    }
}
案例测试
public static void main(String[] args) {
    //1. 创建被代理对象
    Proxy reality = ProxyFactory.builder(Reality.class);
    //2. 直接调用代理对象方法执行
    reality.todo();
}


MyBatis的动态代理模式

一、JDBC开发步骤

public void test(){
        Connection con = null;
        PreparedStatement ps = null;
        ResultSet rs = null;
        try {
            //1. 加载驱动
            Class.forName("com.mysql.jdbc.Driver");
            //2. 建立链接通道
            con = DriverManager.getConnection("jdbc:mysql://localhost:3306/mybatis", "root", "root");
           //3. 建立PreparedStament
            ps = con.prepareStatement("SELECT * FROM ...");
           //4. 输送SQL命令到数据库中执行，并带回运行结果
            rs = ps.executeQuery();
        } catch (ClassNotFoundException e) {
            e.printStackTrace();
        } catch (SQLException e) {
            e.printStackTrace();
        }finally {
            // 5. 销毁链接通道、PreparedStament和结果集对象
            try {
                if (rs != null) {
                    rs.close();
                    rs = null;
                }
                if (ps != null) {
                    ps.close();
                    ps = null;
                }
                if (con != null) {
                    con.close();
                    con = null;
                }
            } catch (SQLException e) {
                e.printStackTrace();
            }
        }
    }

二、MyBatis动态代理模式封装JDBC

1、JDBC的主要业务和次要业务

主要业务：输送SQL命令到数据库中执行，并带回运行结果
次要业务：加载驱动、建立链接通道、建立PreparedStament和销毁链接通道和PreparedStament

2、声明接口SqlSession（定义具体的方法行为）
/**
 * 定义被监控者接口
 */
public interface SqlSession {
    public int insert(String template,Object obj) throws SQLException;
    public int update(String template,Object obj) throws SQLException;
    public void delete(String template,Object obj) throws SQLException;
    public Object queryInfo(String template,Object obj) throws SQLException;
}
3、具体实现类被监控对象

主要业务：具体实现SQL命令执行

/**
 * 被监控对象实现
 */
public class SimpleSqlSession implements SqlSession {
    ParamentHandler parament;//入参处理器
    StatementHandler statement;//执行命令处理器
    ResultSetHandler resultSet;//结果集处理器
    PreparedStatement ps;

    /**
     * 初始化处理器
     */
    public SimpleSqlSession(){
        this.resultSet = new SimpleResultSetHandler();
        this.statement = new SimpleStatementHandler();
        this.parament = new SimpleParmentHandler();
    }
    public int insert(String template,Object obj) throws SQLException {
        String sql = parament.insert(template,obj);
        return statement.update(ps,sql);
    }
    public int update(String template,Object obj) throws SQLException {
        String sql = parament.insert(template,obj);
        return statement.update(ps,sql);
    }
    public void delete(String template,Object obj) throws SQLException {
        String sql = parament.insert(template,obj);
        statement.update(ps,sql);
    }
    public Object queryInfo(String template,Object obj) throws SQLException {
        String sql = parament.insert(template,obj);
        ResultSet object = statement.query(ps,sql);
        return resultSet.query(object);
    }
}

/**
 * 参数处理器接口
 */
public interface ParamentHandler{
    public String insert(String template,Object paremt);
    public String delete(String template,Object paremt);
    public String update(String template,Object paremt);
    public String query(String template,Object paremt);
}

/**
 * 参数处理器具体实现
 */
public class SimpleParmentHandler implements ParamentHandler {
    /**
     * 新增的参数处理
     */
    public String insert(String template, Object paremt) {
        String sql = null;
        //拼接入参和SQL模板
        return sql;
    }
    /**
     * 删除的参数处理
     */
    public String delete(String template, Object paremt) {
        String sql = null;
        //拼接入参和SQL模板
        return sql;
    }
    /**
     * 更新的参数处理
     */
    public String update(String template, Object paremt) {
        String sql = null;
        //拼接入参和SQL模板
        return sql;
    }
    /**
     * 查询的参数处理
     */
    public String query(String template, Object paremt) {
        String sql = null;
        //拼接入参和SQL模板
        return sql;
    }
}

/**
 * 命令执行处理器接口
 */
public interface  StatementHandler{
    public int update(PreparedStatement ps,String sql) throws SQLException;
    public ResultSet query(PreparedStatement ps, String sql) throws SQLException;
}

/**
 * 命令执行处理器具体实现
 */
public class SimpleStatementHandler implements StatementHandler{
    /**
     * 执行更新指令
     */
    public int update(PreparedStatement ps,String sql) throws SQLException {
        return ps.executeUpdate(sql);
    }
    /**
     * 执行查询指令
     */
    public ResultSet query(PreparedStatement ps, String sql) throws SQLException {
        return ps.executeQuery(sql);
    }
}

/**
 * 返回参数格式化处理器接口
 */
public interface ResultSetHandler {
    public Object query(ResultSet resultSet) throws SQLException;
}

/**
 * 返回参数格式化处理器具体实现
 */
public class SimpleResultSetHandler implements ResultSetHandler{

    public Object query(ResultSet resultSet) throws SQLException {
        //格式化为具体对象（反射赋值）
        resultSet.close();
        resultSet = null;
        return null;
    }
}
4、通知类：实现InvocationHandler，在构造方法定义具体入参SqlSession，实现具体次要业务。
/**
 * 通知类（实现次要业务）
 */
public class Plugin implements InvocationHandler {

    SqlSession session;
    Connection con = null;
    PreparedStatement ps = null;

    public Plugin(SqlSession session){
        this.session = session;
    }

    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        //1. 传值给会话对象
        setPreparedStatement();
        //2. 前置处理
        frontLoad();
        //3. 执行主要业务
        Object result = method.invoke(session,args);
        //4. 后置处理
        closeLoad();
        return result;
    }
    /**
     * 反射赋值
     */
    private void setPreparedStatement() throws NoSuchFieldException, IllegalAccessException {
        Field field = session.getClass().getDeclaredField("ps");
        field.setAccessible(true);
        field.set(session,ps);
    }
    /**
     * 前置处理
     * @throws Exception
     */
    private void frontLoad() throws Exception {
        Class.forName("com.mysql.jdbc.Driver");
        con = DriverManager.getConnection("jdbc:mysql://localhost:3306/mybatis", "root", "root");
        ps = con.prepareStatement("");
    }
    /**
     * 后置处理
     * @throws SQLException
     */
    private void closeLoad() throws SQLException {
        if (ps != null) {
            ps.close();
            ps = null;
        }
        if (con != null) {
            con.close();
            con = null;
        }
    }
}
5、实现代理工厂SqlSessionFactory
/**
 * 代理工厂
 */
public class SqlSessionFactory {
    /**
     * JDK动态代理模式下，代理对象的数据类型应由监控行为来描述
     * @param obj 监控的类
     * @return
     */
    public static SqlSession builder(Class obj) throws IllegalAccessException, InstantiationException {
        //1.创建被监控对象
        SqlSession session = (SqlSession) obj.newInstance();
        //2.创建通知对象
        InvocationHandler adviser = new Plugin(session);
        //2、向JVM申请一个负责监控被监控对象的代理对象
        SqlSession proxy = (SqlSession) Proxy.newProxyInstance(session.getClass().getClassLoader(),
                session.getClass().getInterfaces(),adviser);
        return proxy;
    }
}
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 211,348评论 6赞 491
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 90,122评论 2赞 385
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 156,936评论 0赞 347
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 56,427评论 1赞 283
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 65,467评论 6赞 385
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 49,785评论 1赞 290
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,931评论 3赞 406
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 37,696评论 0赞 266
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 44,141评论 1赞 303
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 36,483评论 2赞 327
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 38,625评论 1赞 340
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 34,291评论 4赞 329
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,892评论 3赞 312
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 30,741评论 0赞 21
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,977评论 1赞 265
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 46,324评论 2赞 360
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 43,492评论 2赞 348