一般情况下,我们在springboot中配置mybatis的多数据源时,会使用下面的方法:
@Configuration
@MapperScan(basePackages = "com.example.demo.mapper",sqlSessionFactoryRef = "ssf1")
public class Sql1Config {
@Bean(name = "ds1")
@Primary
@ConfigurationProperties(prefix = "sql1")
public DruidDataSource getDataSource() {
return new DruidDataSource();
}
@Bean(name = "ssf1")
@Primary
public SqlSessionFactory sqlSessionFactory(@Qualifier("ds1") DataSource datasource) throws Exception {
SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
sqlSessionFactoryBean.setDataSource(datasource);
return sqlSessionFactoryBean.getObject();
}
}
这样做,是用我们自己手动去创建DataSource和SqlSessionFactory的bean,来替代mybatis-spring-boot-starter自动创建的bean。其中,SqlSessionFactory是mybatis用来创建SqlSession的b类。由于一个SqlSessionFactory和DataSource一一对应,因此我们两个数据源有两个DataSource的bean,因此SqlSessionFactory的bean也需要创建两个。
我们一旦手动创建了SqlSessionFactory,mybatis-spring-boot-starter就不会自动创建bean了。从起源码中可以看出来:
@org.springframework.context.annotation.Configuration
@ConditionalOnClass({ SqlSessionFactory.class, SqlSessionFactoryBean.class })
@ConditionalOnBean(DataSource.class)
@EnableConfigurationProperties(MybatisProperties.class)
@AutoConfigureAfter(DataSourceAutoConfiguration.class)
public class MybatisAutoConfiguration {
...
@Bean
@ConditionalOnMissingBean
public SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {
...
}
...
}
由于@ConditionalOnMissingBean注解的作用,如果spring的bean清单中有SqlSessionFactory,就不会自动创建SqlSessionFactory的bean。
而yml中mybatis相关配置是在mybatis-spring-boot-starter自动创建bean时注入给bean的,因此我们手动创建的bean,并不会从yml中读取相关配置。我们需要手动将配置注入进去,而注入方法其实很简单:
@Configuration
@MapperScan(basePackages = "com.example.demo.dao",sqlSessionFactoryRef = "ssf1")
public class Sql1Config {
Logger logger = LoggerFactory.getLogger(this.getClass());
@Bean(name = "ds1")
@Primary
@ConfigurationProperties(prefix = "mybatis")//加上该注解
public DruidDataSource getDataSource() {
return new DruidDataSource();
}
@Bean(name = "ssf1")
@Primary
@ConfigurationProperties(prefix = "mybatis")
public SqlSessionFactory sqlSessionFactory(@Qualifier("ds1") DataSource datasource) throws Exception {
SqlSessionFactoryBean sqlSessionFactoryBean = new SqlSessionFactoryBean();
sqlSessionFactoryBean.setDataSource(datasource);
return sqlSessionFactoryBean.getObject();
}
}
使用 @ConfigurationProperties(prefix = "mybatis") 注解即可。配置文件中mybatis前缀的配置会注入给SqlSessionFactory对象。但是要注意,配置文件中的properties键值对要和mybatis原生保持一致。否则就只能使用?ConfigurationCustomizer或者SqlSessionFactoryBean.setConfiuration(xxx)来实现配置注入了。
如果有给不同数据源的mybatis注入不同配置,也很简单,使用不同的前缀即可,然后
@ConfigurationProperties(prefix = "你的前缀")即可。但是还是要保证每一段配置的键值对和mybatis原生键值对一致,spring框架才能帮我们注入对应的属性。
|