JAVA配置多源数据库

备忘&分享

properties文件

示例2个数据源resourcesA & resourcesB

# web port
server.port=8102
# no web
#spring.main.web-environment=false# log config
logging.config=classpath:logback.xmlspring.devtools.restart.exclude=static/**,public/**
spring.devtools.restart.enabled=true#resourcesA
spring.datasource.adas.resourcesA.minimum-idle=5
spring.datasource.adas.resourcesA.maximum-pool-size=10
spring.datasource.adas.resourcesA.idle-timeout=30000
spring.datasource.adas.resourcesA.connection-timeout=30000
spring.datasource.adas.resourcesA.ConnectionTestQuery=select 1
spring.datasource.adas.resourcesA.jdbcUrl=jdbc:postgresql://******此处是数据库链接
spring.datasource.adas.resourcesA.username=postgres
spring.datasource.adas.resourcesA.password=password#resourcesB
spring.datasource.empdata.resourcesB.minimum-idle=5
spring.datasource.empdata.resourcesB.maximum-pool-size=10
spring.datasource.empdata.resourcesB.idle-timeout=30000
spring.datasource.empdata.resourcesB.connection-timeout=30000
spring.datasource.empdata.resourcesB.ConnectionTestQuery=select 1
spring.datasource.empdata.resourcesB.jdbcUrl=jdbc:postgresql://***********此处是数据库链接
spring.datasource.empdata.resourcesB.username=postgres
spring.datasource.empdata.resourcesB.password=password

JAVA配置数据源

resourcesA

import javax.sql.DataSource;import org.apache.ibatis.io.VFS;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.mybatis.spring.boot.autoconfigure.SpringBootVFS;
import org.springframework.beans.factory.annotation.Qualifier;
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;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;import com.zaxxer.hikari.HikariDataSource;@Configuration
@MapperScan(
//此处是对应的mapper包 @bean的name属性是自定义的basePackages = {"com.*.job.executor.mapper.resourcesA"},sqlSessionFactoryRef = "adasSqlSessionFactory"
)
public class resourcesAConfig{@Bean(name = "resourcesA")@ConfigurationProperties(prefix = "spring.datasource.adas.resourcesA")public DataSource dataSource() {return new HikariDataSource();}@Bean(name = "resourcesATransactionManager")public DataSourceTransactionManager resourcesATransactionManager() {return new DataSourceTransactionManager(dataSource());}@Bean(name = "resourcesASqlSessionFactory")public SqlSessionFactory resourcesASqlSessionFactory(@Qualifier("resourcesA") DataSource dataSource)throws Exception {final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();sessionFactory.setDataSource(dataSource);VFS.addImplClass(SpringBootVFS.class);return sessionFactory.getObject();}
}

resourcesB

import javax.sql.DataSource;
import org.apache.ibatis.io.VFS;
import org.apache.ibatis.session.SqlSessionFactory;
import org.mybatis.spring.SqlSessionFactoryBean;
import org.mybatis.spring.annotation.MapperScan;
import org.mybatis.spring.boot.autoconfigure.SpringBootVFS;
import org.springframework.beans.factory.annotation.Qualifier;
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;
import org.springframework.jdbc.datasource.DataSourceTransactionManager;
import com.zaxxer.hikari.HikariDataSource;@Configuration
@MapperScan(//此处是对应的mapper包 @bean的name属性是自定义的basePackages = {"com.*.*.*.mapper.empdata"},sqlSessionFactoryRef = "empSqlSessionFactory"
)
public class ResourcesBConfig {@Bean(name = "resourcesBSource")@ConfigurationProperties(prefix = "spring.datasource.empdata.resourcesB")public DataSource dataSource() {return new HikariDataSource();}@Bean(name = "eresourcesBTransactionManager")public DataSourceTransactionManager resourcesBTransactionManager() {return new DataSourceTransactionManager(dataSource());}@Bean(name = "resourcesBSqlSessionFactory")public SqlSessionFactory resourcesBSqlSessionFactory(@Qualifier("resourcesBSource") DataSource dataSource)throws Exception {final SqlSessionFactoryBean sessionFactory = new SqlSessionFactoryBean();sessionFactory.setDataSource(dataSource);VFS.addImplClass(SpringBootVFS.class);return sessionFactory.getObject();}
}

总结

不同的数据源对应不同的mapper层，就可以无缝衔接多个数据源了。

JAVA配置多源数据库相关推荐

springboot配置多源数据库
springboot 配置多源数据库 springboot+druid+mybatis-plus+dynamic配置多源数据库主要依赖包 spring-boot-starter-web mybati ...
springboot mybatis 配置多源数据库mysql+sqlserver
1.添加驱动包  <dependency> <groupId>org.mybatis</groupId ...
Spring Boot文档阅读笔记-使用Spring Data JPA连接多源数据库（MySQL和Oracle）
下面这个小项目展示了如何连接2个数据库,一个是Oracle,一个是MySQL. 关键的Maven依赖: <dependency><groupId>org.springframe ...
在Nutz中如何配置多个数据库源，并且带事务控制
在Nutz中如何配置多个数据库源,并且带事务控制发布于 560天前作者 Longitude 995 次浏览复制上一个帖子下一个帖子标签: 无在Nutz中如何配置多个数据库源, ...
计算机毕业设计Java房屋租赁管理系统(源码+系统+mysql数据库+lW文档)
计算机毕业设计Java房屋租赁管理系统(源码+系统+mysql数据库+lW文档) 计算机毕业设计Java房屋租赁管理系统(源码+系统+mysql数据库+lW文档) 本源码技术栈: 项目架构:B/S架构 ...
计算机毕业设计Java心理健康管理系统(源码+系统+mysql数据库+Lw文档）
计算机毕业设计Java心理健康管理系统(源码+系统+mysql数据库+Lw文档) 计算机毕业设计Java心理健康管理系统(源码+系统+mysql数据库+Lw文档) 最新计算机专业原创毕业设计参考选题都 ...
计算机毕业设计Java后勤管理系统(源码+系统+mysql数据库+lw文档)
计算机毕业设计Java后勤管理系统(源码+系统+mysql数据库+lw文档) 计算机毕业设计Java后勤管理系统(源码+系统+mysql数据库+lw文档) 本源码技术栈: 项目架构:B/S架构开发语 ...
计算机毕业设计Java超市网站(源码+系统+mysql数据库+lw文档)
计算机毕业设计Java超市网站(源码+系统+mysql数据库+lw文档) 计算机毕业设计Java超市网站(源码+系统+mysql数据库+lw文档) 本源码技术栈: 项目架构:B/S架构开发语言:Ja ...
计算机毕业设计Java个人理财系统(源码+系统+mysql数据库+lW文档)
计算机毕业设计Java个人理财系统(源码+系统+mysql数据库+lW文档) 计算机毕业设计Java个人理财系统(源码+系统+mysql数据库+lW文档) 本源码技术栈: 项目架构:B/S架构开发语 ...

JAVA配置多源数据库

备忘&分享

properties文件

JAVA配置数据源

resourcesA

resourcesB

总结

JAVA配置多源数据库相关推荐

最新文章

热门文章