久久久久久久av_日韩在线中文_看一级毛片视频_日本精品二区_成人深夜福利视频_武道仙尊动漫在线观看

SpringBoot超詳細講解多數據源集成

Java編程 html5模板網
今天分享下SpringBoot多數據源集成，我怕麻煩，這里我覺得我的集成也應該是最簡單的，清晰明了

一、多數據源使用場景與弊端

1.場景

  • 業務系統跨數據庫
  • 數據轉存（這個現在太low了，應該高級點都不用）
  • 系統集成

2.弊端

  • 跨庫業務事務問題
  • service、dao不能重復注入數據源

二、使用步驟

1.引入庫

<!-- 多數據源支持 -->
    <dependency>
      <groupId>com.baomidou</groupId>
      <artifactId>dynamic-datasource-spring-boot-starter</artifactId>
      <version>3.3.6</version>
    </dependency>

2.多數據源配置文件

#數據源配置
spring:
  application:
    name: olap
  datasource:
    dynamic:
      primary: target
    target:
      jdbc-url: jdbc:mysql://192.168.1.101:15051/db1?useUnicode=true&characterEncoding=utf8&useSSL=true&allowPublicKeyRetrieval=true&serverTimezone=GMT%2B8
      username: root
      password: 123
      driver-class-name: com.mysql.jdbc.Driver
    source1:
      jdbc-url: jdbc:mysql://192.168.102:15052/db2?useUnicode=true&characterEncoding=utf8&useSSL=true&allowPublicKeyRetrieval=true&serverTimezone=GMT%2B8
      username: admin
      password: 456
      driver-class-name: com.mysql.jdbc.Driver

3.多數據源配置類

數據源1

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();
  }
}

數據源2

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();
  }
}
  • 注意dao一定要在@MapperScan注解設置的包下
  • 注意xml文件要在MAPPER_LOCATION=的路徑下
  • springBoot啟動類不要再用@MapperScan注解
  • 其他注意配置類的SqlSessionFactory 方法，看注釋

4.使用

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 {
    }

注意是在service的實現類上用@DS(“數據源名稱”)注解，數據源名稱與配置文件里的datasource下的一致。

注意dao不能再用@DS注解，否在報錯

總結

我也是一個怕麻煩的人，所以能有簡單的辦法，我絕對不用復雜的，多數據源集成就是這么簡單，也沒啥好總結的，就提醒下：

跨數據源的業務接口要注意事務

@Transactional不生效

其實也有動態切換數據源的方法，我覺得沒必要，規規矩矩用service，別把自己整糊了。

好就簡單寫道這里，up！

到此這篇關于SpringBoot超詳細講解多數據源集成的文章就介紹到這了,更多相關SpringBoot多數據源集成內容請搜索html5模板網以前的文章希望大家以后多多支持html5模板網！

【網站聲明】本站部分內容來源于互聯網,旨在幫助大家更快的解決問題，如果有圖片或者內容侵犯了您的權益，請聯系我們刪除處理，感謝您的支持！

相關文檔推薦

這篇文章主要介紹了SpringBoot整合MyBatis筆記記錄，大家需要注意在整合mybatis之前我們需要相對應的導入相關依賴,首先需要在java的目錄和resources下創建mapper文件夾，對SpringBoot整合MyBatis的
這篇文章主要介紹了springcloud整合seata的實現方法,整合步驟通過引入spring-cloud-starter-alibaba-seata?jar包，文中結合實例代碼給大家介紹的非常詳細，需要的朋友可以參考下
SpringBoot注冊服務到Nacos上，由Nacos來做服務的管理，本文主要介紹了springboot讀取nacos配置文件的實現，文中通過示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參
這篇文章主要為大家詳細介紹了Spring如何使用注解開發，文中的示例代碼講解詳細，對我們學習或工作有一定幫助，需要的可以參考一下
在用Spring?Security項目開發中，有時候需要放通某一個接口時，我們需要在配置中把接口地址配置上，這樣做有時候顯得麻煩。本文將通過一個注解的方式快速實現接口放通，感興趣的可
這篇文章主要介紹了Springboot自動裝配之注入DispatcherServlet,Springboot向外界提供web服務，底層依賴了springframework中的web模塊來實現,那么springboot在什么時機向容器注入DispatcherServlet這個核心
主站蜘蛛池模板： 99国产精品一区二区三区 | 在线观看国产三级 | 亚洲福利一区二区 | 亚洲一区二区三区在线播放 | 亚洲国产aⅴ成人精品无吗 欧美激情欧美激情在线五月 | 免费在线一区二区三区 | 美女天天操 | 欧美日韩亚 | 懂色中文一区二区三区在线视频 | 新超碰97| 成人av一区二区三区 | 国产精品国产三级国产aⅴ入口 | 四虎成人免费视频 | 狠狠操天天操 | 午夜视频免费 | 91精品国产91久久综合桃花 | 国产精久久久久久久 | 天天干天天玩天天操 | 日韩欧美成人精品 | 成人无遮挡毛片免费看 | 黄色av观看| 国产在线二区 | 色综合色综合 | 99热精品国产 | 天天插天天干 | 999精品视频在线观看 | 亚洲a视频 | www.久草| 日本a视频 | 日韩影院在线 | 国产精品一区一区 | 国产在线精品一区二区 | 国产成人a亚洲精品 | 亚洲美女一区二区三区 | 日韩在线视频免费观看 | 国产亚洲一区二区三区 | 亚洲精品9999 | 在线天堂免费中文字幕视频 | 亚洲国产精品人人爽夜夜爽 | 国产精品视频网 | 国产在线高清 |