SpringBoot超详细讲解多数据源集成

<!-- 多数据源支持 -->

     < dependency >

       < groupId >com.baomidou</ groupId >

       < artifactId >dynamic-datasource-spring-boot-starter</ artifactId >

       < version >3.3.6</ version >

     </ dependency >

import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;

import javax.sql.DataSource;

import org.apache.ibatis.session.SqlSessionFactory;

import org.mybatis.spring.SqlSessionFactoryBean;

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.support.PathMatchingResourcePatternResolver;

import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import org.springframework.transaction.PlatformTransactionManager;

@Configuration

@MapperScan (basePackages = "com.easylinkin.dc.mapper.source1" , sqlSessionFactoryRef = "source1SqlSessionFactory" )

public class Source1DataSourceConfig {

   // mapper.xml所在地址

   private static final String MAPPER_LOCATION = "classpath*:mapper/business/source1/*.xml" ;

   /**

    * 数据源

    */

   @Bean (name = "source1DataSource" )

   @ConfigurationProperties (prefix = "spring.datasource.source1" )

   public DataSource dataSource() {

     DataSource build = DataSourceBuilder.create().build();

     return build;

   }

   /**

    * 事务管理器

    */

   @Bean (name = "source1TransactionManager" )

   public PlatformTransactionManager dataSourceTransactionManager(

       @Qualifier ( "source1DataSource" ) DataSource dataSource) {

     return new DataSourceTransactionManager(dataSource);

   }

   /**

    * session工厂

    */

   @Bean (name = "source1SqlSessionFactory" )

   public SqlSessionFactory sqlSessionFactory( @Qualifier ( "source1DataSource" ) DataSource dataSource)

       throws Exception {

   /*  final SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();

     sessionFactoryBean.setDataSource(dataSource);

     sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(

         Source1DataSourceConfig.MAPPER_LOCATION));*/

     //不使用下面这个无法使用mybatis-plus提供的BaseMapper中的方法，需要增加mybatis-plus 的拓展依赖

     MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();

     bean.setDataSource(dataSource);

     //不在这里注入分页插件，会失效

     //bean.setPlugins(new PaginationInterceptor[]{new PaginationInterceptor()});

     return bean.getObject();

   }

}

import com.baomidou.mybatisplus.extension.spring.MybatisSqlSessionFactoryBean;

import javax.sql.DataSource;

import org.apache.ibatis.session.SqlSessionFactory;

import org.mybatis.spring.SqlSessionFactoryBean;

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.context.annotation.Primary;

import org.springframework.core.io.support.PathMatchingResourcePatternResolver;

import org.springframework.jdbc.datasource.DataSourceTransactionManager;

import org.springframework.transaction.PlatformTransactionManager;

@Configuration

@MapperScan (basePackages = "com.easylinkin.dc.mapper.target" , sqlSessionFactoryRef = "targetSqlSessionFactory" )

public class TargetDataSourceConfig {

   // mapper.xml所在地址

   private static final String MAPPER_LOCATION = "classpath*:mapper/business/target/*.xml" ;

   /**

    * 主数据源，Primary注解必须增加，它表示该数据源为默认数据源 项目中还可能存在其他的数据源，如获取时不指定名称，则默认获取这个数据源，如果不添加，则启动时候回报错

    */

   @Primary

   @Bean (name = "targetDataSource" )

   @ConfigurationProperties (prefix = "spring.datasource.target" )

   public DataSource dataSource() {

     DataSource build = DataSourceBuilder.create().build();

     return build;

   }

   /**

    * 事务管理器，Primary注解作用同上

    */

   @Bean (name = "masterTransactionManager" )

   @Primary

   public PlatformTransactionManager dataSourceTransactionManager(

       @Qualifier ( "targetDataSource" ) DataSource dataSource) {

     return new DataSourceTransactionManager(dataSource);

   }

   /**

    * session工厂，Primary注解作用同上

    */

   @Bean (name = "targetSqlSessionFactory" )

   @Primary

   public SqlSessionFactory sqlSessionFactory( @Qualifier ( "targetDataSource" ) DataSource dataSource)

       throws Exception {

     /*final SqlSessionFactoryBean sessionFactoryBean = new SqlSessionFactoryBean();

     sessionFactoryBean.setDataSource(dataSource);

     sessionFactoryBean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources(

         TargetDataSourceConfig.MAPPER_LOCATION));

     return sessionFactoryBean.getObject();*/

     //不使用下面这个无法使用mybatis-plus提供的BaseMapper中的方法，需要增加mybatis-plus 的拓展依赖

     MybatisSqlSessionFactoryBean bean = new MybatisSqlSessionFactoryBean();

     bean.setDataSource(dataSource);

     //不在这里注入分页插件，会失效

     //bean.setPlugins(new PaginationInterceptor[]{new PaginationInterceptor()});

     return bean.getObject();

   }

}

import com.baomidou.dynamic.datasource.annotation.DS;

import com.baomidou.mybatisplus.core.conditions.query.QueryWrapper;

import com.baomidou.mybatisplus.core.metadata.IPage;

import com.baomidou.mybatisplus.extension.plugins.pagination.Page;

import com.baomidou.mybatisplus.extension.service.impl.ServiceImpl;

import com.easylinkin.dc.common.exceptions.BusinessException;

import com.easylinkin.dc.common.utils.io.OutputStreamUtil;

import com.easylinkin.dc.mapper.source1.FkRegisterVisitorMapper;

import com.easylinkin.dc.business.visitor.entity.FkRegisterVisitor;

import com.easylinkin.dc.business.visitor.entity.vo.FkRegisterVisitorVo;

import com.easylinkin.dc.business.visitor.service.FkRegisterVisitorService;

import lombok.extern.slf4j.Slf4j;

import org.apache.commons.lang3.ObjectUtils;

import org.apache.commons.lang3.StringUtils;

import org.springframework.stereotype.Repository;

import org.springframework.stereotype.Service;

import org.springframework.transaction.annotation.Transactional;

import org.springframework.util.Assert;

import javax.servlet.http.HttpServletRequest;

import javax.servlet.http.HttpServletResponse;

import java.io.IOException;

import java.io.OutputStream;

import java.io.Serializable;

import java.util.ArrayList;

import java.util.List;

/**

  * FkRegisterVisitor表服务实现类

  *

  * @author CodeGenerator

  * @date 2022/05/16

  */

@DS ( "source1" )

@Slf4j

@Service ( "fkRegisterVisitorService" )

public class FkRegisterVisitorServiceImpl extends ServiceImpl

     <FkRegisterVisitorMapper, FkRegisterVisitor> implements FkRegisterVisitorService {

     }