Mybatis实现及原理

2018-06-28 9044

版权

本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

本文涉及的产品

RDS MySQL Serverless 基础系列，0.5-2RCU 50GB

云数据库 RDS MySQL，集群系列 2核4GB

云数据库 RDS MySQL，高可用系列 2核4GB

简介： 什么是Mybatis MyBatis 是一款优秀的持久层框架，它支持定制化 SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。MyBatis 可以使用简单的 XML 或注解来配置和映射原生信息，将接口和 Java 的 POJOs(Plain Old Java Objects,普通的 Java对象)映射成数据库中的记录。

什么是Mybatis

MyBatis 是一款优秀的持久层框架，它支持定制化 SQL、存储过程以及高级映射。MyBatis 避免了几乎所有的 JDBC 代码和手动设置参数以及获取结果集。MyBatis 可以使用简单的 XML 或注解来配置和映射原生信息，将接口和 Java 的 POJOs(Plain Old Java Objects,普通的 Java对象)映射成数据库中的记录。

Mybatis优势

与JDBC相比，减少了50%以上的代码量。
MyBatis实现了接口绑定,无需自己写DAO实现类.
MyBatis是最简单的持久化框架，小巧并且简单易学。
MyBatis相当灵活，不会对应用程序或者数据库的现有设计强加任何影响，SQL写在XML里，从程序代码中彻底分离，降低耦合度，便于统一管理和优化，并可重用

Mybatis简单实现

Mybatis主要是为了简化我们操纵数据库的过程，那么首先应该在本地的数据库建立一张表。

CREATE TABLE STUDENT (
  id          INT,
  name        VARCHAR(20),
  PRIMARY KEY (id)
);

向表中插入记录。

INSERT INTO student (id,name) VALUES (1,'A');
INSERT INTO student (id,name) VALUES (2,'B');
INSERT INTO student (id,name) VALUES (3,'C');
INSERT INTO student (id,name) VALUES (4,'D');
INSERT INTO student (id,name) VALUES (5,'E');
INSERT INTO student (id,name) VALUES (6,'F');
INSERT INTO student (id,name) VALUES (7,'F');
INSERT INTO student (id,name) VALUES (8,'G');
INSERT INTO student (id,name) VALUES (9,'H');
INSERT INTO student (id,name) VALUES (10,'I');

在IDEA中新建一个maven工程，并加入使用Mybatis相关依赖。

    <!-- 与连接数据库相关的依赖 -->
    <dependency>
      <groupId>mysql</groupId>
      <artifactId>mysql-connector-java</artifactId>
      <version>5.1.20</version>
    </dependency>
    <!-- 与Mybatis相关的依赖 -->
    <dependency>
      <groupId>org.mybatis</groupId>
      <artifactId>mybatis</artifactId>
      <version>3.4.0</version>
    </dependency>

编写domain类，此类中的属性与数据库中的列名一一对应。

package com.alibaba.mybatis.domain;

public class Student {
    private Integer id;
    
    private String name;

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }
    
    @Override
    public String toString() {
        return "[" + "id:" + id + " name:" + name + "]";
    }
}

编写dao层接口，不需要编写该接口的实现类。具体的原因会在下面进行具体的解释。这也是使用Mybatis后最大的困惑。

package com.alibaba.mybatis.mapper;

import com.alibaba.mybatis.domain.Student;

import java.util.List;

public interface StudentMapper {
    List<Student> findAll();
}

在这里我们要实现的是查询数据库的功能，因此，我们需要编写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">
<mapper namespace="com.alibaba.mybatis.mapper.StudentMapper">
    <select id="findAll" resultType="Student">
        select * from student
    </select>
</mapper>

配置mybatis-config文件，该文件的具体的路径为：src/main/resources。

<?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>
    <!-- 类型的别名 -->
    <typeAliases>
        <package name="com.alibaba.mybatis.domain"/>
    </typeAliases>
    <!-- 配置Mybatis运行环境 -->
    <environments default="development">
        <environment id="development">
            <!-- type="JDBC" 代表使用JDBC的提交和回滚来管理事务 -->
            <transactionManager type="JDBC"/>
            <!-- mybatis提供了3种数据源类型，分别是：POOLED,UNPOOLED,JNDI -->
            <!-- POOLED 表示支持JDBC数据源连接池 -->
            <!-- UNPOOLED 表示不支持数据源连接池 -->
            <!-- JNDI 表示支持外部数据源连接池 -->
            <dataSource type="POOLED">
                <!-- 数据库的具体配置 -->
                <!-- url表示你数据库的地址
                     username表示的是数据库的用户
                     password表示的是数据库的密码-->
                <property name="driver" value="com.mysql.jdbc.Driver"/>
                <property name="url" value="jdbc:mysql://localhost:3306/hongchen"/>
                <property name="username" value="root"/>
                <property name="password" value=""/>
            </dataSource>
        </environment>
    </environments>
    <!-- 注册StudentMapper.xml映射文件 -->
    <mappers>
        <package name="com.alibaba.mybatis.mapper"/>
    </mappers>
</configuration>

编写测试类

package com.alibaba.mybatis;

import java.io.Reader;

import org.apache.ibatis.io.Resources;
import org.apache.ibatis.session.SqlSession;
import org.apache.ibatis.session.SqlSessionFactory;
import org.apache.ibatis.session.SqlSessionFactoryBuilder;

public class DBTools {
    public static SqlSessionFactory sessionFactory;

    static{
        try {
            //使用MyBatis提供的Resources类加载mybatis的配置文件
            Reader reader = Resources.getResourceAsReader("mybatis-config.xml");
            //构建sqlSession的工厂
            sessionFactory = new SqlSessionFactoryBuilder().build(reader);
        } catch (Exception e) {
            e.printStackTrace();
        }

    }
    //创建能执行映射文件中sql的sqlSession
    public static SqlSession getSession(){
        return sessionFactory.openSession();
    }

}

package com.alibaba.mybatis;

import com.alibaba.mybatis.domain.Student;
import com.alibaba.mybatis.mapper.StudentMapper;
import org.apache.ibatis.session.SqlSession;

import java.util.List;

public class Demo {

    public static void main(String[] args) {
        selectAllUser();
    }

    /**
     * 查询所有的用户
     */
    private static void selectAllUser(){
        SqlSession session=DBTools.getSession();
        StudentMapper mapper=session.getMapper(StudentMapper.class);
        try {
            List<Student> user=mapper.findAll();
            System.out.println(user.toString());
            session.commit();
        } catch (Exception e) {
            e.printStackTrace();
            session.close();
        }
    }

}

执行Demo类中的main函数，得到如下的结果：

Mybatis技术内幕

在学习Mybatis过程中遇到一个一直困扰我很久的问题，在Mybatis中声明一个interface接口，没有编写任何实现类，Mybatis就能返回接口实例，并调用接口方法返回数据库中的数据。实现这个功能的底层原理主要是底层采用了jdk动态代理。

动态代理

动态代理的主要功能是：通过拦截器方法回调，对目标target方法进行增强。言外之意就是为了增强目标target方法，这句话确实是讲的没有错误，但是在动态代理的过程中我们也可以做到连目标tagert都不要的霸权。

自定义自动映射器Mapper

首先我们先不研究源码，通过仿照源码的格式来自定义我们的自动映射器。其中我们的domain类还是采用的上面的Student类，不过在原来的基础上加上一个带参构造器。

public class Student {
    private Integer id;

    private String name;

    public Student(Integer id,String name) {
        this.id=id;
        this.name=name;
    }

    public Integer getId() {
        return id;
    }

    public void setId(Integer id) {
        this.id = id;
    }

    public String getName() {
        return name;
    }

    public void setName(String name) {
        this.name = name;
    }

    @Override
    public String toString() {
        return "[" + "id:" + id + " name:" + name + "]";
    }
}

dao层接口中的方法改为getStudentById()。

public interface StudentMapper {

    public Student getStudentById(Integer id);
}

实现一个InvocationHandler。

import java.lang.reflect.InvocationHandler;
import java.lang.reflect.Method;
import java.lang.reflect.Proxy;

public class MapperProxy implements InvocationHandler {

    public <T> T newInstance(Class<T> clz) {
        return (T) Proxy.newProxyInstance(clz.getClassLoader(), new Class[] { clz }, this);
    }

    @Override
    public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
        if (Object.class.equals(method.getDeclaringClass())) {
            try {
                // 诸如hashCode()、toString()、equals()等方法，将target指向当前对象this
                return method.invoke(this, args);
            } catch (Throwable t) {
            }
        }
        
        return new Student((Integer) args[0], "hongchen.zhx");
    }
}

在MapperProxy类中，我们可以看到在执行Object对象的方法时，target被指向了this，此时target已经可以说是成为一个傀儡了。已经没有target什么事了。
编写测试代码进行测试。

public class Demo {
    public static void main(String[] args) {
        MapperProxy proxy = new MapperProxy();

        StudentMapper mapper = proxy.newInstance(StudentMapper.class);
        Student student= mapper.getStudentById(1001);

        System.out.println("ID:" + student.getId());
        System.out.println("Name:" + student.getName());

        System.out.println(mapper.toString());
    }
}

那么测试代码运行后的结果为：

真正的MapperProxy

通过以上自定义的Mapper映射器再来看相对应的源码就会轻松很多。

  @Override
  public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
    if (Object.class.equals(method.getDeclaringClass())) {
      try {
      //在执行诸如Object的方式时，target指向当前对象this。
        return method.invoke(this, args);
      } catch (Throwable t) {
        throw ExceptionUtil.unwrapThrowable(t);
      }
    }
    //从缓存中获取MapperMethod对象，如果缓存中没有，则创建新的MapperMethod对象并添加到缓存中。
    final MapperMethod mapperMethod = cachedMapperMethod(method);
    //调用MapperMethod.execute()方法执行sql语句。
    return mapperMethod.execute(sqlSession, args);
  }

Mybatis实现及原理

什么是Mybatis

Mybatis优势

Mybatis简单实现

Mybatis技术内幕

动态代理

自定义自动映射器Mapper

真正的MapperProxy

热门文章

最新文章

相关课程

相关电子书

热门

活动广场

任务中心

开发者评测

高校计划

乘风者计划

训练营

阿里云MVP

话题

直播

下载

镜像站

技术资料

插件

Mybatis实现及原理

什么是Mybatis

Mybatis优势

Mybatis简单实现

Mybatis技术内幕

动态代理

自定义自动映射器Mapper

真正的MapperProxy

热门文章

最新文章

相关课程

相关电子书