Mybatis中自定义实例化SqlSessionFactoryBean问题怎么解决

数据库   发布日期:2023年07月13日   浏览次数:509

本篇内容介绍了“Mybatis中自定义实例化SqlSessionFactoryBean问题怎么解决”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!

Mybatis自定义实例化SqlSessionFactoryBean

现在SpringBoot基本成为开发的标配,如果你上司让你搭建一个SpringBoot,然后集成Mybatis+Druid,你可以能百度几下,卡卡就搭建完毕了。

现在项目基本都会使用连接池技术,市面上的连接池有很多,比如:DBCP、c3p0、Druid等,今天我们重点介绍Druid连接池。

application.yml配置文件如下所示:

  1. spring:
  2. #数据库配置
  3. datasource:
  4. druid:
  5. type: com.alibaba.druid.pool.DruidDataSource
  6. url: jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8&zeroDateTimeBehavior=round&serverTimezone=GMT%2B8
  7. username: test
  8. password: test
  9. driver-class-name: com.mysql.jdbc.Driver
  10. # 获取连接时最大等待时间,单位毫秒
  11. max-wait: 60000
  12. # 最大连接池数量
  13. max-active: 80
  14. # 初始化时建立物理连接的个数
  15. initial-size: 20
  16. # 最小连接池数量
  17. min-idle: 40
  18. #Destory线程中如果检测到当前连接的最后活跃时间和当前时间的差值大于minEvictableIdleTimeMillis,则关闭当前连接。
  19. min-evictable-idle-time-millis: 600000
  20. # testWhileIdle的判断依据,详细看testWhileIdle属性的说明
  21. time-between-eviction-runs-millis: 2000
  22. #用来检测连接是否有效的sql,要求是一个查询语句。
  23. validation-query: select 1
  24. # 申请连接的时候检测,如果空闲时间大于timeBetweenEvictionRunsMillis,执行validationQuery检测连接是否有效。
  25. test-while-idle: true
  26. # 申请连接时执行validationQuery检测连接是否有效,做了这个配置会降低性能。
  27. test-on-borrow: false
  28. # 归还连接时执行validationQuery检测连接是否有效,做了这个配置会降低性能
  29. test-on-return: false
  30. # 属性类型是字符串,通过别名的方式配置扩展插件
  31. filters: stat,wall
  32. # 开启慢sql,并设置时间
  33. filter:
  34. stat.log-slow-sql: true
  35. stat.slow-sql-millis: 2000
  36. web-stat-filter:
  37. enabled: true
  38. url-pattern: /*
  39. stat-view-servlet:
  40. enabled: true
  41. url-pattern: /druid/*

使用SpringBoot作为项目框架自然简单,没有很多的xml配置文件,不需要配置额外的tomcat,不管是开发还是部署都非常方便。但高度集成有时候也会带来一些麻烦。

比如你上司要求你在mybatis中集成插件并可以识别common模块的mybatis.xml映射文件。

这个时候你可能首先会百度如何配置mybatis插件、如何配置多模块的mapper-locations,然后有很多博文会说在SqlSessionFactoryBean设置即可。

你可能会这么设置:

  1. @Autowired
  2. private SqlSessionFactoryBean sqlSessionFactoryBean;

但是结果不是那么尽人意,初始化的结果为null。

这是因为高版本的mybatis实现机制做了一些修改,我们没办法通过@Autowired来实例化SqlSessionFactoryBean对象。

所以我们必须自己来实例化SqlSessionFactoryBean对象,而实例化SqlSessionFactoryBean对象的关键就是设置DataSource数据源。

我们可以通过如下代码来实例化过SqlSessionFactoryBean。

  1. /**
  2. * mybatis配置
  3. * @author linzhiqinag
  4. */
  5. @Configuration
  6. public class MybatisConfig {
  7. private Logger logger = LoggerFactory.getLogger(MybatisConfig.class);
  8. @Value("${mybatis.mapper-locations}")
  9. private String mapperLocation;
  10. @Value("${common-mybatis.mapper-locations}")
  11. private String commonMapperLocation;
  12. @Value("${spring.datasource.druid.username}")
  13. private String username;
  14. @Value("${spring.datasource.druid.password}")
  15. private String password;
  16. @Value("${spring.datasource.druid.url}")
  17. private String dbUrl;
  18. @Value("${spring.datasource.druid.initial-size}")
  19. private int initialSize;
  20. @Value("${spring.datasource.druid.min-idle}")
  21. private int minIdle;
  22. @Value("${spring.datasource.druid.max-active}")
  23. private int maxActive;
  24. @Value("${spring.datasource.druid.max-wait}")
  25. private long maxWait;
  26. @Value("${spring.datasource.druid.driver-class-name}")
  27. private String driverClassName;
  28. @Value("${spring.datasource.druid.min-evictable-idle-time-millis}")
  29. private long minEvictableIdleTimeMillis;
  30. @Value("${spring.datasource.druid.time-between-eviction-runs-millis}")
  31. private long timeBetweenEvictionRunsMillis;
  32. @Value("${spring.datasource.druid.validation-query}")
  33. private String validationQuery;
  34. @Value("${spring.datasource.druid.test-while-idle}")
  35. private boolean testWhileIdle;
  36. @Value("${spring.datasource.druid.test-on-borrow}")
  37. private boolean testOnBorrow;
  38. @Value("${spring.datasource.druid.test-on-return}")
  39. private boolean testOnReturn;
  40. @Value("${spring.datasource.druid.filter.stat.log-slow-sql}")
  41. private boolean logSlowSql;
  42. @Value("${spring.datasource.druid.filter.stat.slow-sql-millis}")
  43. private long slowSqlMillis;
  44. @Bean
  45. public DruidDataSource dataSource() {
  46. DruidDataSource druidDataSource = new DruidDataSource();
  47. try {
  48. druidDataSource.setUsername(username);
  49. druidDataSource.setPassword(password);
  50. druidDataSource.setUrl(dbUrl);
  51. druidDataSource.setFilters("stat,wall");
  52. druidDataSource.setInitialSize(initialSize);
  53. druidDataSource.setMinIdle(minIdle);
  54. druidDataSource.setMaxActive(maxActive);
  55. druidDataSource.setMaxWait(maxWait);
  56. druidDataSource.setMinEvictableIdleTimeMillis(minEvictableIdleTimeMillis);
  57. druidDataSource.setTimeBetweenEvictionRunsMillis(timeBetweenEvictionRunsMillis);
  58. druidDataSource.setUseGlobalDataSourceStat(true);
  59. druidDataSource.setDriverClassName(driverClassName);
  60. druidDataSource.setValidationQuery(validationQuery);
  61. druidDataSource.setTestWhileIdle(testWhileIdle);
  62. druidDataSource.setTestOnBorrow(testOnBorrow);
  63. druidDataSource.setTestOnReturn(testOnReturn);
  64. // 设置需要的过滤
  65. List<Filter> statFilters =new ArrayList<>();
  66. StatFilter statFilter = new StatFilter();
  67. statFilter.setLogSlowSql(logSlowSql);
  68. statFilter.setSlowSqlMillis(slowSqlMillis);
  69. statFilters.add(statFilter);
  70. // 设置慢SQL
  71. druidDataSource.setProxyFilters(statFilters);
  72. } catch (Exception e) {
  73. e.printStackTrace();
  74. }
  75. return druidDataSource;
  76. }
  77. @Bean
  78. public SqlSessionFactoryBean mysqlSessionFactory(DataSource dataSource) throws Exception {
  79. SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
  80. sqlSessionFactoryBean.setDataSource(dataSource);
  81. PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver();
  82. Resource[] resources1 = resolver.getResources(mapperLocation);
  83. Resource[] resources2 = resolver.getResources(commonMapperLocation);
  84. Resource[] resources = new Resource[resources1.length+resources2.length];
  85. for (int i=0;i<resources1.length;i++) {
  86. resources[i] = resources1[i];
  87. }
  88. int initSize = resources1.length;
  89. for (int i=0;i<resources2.length;i++) {
  90. resources[initSize+i] = resources2[i];
  91. }
  92. sqlSessionFactoryBean.setMapperLocations(resources);
  93. sqlSessionFactoryBean.setPlugins(new Interceptor[]{new CatMybatisInterceptor(dbUrl)});
  94. return sqlSessionFactoryBean;
  95. }
  96. }

这样我们就可以得到SqlSessionFactoryBean对象了,然后我们就可以通过sqlSessionFactoryBean.setMapperLocations()来设置多模块xml映射,通过sqlSessionFactoryBean.setPlugins()来设置指定的插件了。

注意:

这边需要注意的是,如果采用代码的方式实例化SqlSessionFactoryBean,那关于数据库相关的配置将会失效,所以在设置数据源的时候一定要设置全。

MyBatis中SqlSessionFactoryBean的作用

在使用Spring+MyBatis的环境下,我们需要配值一个SqlSessionFactoryBean来充当SqlSessionFactory,这里我们要搞清楚的就是为什么SqlSessionFactoryBean为什么能在Spring IoC容器中以SqlSessionFactory的类型保存并被获取。

我们来看看SqlSessionFactoryBean的定义是怎样的:

  1. public class SqlSessionFactoryBean implements FactoryBean<SqlSessionFactory>, InitializingBean, ApplicationListener<ApplicationEvent> {
  2. }

能被Spring IoC容器管理的原因就是继承了FactoryBean这个接口了,这是个支持泛型的接口:

  1. public interface FactoryBean<T> {
  2. @Nullable
  3. T getObject() throws Exception;
  4. @Nullable
  5. Class<?> getObjectType();
  6. default boolean isSingleton() {
  7. return true;
  8. }
  9. }

当实现了这个接口的Bean在配置为被Spring接管时,存入IoC容器中的实例类型将会是实例化泛型的那个类型,从IoC容器中获取时也是实例化泛型的那个类型,这种情况下,Spring 将会在应用启动时为你创建SqlSessionFactory对象,然后将它以 SqlSessionFactory为名来存储。

当把这个bean注入到Spring中去了以后,IoC容器中的其他类型就可以拿到SqlSession实例了,就可以进行相关的SQL执行任务了。

以上就是Mybatis中自定义实例化SqlSessionFactoryBean问题怎么解决的详细内容,更多关于Mybatis中自定义实例化SqlSessionFactoryBean问题怎么解决的资料请关注九品源码其它相关文章!