package com.tanpu.feo.feojob.dao; import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean; import org.apache.commons.lang3.ArrayUtils; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionTemplate; import org.mybatis.spring.annotation.MapperScan; import org.springframework.beans.factory.annotation.Qualifier; import org.springframework.boot.context.properties.ConfigurationProperties; import org.springframework.boot.jdbc.DataSourceBuilder; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.io.Resource; import org.springframework.core.io.support.PathMatchingResourcePatternResolver; import org.springframework.jdbc.core.JdbcTemplate; import org.springframework.jdbc.core.namedparam.NamedParameterJdbcTemplate; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import org.springframework.transaction.PlatformTransactionManager; import org.springframework.transaction.support.TransactionTemplate; import javax.sql.DataSource; @Configuration @MapperScan(value = {"com.tanpu.feo.feojob.dao.user.mapper"}, sqlSessionTemplateRef = "userSqlSessionTemplate") public class UserDataSourceConfig { @Bean(name = "userDataSource") @ConfigurationProperties(prefix = "spring.datasource.user") public DataSource setDataSource() { return DataSourceBuilder.create().build(); } @Bean(name = "userTransactionManager") public DataSourceTransactionManager setTransactionManager(@Qualifier("userDataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } @Bean(name = "userSqlSessionFactory") public SqlSessionFactory setSqlSessionFactory(@Qualifier("userDataSource") DataSource dataSource) throws Exception { MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean(); bean.setDataSource(dataSource); PathMatchingResourcePatternResolver resolver = new PathMatchingResourcePatternResolver(); Resource[] resources1 = resolver.getResources("classpath:mapper/user/*.xml"); Resource[] resources = ArrayUtils.addAll(resources1); bean.setMapperLocations(resources); return bean.getObject(); } @Bean(name = "userSqlSessionTemplate") public SqlSessionTemplate setSqlSessionTemplate(@Qualifier("userSqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); } @Bean(name = "userTransactionTemplate") public TransactionTemplate transactionTemplate(@Qualifier("userTransactionManager") PlatformTransactionManager transactionManager) { return new TransactionTemplate(transactionManager); } @Bean(name = "userJdbcTemplate") public JdbcTemplate userJdbcTemplate(@Qualifier("userDataSource") DataSource dataSource) { return new JdbcTemplate(dataSource); } @Bean(name = "userNamedParameterJdbcTemplate") public NamedParameterJdbcTemplate namedParameterJdbcTemplate(@Qualifier("userJdbcTemplate") JdbcTemplate jdbcTemplate) { return new NamedParameterJdbcTemplate(jdbcTemplate); } }