java之mybatisPlus 分布式时候的手动配置

快来打我* 2021-11-11 20:24 330阅读 0赞

import com.alibaba.druid.pool.DruidDataSourceFactory;
    import com.baomidou.mybatisplus.core.MybatisConfiguration;
    import com.baomidou.mybatisplus.extension.plugins.OptimisticLockerInterceptor;
    import com.baomidou.mybatisplus.extension.plugins.PaginationInterceptor;
    import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;
    import org.apache.ibatis.logging.stdout.StdOutImpl;
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.annotation.MapperScan;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.core.env.Environment;
    import org.springframework.core.io.support.PathMatchingResourcePatternResolver;
    import org.springframework.transaction.annotation.EnableTransactionManagement;
    
    import javax.annotation.Resource;
    import javax.sql.DataSource;
    import java.util.Properties;
    
    /**
     * 配置文件
     *
     * @author sunwen
     * @version 1.0
     * @date 2019/8/5 15:19
     **/
    @EnableTransactionManagement
    @Configuration
    @MapperScan(basePackages = {"com.yixing.*.dao", "com.baomidou.cloud.service.*.mapper*"})
    public class MyBatisConfig {
    
        @Resource
        private Environment env;
    
        @Bean
        public DataSource getDataSource() {
            Properties props = new Properties();
            props.put("driverClass", env.getProperty("jdbc.driverClass"));
            props.put("url", env.getProperty("jdbc.url"));
            props.put("username", env.getProperty("jdbc.username"));
            props.put("password", env.getProperty("jdbc.password"));
            props.put("maxWait", env.getProperty("jdbc.maxWait"));
            props.put("maxActive", env.getProperty("jdbc.maxActive"));
            props.put("minIdle", env.getProperty("jdbc.minIdle"));
            props.put("initialSize", env.getProperty("jdbc.initialSize"));
            props.put("timeBetweenEvictionRunsMillis", env.getProperty("jdbc.timeBetweenEvictionRunsMillis"));
            props.put("minEvictableIdleTimeMillis", env.getProperty("jdbc.minEvictableIdleTimeMillis"));
            try {
                return DruidDataSourceFactory.createDataSource(props);
            } catch (Exception e) {
                e.printStackTrace();
            }
            return null;
        }
    
    
        /**
         * @Title: sqlSessionFactory @Description:
         * 根据数据源创建SqlSessionFactory @param @param
         * ds @param @return @param @throws Exception @return
         * SqlSessionFactory @throws
         */
        @Bean
        public SqlSessionFactory sqlSessionFactory(DataSource dataSource) throws Exception {
            MybatisSqlSessionFactoryBean msfb = new MybatisSqlSessionFactoryBean();
            msfb.setDataSource(dataSource);
            {
                MybatisConfiguration configuration = new MybatisConfiguration();
                configuration.setLogImpl(StdOutImpl.class);
                msfb.setConfiguration(configuration);
            }
            msfb.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(env.getProperty("mybatis.mapperLocations")));
            return msfb.getObject();
        }
    
        /**
         * 分页插件
         */
        @Bean
        public PaginationInterceptor paginationInterceptor() {
            return new PaginationInterceptor();
        }
    
        /**
         * 乐观所
         */
        @Bean
        public OptimisticLockerInterceptor optimisticLockerInterceptor() {
            return new OptimisticLockerInterceptor();
        }
    }

其实就是接管了SqlSessionFactory的初始化过程。