首页 > 基础资料博客日记

springboot配置多个数据源

2024-10-18 11:00:05基础资料围观96次

文章springboot配置多个数据源分享给大家，欢迎收藏Java资料网，专注分享技术知识

实际业务中；在一个项目里面读取多个数据库的数据来进行展示，例如读取mysql，pgsql，oracle的不同数据库，springboto对同时配置多个数据源是支持的。

使用springboot+mybatis的框架来进行演示，

在配置文件中配置多个数据源，然后通过配置类来获取数据源以及mapper相关的扫描配置

pom.xml文件

<parent>
		<groupId>org.springframework.boot</groupId>
		<artifactId>spring-boot-starter-parent</artifactId>
		<version>...</version>
		<relativePath/>
	</parent>
  <dependencies>
  			<!-- druid数据源驱动 -->
			<dependency>
			   <groupId>com.alibaba</groupId>
			   <artifactId>druid-spring-boot-starter</artifactId>
			   <version>1.1.0</version>
			</dependency>
  			<dependency>
	            <groupId>mysql</groupId>
	            <artifactId>mysql-connector-java</artifactId>
	        </dependency>
			<!--mybatis SpringBoot依赖 -->
			<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-web</artifactId>
		</dependency>
		
		<dependency>
		    <groupId>org.springframework.boot</groupId>
		    <artifactId>spring-boot-starter-tomcat</artifactId>
		    <scope>compile</scope>
		</dependency>
		
		<dependency>
			<groupId>org.springframework.boot</groupId>
			<artifactId>spring-boot-starter-test</artifactId>
		</dependency>
		
		<!-- aop依赖 -->
		<dependency>
		    <groupId>org.springframework.boot</groupId>
		    <artifactId>spring-boot-starter-aop</artifactId>
		</dependency>
		
		<!-- mybatis -->
		<dependency>
		    <groupId>org.mybatis.spring.boot</groupId>
		    <artifactId>mybatis-spring-boot-starter</artifactId>
		    <version>1.3.1</version>
		</dependency>
		
		<!-- 通用mapper -->
		<dependency>
		    <groupId>tk.mybatis</groupId>
		    <artifactId>mapper-spring-boot-starter</artifactId>
		    <version>1.1.5</version>
		</dependency>
			<!-- druid监控依赖 -->
			<dependency>
				<groupId>com.alibaba</groupId>
				<artifactId>druid</artifactId>
				<version>1.0.28</version>
			</dependency>
  </dependencies>

application.yml 配置文件中可以配置多个不同数据源，例如下面配置了mysql和pgsql两个不同数据源。

spring:
  datasource:
      mysql-op:   //数据源1，mysql
	    type: com.alibaba.druid.pool.DruidDataSource
	    driverClassName: com.mysql.jdbc.Driver
	    url: jdbc:mysql://127.0.0.1:3306/test2?useUnicode=true&characterEncoding=utf8
	    username: root
	    password: 123456
	    schema: tasa_dev
	  pgsql-npaaa: //数据源2，pgsql
	    type: com.alibaba.druid.pool.DruidDataSource
	    driverClassName: com.pgsql.jdbc.Driver
	    url: jdbc:mysql://127.0.0.1:3306/test1?useUnicode=true&characterEncoding=utf8
	    username2: root
	    password2: 123456
	    schema: tasa_test

如果使用type类型 com.alibaba.druid.pool.DruidDataSource，需要进行DruidDBConfig 连接池相关配置，如下所示，如果时候type是其他类型，例如spring.datasource.type=com.zaxxer.hikari.HikariDataSource，就可以不配置下面的内容。

package com.xbz.common.config;
 
import com.alibaba.druid.support.http.StatViewServlet;
import com.alibaba.druid.support.http.WebStatFilter;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.boot.web.servlet.ServletRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
/**
 * Druid监控
 */
@SuppressWarnings("AlibabaRemoveCommentedCode")
@Configuration
public class DruidDBConfig {
    private Logger logger = LoggerFactory.getLogger(DruidDBConfig.class);
 
    /**
     * 注册ServletRegistrationBean
     * @return
     */
    @Bean
    public ServletRegistrationBean druidServlet() {
        ServletRegistrationBean reg = new ServletRegistrationBean();
        reg.setServlet(new StatViewServlet());
        reg.addUrlMappings("/druid/*");
        reg.addInitParameter("allow", ""); //白名单
        return reg;
    }
 
    /**
     * 注册FilterRegistrationBean
     * @return
     */
    @Bean
    public FilterRegistrationBean filterRegistrationBean() {
        FilterRegistrationBean filterRegistrationBean = new FilterRegistrationBean();
        filterRegistrationBean.setFilter(new WebStatFilter());
        filterRegistrationBean.addUrlPatterns("/*");
        filterRegistrationBean.addInitParameter("exclusions", "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*");
        filterRegistrationBean.addInitParameter("profileEnable", "true");
        filterRegistrationBean.addInitParameter("principalCookieName", "USER_COOKIE");
        filterRegistrationBean.addInitParameter("principalSessionName", "USER_SESSION");
        filterRegistrationBean.addInitParameter("DruidWebStatFilter", "/*");
        return filterRegistrationBean;
    }
}

配置数据源mysql-op的连接信息，包含配置数据库连接信息，扫描对应的实体类路径。

package com.xbz.common.config;
 
import com.alibaba.druid.pool.DruidDataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
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 javax.sql.DataSource;
import java.sql.SQLException;
 
 
@Configuration
@MapperScan(basePackages  = {"com.biz.data.process.mapper.op", //配置数据源需要读取的mapper文件路径，也就是需要在这个数据源下执行的sql
                             "com.biz.data.process.mapper.npa",
                             "com.biz.data.process.mapper.cust"} , 
                             sqlSessionFactoryRef = "mysqlSqlSessionFactory")
public class MysqlDbConfig {
    private Logger logger = LoggerFactory.getLogger(MysqlDbConfig.class);
    private static final String MAPPER_LOCATION = "classpath*:mapper/master/*.xml";
    private static final String DOMAIN_PACKAGE = "com.xbz.**.domain";
 
    //从配置文件中读取数据库连接信息
    @Value("${spring.datasource.url}")
    private String dbUrl;
    
    //从配置文件中读取数据库连接信息
    @Value("${spring.datasource.username}")
    private String username;
 
    //从配置文件中读取数据库连接信息
    @Value("${spring.datasource.password}")
    private String password;
 
    //从配置文件中读取数据库连接信息
    @Value("${spring.datasource.driverClassName}")
    private String driverClassName;

    //从配置文件中读取数据库连接信息
    @Value("${spring.datasource.schema}")
    private String schema;
 
    @Autowired
    MybatisPlusInterceptor mybatisPlusInterceptor; //分页插件注入
 
    @Bean(name="masterDataSource")   //声明其为Bean实例
    @Primary  //在同样的DataSource中，首先使用被标注的DataSource
    public DataSource MysqlDbConfig () {
        DruidDataSource datasource = new DruidDataSource();
        //不适用Druid时，使用下面的数据源连接
        //DriverManagerDataSource  datasource=new DriverManagerDataSource ();
 
        datasource.setUrl(dbUrl);
        datasource.setUsername(username);
        datasource.setPassword(password);
        datasource.setDriverClassName(driverClassName);
        datasource.setSchema(schema);
        return datasource;
    }
 
    //事务处理异常的类
    @Bean(name = "mysqlTransactionManager")
    @Primary
    public DataSourceTransactionManager masterTransactionManager() {
        return new DataSourceTransactionManager(masterDataSource());
    }
 
    @Bean(name = "mysqlSqlSessionFactory")
    @Primary
    public SqlSessionFactory masterSqlSessionFactory(@Qualifier("mysqlDataSource") DataSource mysqlDataSource)
            throws Exception {
        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(mysqlDataSource);      
         // mapper的xml形式文件位置必须要配置，不然将报错：no statement （这种错误也可能是mapper的xml中，namespace与项目的路径不一致导致）
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources(MasterDbConfig.MAPPER_LOCATION));
        //domain的具体路径，读取do类和数据库表的映射
        sessionFactory.setTypeAliasesPackage(DOMAIN_PACKAGE);
        // 设置分页
        sessionFactory.setPlugins(mybatisPlusInterceptor);
        //mybatis 数据库字段与实体类属性驼峰映射配置
        sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
        return sessionFactory.getObject();
    }

 @Bean(name = "db1SqlSessionTemplate")
    @Primary
 public SqlSessionTemplate dbSqlSessionTemplate(@Qualifier("db1SqlSessionFactory") SqlSessionFactory sqlSessionFactory)  {
        return new SqlSessionTemplate(sqlSessionFactory);
    }
}

配置数据源pgsql的连接信息，包含配置数据库连接信息，扫描对应的实体类路径。

package com.xbz.common.config;
 
import com.alibaba.druid.pool.DruidDataSource;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.beans.factory.annotation.Value;
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 javax.sql.DataSource;
import java.sql.SQLException;
 
/**
 * 从数据源配置
 * 若需要配置更多数据源 , 直接在yml中添加数据源配置再增加相应的新的数据源配置类即可
 */
@Configuration
@MapperScan(basePackages  ={"com.biz.data.process.mapper.op", //配置数据源需要读取的mapper文件路径，也就是需要在这个数据源下执行的sql
                             "com.biz.data.process.mapper.npa",
                             "com.biz.data.process.mapper.cust"} , sqlSessionFactoryRef = "clusterSqlSessionFactory")
public class PgsqlDbConfig {
    private Logger logger = LoggerFactory.getLogger(PgsqlDbConfig .class);
    // 精确到 cluster 目录，以便跟其他数据源隔离
    static final String PACKAGE = "com.xbz.**.dao.cluster";
    private static final String MAPPER_LOCATION = "classpath*:mapper/cluster/*.xml";
    private static final String DOMAIN_PACKAGE = "com.xbz.**.domain";
 
    @Value("${spring.datasource.url2}")
    private String dbUrl;
 
    @Value("${spring.datasource.username2}")
    private String username;
 
    @Value("${spring.datasource.password2}")
    private String password;
 
    @Value("${spring.datasource.driverClassName}")
    private String driverClassName;
 

    @Autowired
    MybatisPlusInterceptor mybatisPlusInterceptor; //分页插件注入
 
    @Bean(name="pgsqlDataSource")   //声明其为Bean实例
    public DataSource pgsqlDataSource() {
         //不适用Druid时，使用下面的数据源连接
        //DriverManagerDataSource  datasource=new DriverManagerDataSource ();     
        
        DruidDataSource datasource = new DruidDataSource();
 
        datasource.setUrl(dbUrl);
        datasource.setUsername(username);
        datasource.setPassword(password);
        datasource.setDriverClassName(driverClassName);
        return datasource;
    }
 
    @Bean(name = "pgsqlTransactionManager")
    public DataSourceTransactionManager clusterTransactionManager() {
        return new DataSourceTransactionManager(clusterDataSource());
    }
 
    @Bean(name = "pgsqlSqlSessionFactory")
    public SqlSessionFactory clusterSqlSessionFactory(@Qualifier("pgsqlDataSource") DataSource pgsqlDataSource)
            throws Exception {
        final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();
        sessionFactory.setDataSource(pgsqlDataSource);
        // mapper的xml形式文件位置必须要配置，不然将报错：no statement （这种错误也可能是mapper的xml中，namespace与项目的路径不一致导致）
        sessionFactory.setMapperLocations(new PathMatchingResourcePatternResolver()
                .getResources(ClusterDbConfig.MAPPER_LOCATION));
        sessionFactory.setTypeAliasesPackage(DOMAIN_PACKAGE);
        / 设置分页
        sessionFactory.setPlugins(mybatisPlusInterceptor);
        //mybatis 数据库字段与实体类属性驼峰映射配置
        sessionFactory.getObject().getConfiguration().setMapUnderscoreToCamelCase(true);
        return sessionFactory.getObject();
    }
}

不同的数据源配置不同的mapper扫描位置，需要查询哪一个数据源的数据，就直接调用该数据源对应的mapper类文件（位于Domain包下）就可以。

MybatisPlus分页配置

package com.whut.multisource.config;
 
import com.baomidou.mybatisplus.annotation.DbType;
import com.baomidou.mybatisplus.extension.plugins.MybatisPlusInterceptor;
import com.baomidou.mybatisplus.extension.plugins.inner.PaginationInnerInterceptor;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
 
/**
 * MybatisPlus分页配置
 */
@Configuration
public class MybatisPlusConfig {
    /**
     * 分页插件
     */
    @Bean
    public MybatisPlusInterceptor mybatisPlusInterceptor() {
        MybatisPlusInterceptor interceptor = new MybatisPlusInterceptor();
        interceptor.addInnerInterceptor(new PaginationInnerInterceptor(DbType.POSTGRE_SQL));
        return interceptor;
    }
 
}

注意点：
编写mapper层，其中不同数据源对应的mapper要分包编写，也就是不同数据源对应的mapper文件要放在domian不同的包下，mapeer文件对应的sql.xml文件最好也要分开写，不然可能会有问题，可以参考如下的方式配置mapper的路径，

文章来源:https://blog.csdn.net/weixin_42704604/article/details/140853156
本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若内容造成侵权/违法违规/事实不符，请联系邮箱：jacktools123@163.com进行投诉反馈，一经查实，立即删除！

标签：

上一篇：Java 多线程（三）—— 死锁
下一篇：Javascript中var和let之间的区别

首页 > 基础资料博客日记

springboot配置多个数据源

相关文章

最新发布

点击排行

本站推荐

标签云

首页 > 基础资料 博客日记

springboot配置多个数据源

相关文章

最新发布

点击排行

本站推荐

标签云

首页 > 基础资料博客日记