Spring 整合 MyBatis 底层源码解析

Spring 整合 MyBatis 底层源码解析

大家好，我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编，也是冬天不穿秋裤，天冷也要风度的程序猿！

Spring与MyBatis的整合是企业级开发中的常见需求，它不仅能够简化数据库操作，还能充分利用Spring的依赖注入和事务管理功能。本文将深入解析Spring整合MyBatis的底层源码，帮助大家更好地理解其工作原理。

1. Spring 与 MyBatis 的整合概述

Spring与MyBatis整合主要通过Spring提供的SqlSessionFactoryBean、MapperFactoryBean以及MyBatis的核心组件来实现。这些组件在Spring容器启动时初始化，并在应用运行时提供数据库操作的功能。

2. 核心组件解析

2.1 SqlSessionFactoryBean

SqlSessionFactoryBean是Spring与MyBatis整合的核心组件之一。它负责创建SqlSessionFactory，SqlSessionFactory用于生成SqlSession，SqlSession是MyBatis执行SQL语句的核心对象。

@Bean
public SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();factoryBean.setDataSource(dataSource);return factoryBean.getObject();
}

SqlSessionFactoryBean通过DataSource创建SqlSessionFactory，并将其注册到Spring容器中。它的核心方法是afterPropertiesSet和buildSqlSessionFactory。

2.2 MapperFactoryBean

MapperFactoryBean用于生成MyBatis的Mapper接口代理对象，并将其注册到Spring容器中。它实现了Spring的FactoryBean接口，可以生成自定义的Bean。

public class MapperFactoryBean<T> extends SqlSessionDaoSupport implements FactoryBean<T> {private Class<T> mapperInterface;@Overridepublic T getObject() throws Exception {return getSqlSession().getMapper(this.mapperInterface);}@Overridepublic Class<?> getObjectType() {return this.mapperInterface;}
}

MapperFactoryBean通过SqlSession创建Mapper接口的代理对象，并返回给Spring容器。Spring容器在需要时会调用getObject方法获取Mapper实例。

3. 源码解析

3.1 SqlSessionFactoryBean 的初始化

在Spring容器启动过程中，SqlSessionFactoryBean的afterPropertiesSet方法会被调用。这个方法调用了buildSqlSessionFactory来创建SqlSessionFactory。

@Override
public void afterPropertiesSet() throws Exception {if (this.sqlSessionFactory == null) {afterPropertiesSet();}
}protected SqlSessionFactory buildSqlSessionFactory() throws Exception {Configuration configuration = new Configuration();// 配置相关属性return new SqlSessionFactoryBuilder().build(configuration);
}

buildSqlSessionFactory方法创建了MyBatis的Configuration对象，并调用SqlSessionFactoryBuilder的build方法创建SqlSessionFactory。

3.2 MapperFactoryBean 的工作原理

MapperFactoryBean在Spring容器启动时会被初始化，并调用getObject方法生成Mapper接口的代理对象。

@Override
public T getObject() throws Exception {return getSqlSession().getMapper(this.mapperInterface);
}

getSqlSession方法获取当前的SqlSession，getMapper方法使用JDK动态代理生成Mapper接口的代理对象。

4. 事务管理

Spring与MyBatis整合时，事务管理是一个重要的部分。Spring通过DataSourceTransactionManager管理事务。DataSourceTransactionManager依赖于DataSource，而DataSource由Spring管理。

@Bean
public DataSourceTransactionManager transactionManager(DataSource dataSource) {return new DataSourceTransactionManager(dataSource);
}

Spring通过AOP拦截需要事务管理的方法，利用TransactionInterceptor实现事务的开启、提交和回滚。

5. 实际应用

以下是Spring整合MyBatis的实际应用示例：

5.1 配置类

@Configuration
@MapperScan("com.example.mapper")
public class MyBatisConfig {@Beanpublic DataSource dataSource() {// 配置数据源}@Beanpublic SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {SqlSessionFactoryBean factoryBean = new SqlSessionFactoryBean();factoryBean.setDataSource(dataSource);return factoryBean.getObject();}@Beanpublic DataSourceTransactionManager transactionManager(DataSource dataSource) {return new DataSourceTransactionManager(dataSource);}
}

5.2 Mapper接口

public interface UserMapper {User selectUserById(Long id);
}

5.3 服务类

@Service
public class UserService {@Autowiredprivate UserMapper userMapper;@Transactionalpublic User getUserById(Long id) {return userMapper.selectUserById(id);}
}