mybatis-plus 多数据源配置详解包含pom,yml,config等配置

川长思鸟来 2023-07-05 05:27 5阅读 0赞

需要引入的pom

<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
    	<parent>
    		<groupId>org.springframework.boot</groupId>
    	    <artifactId>spring-boot-starter-parent</artifactId>
    	  	<version>2.1.4.RELEASE</version>
    	    <relativePath/> 
    	</parent>
      <groupId>com.cqyx</groupId>
      <artifactId>others</artifactId>
      <version>0.0.1-SNAPSHOT</version>
      
      
       
    
    <repositories>
       <repository>
          <id>maven-ali</id>
          <url>http://maven.aliyun.com/nexus/content/groups/public//</url>
          <releases>
             <enabled>true</enabled>
          </releases>
          <snapshots>
             <enabled>true</enabled>
             <updatePolicy>always</updatePolicy>
             <checksumPolicy>fail</checksumPolicy>
          </snapshots>
       </repository>
    </repositories>
    
    
    	<dependencies>	
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-configuration-processor</artifactId>
    			<optional>true</optional>
    		</dependency>
    		<dependency>
    			<groupId>org.projectlombok</groupId>
    			<artifactId>lombok</artifactId>
    			<optional>true</optional>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-jdbc</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    	
        <dependency>
    	    <groupId>org.mybatis.spring.boot</groupId>
    	    <artifactId>mybatis-spring-boot-starter</artifactId>
    	    <version>1.1.1</version>
    	</dependency>
    
    	<dependency>
                <groupId>com.baomidou</groupId>
                <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
                <version>2.5.4</version>
            </dependency>
    
    	<dependency>
    	    <groupId>com.baomidou</groupId>
    	    <artifactId>mybatis-plus</artifactId>
    	    <version>2.1.2</version>
    	</dependency>
    		<dependency>
                <groupId>mysql</groupId>
                <artifactId>mysql-connector-java</artifactId>
                <version>8.0.12</version>
            </dependency>
    	
    	<dependency>
    		<groupId>org.mybatis.caches</groupId>
    		<artifactId>mybatis-ehcache</artifactId>
    		<version>1.0.3</version>
    	</dependency>
    	
    	<dependency>
    	    <groupId>org.apache.velocity</groupId>
    	    <artifactId>velocity-engine-core</artifactId>
    	    <version>2.0</version>
    	</dependency>
     		
    		
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-devtools</artifactId>
    			<optional>true</optional>
    		</dependency>
    
        </dependencies>
    
    	<build>
    		
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    			<plugin>
    	            <groupId>org.apache.maven.plugins</groupId>
    	            <artifactId>maven-compiler-plugin</artifactId>
    	            <configuration>
    	           
    	                <source>1.8</source>
    	                <target>1.8</target>
    	                <encoding>UTF-8</encoding>
    				    <includeSystemScope>true</includeSystemScope>
    	                  
                        <fork>true</fork>
                  
    	            </configuration>
    
    	        </plugin>
    		</plugins>
    
    	</build>
    </project>

1.yml

server:
      port: 8888
      max-http-header-size: 1024000
    spring:
      servlet:
        multipart:
          max-file-size: 1000MB
          max-request-size: 1000MB
      application:
        name: cqyx
      mvc:
        favicon:
          enabled: false
      datasource:
        ds1:
          url: jdbc:mysql://xxxx:3306/cqyx?characterEncoding=utf8&allowPublicKeyRetrieval=true&allowMultiQueries=true&serverTimezone=UTC&useSSL=false
          username: cf
          password: 123456
          driver-class-name: com.mysql.cj.jdbc.Driver
          type: com.zaxxer.hikari.HikariDataSource
          hikari:  
            minimum-idle: 5
            maximum-pool-size: 15
            auto-commit: true
            idle-timeout: 30000
            pool-name: DatebookHikariCP
            max-lifetime: 1800000
            connection-timeout: 30000
            connection-test-query: SELECT 1
        ds2:
          url: jdbc:mysql://xxxx:3306/cqyx?characterEncoding=utf8&allowPublicKeyRetrieval=true&allowMultiQueries=true&serverTimezone=UTC&useSSL=false
          username: cqyx
          password: 123456
          driver-class-name: com.mysql.cj.jdbc.Driver
          type: com.zaxxer.hikari.HikariDataSource
          hikari:  
            minimum-idle: 5
            maximum-pool-size: 15
            auto-commit: true
            idle-timeout: 30000
            pool-name: DatebookHikariCP
            max-lifetime: 1800000
            connection-timeout: 30000
            connection-test-query: SELECT 1        
    
    #mybatis配置
    mybatis:
      mapper-locations: classpath*:mybatis/*Mapper.xml
      #实体扫描，多个package用逗号或者分号分隔
      typeAliasesPackage: com.cqyx.**.entity
      global-config:
        #字段策略 0:"忽略判断",1:"非 NULL 判断"),2:"非空判断"
        field-strategy: 2
        #驼峰下划线转换
        db-column-underline: true
        #刷新mapper 调试神器
        refresh-mapper: true
      configuration:
        map-underscore-to-camel-case: true
        cache-enabled: false
        
        
    cqyx:    
      #是否开启定时任务
      openTask: 1

2.dataresource配置文件

import javax.sql.DataSource;
    
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.boot.autoconfigure.jdbc.DataSourceProperties;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    
    /**
     * 多数据源配置
     */
    @Configuration
    public class DataSourceConfig {
    	 //主数据源配置 ds1数据源
        @Primary
        @Bean(name = "ds1DataSourceProperties")
        @ConfigurationProperties(prefix = "spring.datasource.ds1")
        public DataSourceProperties ds1DataSourceProperties() {
            return new DataSourceProperties();
        }
    
        //主数据源 ds1数据源
        @Primary
        @Bean(name = "ds1DataSource")
        public DataSource ds1DataSource(@Qualifier("ds1DataSourceProperties") DataSourceProperties dataSourceProperties) {
            return dataSourceProperties.initializeDataSourceBuilder().build();
        }
    
        //第二个ds2数据源配置
        @Bean(name = "ds2DataSourceProperties")
        @ConfigurationProperties(prefix = "spring.datasource.ds2")
        public DataSourceProperties ds2DataSourceProperties() {
            return new DataSourceProperties();
        }
    
        //第二个ds2数据源
        @Bean("ds2DataSource")
        public DataSource ds2DataSource(@Qualifier("ds2DataSourceProperties") DataSourceProperties dataSourceProperties) {
            return dataSourceProperties.initializeDataSourceBuilder().build();
        }
    }

3.mybatis-plus配置文件

import javax.sql.DataSource;
    
    import org.apache.ibatis.mapping.DatabaseIdProvider;
    import org.apache.ibatis.plugin.Interceptor;
    import org.apache.ibatis.session.SqlSessionFactory;
    import org.mybatis.spring.SqlSessionTemplate;
    import org.mybatis.spring.annotation.MapperScan;
    import org.mybatis.spring.boot.autoconfigure.SpringBootVFS;
    import org.mybatis.spring.boot.autoconfigure.MybatisProperties;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    import org.springframework.core.io.DefaultResourceLoader;
    import org.springframework.core.io.ResourceLoader;
    import org.springframework.jdbc.datasource.DataSourceTransactionManager;
    import org.springframework.util.ObjectUtils;
    import org.springframework.util.StringUtils;
    
    import com.baomidou.mybatisplus.MybatisConfiguration;
    import com.baomidou.mybatisplus.MybatisXMLLanguageDriver;
    import com.baomidou.mybatisplus.entity.GlobalConfiguration;
    import com.baomidou.mybatisplus.enums.IdType;
    import com.baomidou.mybatisplus.mapper.AutoSqlInjector;
    import com.baomidou.mybatisplus.plugins.OptimisticLockerInterceptor;
    import com.baomidou.mybatisplus.plugins.PaginationInterceptor;
    import com.baomidou.mybatisplus.spring.MybatisSqlSessionFactoryBean;
    
    
    
    
    
    @Configuration
    @MapperScan(basePackages ="com.cqyx.**.mapper*", sqlSessionTemplateRef  = "ds1SqlSessionTemplate")
    public class MybatisPlusConfig {
    	@Autowired
    	private DataSource dataSource;
    
    	@Autowired
    	private MybatisProperties properties;
    
    	@Autowired
    	private ResourceLoader resourceLoader = new DefaultResourceLoader();
    
    	@Autowired(required = false)
    	private Interceptor[] interceptors;
    
    	@Autowired(required = false)
    	private DatabaseIdProvider databaseIdProvider;
    	
    	
    	/**
    	 *	 mybatis-plus分页插件
    	 */
    	@Primary
    	@Bean("ds1PaginationInterceptor")
    	public PaginationInterceptor paginationInterceptor() {
    		PaginationInterceptor page = new PaginationInterceptor();
    		page.setDialectType("mysql");
    		return page;
    	}
    	
    	/**
    	 *	 mybatis-plus乐观锁插件
    	 */
    	@Primary
    	@Bean("ds1OptimisticLocker")
    	public OptimisticLockerInterceptor optimisticLockerInterceptor() {
    		OptimisticLockerInterceptor oLocker = new OptimisticLockerInterceptor();
    		return oLocker;
    	}
    	/**
    	 * 这里全部使用mybatis-autoconfigure 已经自动加载的资源。不手动指定
    	 * 配置文件和mybatis-boot的配置文件同步
    	 * @return
    	 */
    	@Primary
    	@Bean("ds1SqlSessionFactory")
    	public MybatisSqlSessionFactoryBean mybatisSqlSessionFactoryBean() {
    		MybatisSqlSessionFactoryBean mybatisPlus = new MybatisSqlSessionFactoryBean();
    		
    		mybatisPlus.setDataSource(dataSource);
    		mybatisPlus.setVfs(SpringBootVFS.class);
    		if (StringUtils.hasText(this.properties.getConfigLocation())) {
    			mybatisPlus.setConfigLocation(this.resourceLoader.getResource(this.properties.getConfigLocation()));
    		}
    		mybatisPlus.setConfiguration(properties.getConfiguration());
    		if (!ObjectUtils.isEmpty(this.interceptors)) {
    			mybatisPlus.setPlugins(this.interceptors);
    		}
    		MybatisConfiguration mc = new MybatisConfiguration();
    		mc.setDefaultScriptingLanguage(MybatisXMLLanguageDriver.class);
    		mybatisPlus.setConfiguration(mc);
    		if (this.databaseIdProvider != null) {
    			mybatisPlus.setDatabaseIdProvider(this.databaseIdProvider);
    		}
    		if (StringUtils.hasLength(this.properties.getTypeAliasesPackage())) {
    			mybatisPlus.setTypeAliasesPackage(this.properties.getTypeAliasesPackage());
    		}
    		if (StringUtils.hasLength(this.properties.getTypeHandlersPackage())) {
    			mybatisPlus.setTypeHandlersPackage(this.properties.getTypeHandlersPackage());
    		}
    		if (!ObjectUtils.isEmpty(this.properties.resolveMapperLocations())) {
    			mybatisPlus.setMapperLocations(this.properties.resolveMapperLocations());
    		}
    		//ID自增
    		GlobalConfiguration global = new GlobalConfiguration(new AutoSqlInjector());
    		global.setIdType(IdType.AUTO.getKey());
    		global.setDbColumnUnderline(true);
    		mybatisPlus.setGlobalConfig(global);
    		return mybatisPlus;
    	}
    	 	@Primary
    	    @Bean(name = "ds1TransactionManager")
    	    public DataSourceTransactionManager ds1TransactionManager(@Qualifier("ds1DataSource") DataSource dataSource) {
    	        return new DataSourceTransactionManager(dataSource);
    	    }
    
    	    @Primary
    	    @Bean(name = "ds1SqlSessionTemplate")
    	    public SqlSessionTemplate ds1SqlSessionTemplate(@Qualifier("ds1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) {
    	        return new SqlSessionTemplate(sqlSessionFactory);
    	    }
    }