MyBatis框架:第五章:源码解析及Mapper接口方式的mybatis的增,删,改,查实现

本文涉及的产品
公共DNS(含HTTPDNS解析),每月1000万次HTTP解析
云解析 DNS,旗舰版 1个月
全局流量管理 GTM,标准版 1个月
简介: MyBatis框架:第五章:源码解析及Mapper接口方式的mybatis的增,删,改,查实现

Mapper接口编程的命名习惯

Mapper接口方式的编程,需要先有一个接口。这个接口的命名一般是xxxxMapper。

比如:

User模块的Mapper,接口命名为UserMapper。

Book模块的Mapper,接口命名为BookMapper。

Mapper接口开发有四个开发规范必须遵守

1、对应的mapper配置文件的namespace属性值必须是Mapper接口的全类名。

2、Mapper接口中的方法名必须与mapper配置文件中对应的id值相同。

3、Mapper接口的方法的参数类型必须与mapper配置文件中配置的parameterType类型匹配上

4、Mapper接口的方法返回值类型必须与mapper配置文件中配置的resultType 类型匹配上

提前准备工作,准备好的项目

在mybatis-config.xml中配置你的库名我的是mybatis

<?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">
      <transactionManager type="JDBC"/>
      <!-- 修改数据库的四个连接属性  -->
      <dataSource type="POOLED">
        <property name="driver" value="com.mysql.jdbc.Driver"/>
        <property name="url" value="jdbc:mysql://localhost:3306/mybatis"/>
        <property name="username" value="root"/>
        <property name="password" value="root"/>
      </dataSource>
    </environment>
  </environments>
  <!-- 配置sql语句 的那个mapper配置文件 -->
  <mappers>
    <mapper resource="com/dao/UserMapper.xml"/>
  </mappers>
</configuration>

UserMapper代码:

public interface UserMapper {    
    // 保存用户
    public int saveUser(User user);    
    // 更新用户
    public int updateUser(User user);    
    // 根据id删除用户
    public int deleteUserById(int id);    
    // 根据id搜索用户
    public User findUserById(int id);    
    // 搜索全部用户
    public List<User> findUsers();
}

UserMapper.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="com.dao.UserMapper">
<!--  public Integer saveUser(User user); -->
  <insert id="saveUser" parameterType="com.pojo.User">
    insert into t_user(`last_name`,`sex`) values(#{lastName},#{sex})
  </insert>
<!--  public Integer updateUser(User user); -->
  <update id="updateUser" parameterType="com.pojo.User">
    update t_user set last_name = #{lastName} , sex = #{sex} where id = #{id}
  </update>
<!--  public Integer deleteUserById(Integer id); -->
  <delete id="deleteUserById">
    delete from t_user where id = #{id}
  </delete> 
<!--  public User findUserById(Integer id); -->
  <select id="findUserById" resultType="com.pojo.User">
    select id,last_name lastName,sex from t_user where id = #{id}
  </select>
<!--  public List<User> findUsers(); -->
  <select id="findUsers" resultType="com.pojo.User">
    select id,last_name lastName,sex from t_user
  </select>
</mapper>

测试类:

public class UserMapperTest {
  static SqlSessionFactory sqlSessionFactory;
  @BeforeClass
  public static void setUpBeforeClass() throws Exception {
    String url = "mybatis-config.xml";
    // 读取配置文件
    InputStream inputStream = Resources.getResourceAsStream(url);
    // 创建SqlSessionFactory对象
    sqlSessionFactory = new SqlSessionFactoryBuilder().build(inputStream);
  }
  @Test
  public void testSaveUser() {
    SqlSession session = sqlSessionFactory.openSession();
    try {
      UserMapper userMapper = session.getMapper(UserMapper.class);
      User user = new User(0, "ddddd", 1);
      userMapper.saveUser(user);
      session.commit();
      System.out.println(user);
    } finally {
      session.close();
    }
  }
  @Test
  public void testUpdateUser() {
    SqlSession session = sqlSessionFactory.openSession();
    try {
      UserMapper userMapper = session.getMapper(UserMapper.class);
      User user = new User(4, "eeeee", 1);
      userMapper.updateUser(user);
      session.commit();
    } finally {
      session.close();
    }
  }
  @Test
  public void testDeleteUserById() {
    SqlSession session = sqlSessionFactory.openSession();
    try {
      UserMapper userMapper = session.getMapper(UserMapper.class);
      userMapper.deleteUserById(4);
      session.commit();
    } finally {
      session.close();
    }
  }
  @Test
  public void testFindUserById() {
    SqlSession session = sqlSessionFactory.openSession();
    try {
      UserMapper userMapper = session.getMapper(UserMapper.class);
      System.out.println(userMapper.findUserById(1));
    } finally {
      session.close();
    }
  }
  @Test
  public void testFindUsers() {
    SqlSession session = sqlSessionFactory.openSession();
    try {
      UserMapper userMapper = session.getMapper(UserMapper.class);
      System.out.println(userMapper.findUsers());
    } finally {
      session.close();
    }
  }
}

源码解析

它是怎么工作的呢?拿测试类中查询举例

1.读取配置文件mybatis-config.xml,通过Resources.getResourceAsStream(“mybatis-config.xml”);返回一个流对象InputStream

2.通过SqlSessionFactoryBuilder().build(流对象InputStream放进来)来创建SqlSessionFactory对象

3.使用SqlSessionFactory对象打开一个session方法,sqlSessionFactory.openSession();获取SqlSession对象

4.使用SqlSession调用getMapper()方法,我们进入源码查看该方法

@Override
  public <T> T getMapper(Class<T> type) {
    return configuration.<T>getMapper(type, this);
  }

我们之前放进来的UserMapper.class对应Class type,它作为 configuration.getMapper(type, this)的参数再次传递,我们进入它的方法体内

public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
    return mapperRegistry.getMapper(type, sqlSession);
  }

它再次被当做参数和sqlSession一起传递,进入它的方法体内,现在才是重点

@SuppressWarnings("unchecked")
  public <T> T getMapper(Class<T> type, SqlSession sqlSession) {
    final MapperProxyFactory<T> mapperProxyFactory = (MapperProxyFactory<T>) knownMappers.get(type);
    if (mapperProxyFactory == null) {
      throw new BindingException("Type " + type + " is not known to the MapperRegistry.");
    }
    try {
      return mapperProxyFactory.newInstance(sqlSession);
    } catch (Exception e) {
      throw new BindingException("Error getting mapper instance. Cause: " + e, e);
    }
  }

我们可以看到MapperProxyFactory这个类是Mapper接口的代理工厂,这个mapper的代理就是我们之前的UserMapper 的实现类

看看之前的代码UserMapper userMapper = session.getMapper(UserMapper.class);

接着查看源码return mapperProxyFactory.newInstance(sqlSession);通过newInstance方法它要创建UserMapper接口的实例了,反射有讲newInstance()创建实例。

mapperProxyFactory.newInstance(sqlSession)进入它的方法体内

public T newInstance(SqlSession sqlSession) {
    final MapperProxy<T> mapperProxy = new MapperProxy<T>(sqlSession, mapperInterface, methodCache);
    return newInstance(mapperProxy);
  }

newInstance(mapperProxy)进入它的方法体内

@SuppressWarnings("unchecked")
  protected T newInstance(MapperProxy<T> mapperProxy) {
    return (T) Proxy.newProxyInstance(mapperInterface.getClassLoader(), new Class[] { mapperInterface }, mapperProxy);
  }

Proxy.newProxyInstance()方法解析:用来new一个jdk动态代理的

看看里面的参数 (mapperInterface.getClassLoader(), new Class[] { mapperInterface }, mapperProxy)

mapperInterface.getClassLoader():类加载器

new Class[] { mapperInterface }:interface com.dao.UserMapper

mapperProxy:

protected T newInstance(MapperProxy mapperProxy) {

进入MapperProxy类中

public class MapperProxy implements InvocationHandler, Serializable {

可以看到MapperProxy实现了InvocationHandler

回到之前测试类的代码:UserMapper userMapper = session.getMapper(UserMapper.class);

可以看到它已经是mapper的代理,jdk动态代理,这样可以解释为什么我们没有写接口也可以用接口里的方法,因为它通过代理给你创建了一个实现类。

继续看System.out.println(userMapper.findUsers());进入方法体内

  @Override
  public Object invoke(Object proxy, Method method, Object[] args) throws Throwable {
    if (Object.class.equals(method.getDeclaringClass())) {
      try {
        return method.invoke(this, args);
      } catch (Throwable t) {
        throw ExceptionUtil.unwrapThrowable(t);
      }
    }
    final MapperMethod mapperMethod = cachedMapperMethod(method);
    return mapperMethod.execute(sqlSession, args);
  }

为什么会进入到这个方法体内呢?userMapper.findUsers()前面证明了userMapper是jdk动态代理,jdk动态代理在执行任何方法时都会执行InvocationHandler执行里面的invoke方法

执行 final MapperMethod mapperMethod = cachedMapperMethod(method);

可以看到它已经找到了UserMapper接口中对应的方法了再看

可以看到它找到了select标签,我们接口中的方法名和我们的id值是不是对应上了,我们还可以深入的看看,select只有二种情况,一种是执行selectOne,一种是执行selectList.

当我们执行到return mapperMethod.execute(sqlSession, args);进入它的方法体内

  public Object execute(SqlSession sqlSession, Object[] args) {
    Object result;
    switch (command.getType()) {
      case INSERT: {
      Object param = method.convertArgsToSqlCommandParam(args);
        result = rowCountResult(sqlSession.insert(command.getName(), param));
        break;
      }
      case UPDATE: {
        Object param = method.convertArgsToSqlCommandParam(args);
        result = rowCountResult(sqlSession.update(command.getName(), param));
        break;
      }
      case DELETE: {
        Object param = method.convertArgsToSqlCommandParam(args);
        result = rowCountResult(sqlSession.delete(command.getName(), param));
        break;
      }
      case SELECT:
        if (method.returnsVoid() && method.hasResultHandler()) {
          executeWithResultHandler(sqlSession, args);
          result = null;
        } else if (method.returnsMany()) {
          result = executeForMany(sqlSession, args);
        } else if (method.returnsMap()) {
          result = executeForMap(sqlSession, args);
        } else if (method.returnsCursor()) {
          result = executeForCursor(sqlSession, args);
        } else {
          Object param = method.convertArgsToSqlCommandParam(args);
          result = sqlSession.selectOne(command.getName(), param);
        }
        break;
      case FLUSH:
        result = sqlSession.flushStatements();
        break;
      default:
        throw new BindingException("Unknown execution method for: " + command.getName());
    }
    if (result == null && method.getReturnType().isPrimitive() && !method.returnsVoid()) {
      throw new BindingException("Mapper method '" + command.getName() 
          + " attempted to return null from a method with a primitive return type (" + method.getReturnType() + ").");
    }
    return result;
  }

通过command.getType()判断类型SELECT执行

   case SELECT:
            if (method.returnsVoid() && method.hasResultHandler()) {
              executeWithResultHandler(sqlSession, args);
              result = null;
            } else if (method.returnsMany()) {
              result = executeForMany(sqlSession, args);
            } else if (method.returnsMap()) {
              result = executeForMap(sqlSession, args);
            } else if (method.returnsCursor()) {
              result = executeForCursor(sqlSession, args);
            } else {
              Object param = method.convertArgsToSqlCommandParam(args);
              result = sqlSession.selectOne(command.getName(), param);
            }
            break;

method.returnsVoid() 可以看到通过方法的返回值区别是执行selectOne,是执行selectList.

  // 根据id搜索用户
  public User findUserById(int id);    
  // 搜索全部用户
  public List<User> findUsers();

method.returnsMany() 它是返回集合,就是返回多个,可以深入的看看

public boolean returnsMany() {

return returnsMany;

}

进入方法体内

  public static class MethodSignature {
    private final boolean returnsMany;

ctrl+f查找returnsMany

public MethodSignature(Configuration configuration, Class<?> mapperInterface, Method method) {
  Type resolvedReturnType = TypeParameterResolver.resolveReturnType(method, mapperInterface);
  if (resolvedReturnType instanceof Class<?>) {
    this.returnType = (Class<?>) resolvedReturnType;
  } else if (resolvedReturnType instanceof ParameterizedType) {
    this.returnType = (Class<?>) ((ParameterizedType) resolvedReturnType).getRawType();
  } else {
    this.returnType = method.getReturnType();
  }
  this.returnsVoid = void.class.equals(this.returnType);
  this.returnsMany = (configuration.getObjectFactory().isCollection(this.returnType) || this.returnType.isArray());

通过this.returnsMany = (configuration.getObjectFactory().isCollection(this.returnType) || this.returnType.isArray());可以看到它是不是集合还是数组

如果是list集合进入到result = executeForMany(sqlSession, args);进入到它的方法体内

  private <E> Object executeForMany(SqlSession sqlSession, Object[] args) {
    List<E> result;
    Object param = method.convertArgsToSqlCommandParam(args);
    if (method.hasRowBounds()) {
      RowBounds rowBounds = method.extractRowBounds(args);
      result = sqlSession.<E>selectList(command.getName(), param, rowBounds);
    } else {
      result = sqlSession.<E>selectList(command.getName(), param);
    }
    // issue #510 Collections & arrays support
    if (!method.getReturnType().isAssignableFrom(result.getClass())) {
      if (method.getReturnType().isArray()) {
        return convertToArray(result);
      } else {
        return convertToDeclaredCollection(sqlSession.getConfiguration(), result);
      }
    }
    return result;
  }

可以看到它找到了SelectList

if (method.hasRowBounds()) {
          RowBounds rowBounds = method.extractRowBounds(args);
          result = sqlSession.<E>selectList(command.getName(), param, rowBounds);
        } else {
          result = sqlSession.<E>selectList(command.getName(), param);
        }

method.returnsMap() 是不是Map

method.returnsCursor() 是不是游标

最后 result = sqlSession.selectOne(command.getName(), param);可以看到它找到了selectOne

相关文章
|
2月前
|
SQL XML Java
mybatis-源码深入分析(一)
mybatis-源码深入分析(一)
|
20天前
|
消息中间件 缓存 安全
Future与FutureTask源码解析,接口阻塞问题及解决方案
【11月更文挑战第5天】在Java开发中,多线程编程是提高系统并发性能和资源利用率的重要手段。然而,多线程编程也带来了诸如线程安全、死锁、接口阻塞等一系列复杂问题。本文将深度剖析多线程优化技巧、Future与FutureTask的源码、接口阻塞问题及解决方案,并通过具体业务场景和Java代码示例进行实战演示。
39 3
|
1月前
|
SQL Java 数据库连接
mybatis使用四:dao接口参数与mapper 接口中SQL的对应和对应方式的总结,MyBatis的parameterType传入参数类型
这篇文章是关于MyBatis中DAO接口参数与Mapper接口中SQL的对应关系,以及如何使用parameterType传入参数类型的详细总结。
35 10
|
1月前
|
自动驾驶 安全 物联网
|
21天前
|
JSON 前端开发 JavaScript
API接口商品详情接口数据解析
商品详情接口通常用于提供特定商品的详细信息,这些信息比商品列表接口中的信息更加详细和全面。以下是一个示例的JSON数据格式,用于表示一个商品详情API接口的响应。这个示例假定API返回一个包含商品详细信息的对象。
|
1月前
|
前端开发 Java 数据库连接
表白墙/留言墙 —— 中级SpringBoot项目,MyBatis技术栈MySQL数据库开发,练手项目前后端开发(带完整源码) 全方位全步骤手把手教学
本文是一份全面的表白墙/留言墙项目教程,使用SpringBoot + MyBatis技术栈和MySQL数据库开发,涵盖了项目前后端开发、数据库配置、代码实现和运行的详细步骤。
46 0
表白墙/留言墙 —— 中级SpringBoot项目,MyBatis技术栈MySQL数据库开发,练手项目前后端开发(带完整源码) 全方位全步骤手把手教学
|
1月前
|
Java 数据库连接 mybatis
Springboot整合Mybatis,MybatisPlus源码分析,自动装配实现包扫描源码
该文档详细介绍了如何在Springboot Web项目中整合Mybatis,包括添加依赖、使用`@MapperScan`注解配置包扫描路径等步骤。若未使用`@MapperScan`,系统会自动扫描加了`@Mapper`注解的接口;若使用了`@MapperScan`,则按指定路径扫描。文档还深入分析了相关源码,解释了不同情况下的扫描逻辑与优先级,帮助理解Mybatis在Springboot项目中的自动配置机制。
130 0
Springboot整合Mybatis,MybatisPlus源码分析,自动装配实现包扫描源码
|
2月前
|
网络协议 安全 Linux
网卡接口跃点数:概念与重要性解析
在计算机网络中,跃点数(Hop Count)是指数据包从源设备传输到目标设备时经过的路由器或网关数量,是衡量路径长度的关键指标。本文详细介绍了跃点数的概念、计算方法及其在网络管理中的重要性,包括性能评估、故障排除、网络优化及路由选择等方面的应用。通过使用traceroute或tracert命令,网络管理员可以轻松获取跃点数信息,并据此优化网络结构,提高数据传输效率和安全性。尽管跃点数是重要指标,但仍需与其他因素结合分析以全面评估网络性能。
|
2月前
|
SQL XML Java
mybatis :sqlmapconfig.xml配置 ++++Mapper XML 文件(sql/insert/delete/update/select)(增删改查)用法
当然,这些仅是MyBatis功能的初步介绍。MyBatis还提供了高级特性,如动态SQL、类型处理器、插件等,可以进一步提供对数据库交互的强大支持和灵活性。希望上述内容对您理解MyBatis的基本操作有所帮助。在实际使用中,您可能还需要根据具体的业务要求调整和优化SQL语句和配置。
45 1
|
3月前
|
Java 开发者 C++

推荐镜像

更多
下一篇
无影云桌面