SpringBoot配置连接两个或多个数据库 |
您所在的位置：网站首页 › springboot链接两个数据库 › SpringBoot配置连接两个或多个数据库 |
SpringBoot配置连接两个或多个数据库
|
一、背景
项目中需要从两个不同的数据库查询数据，之前实现方法是：SpringBoot配置连接一个数据源，另一个使用jdbc代码连接。 比如jdbc代码连接 public List getSecurityInstalled(String computerName){ List result = new ArrayList(); String sql = "select * from(\n" + "Select t0.Name0,T1.Process_Name,T1.Last_CheckTime from v_R_System T0 right join\n" + "(Select ResourceID,Caption0 as Process_Name,MAX(TimeStamp) as Last_CheckTime from v_GS_PROCESS where Caption0 in ('edpa.exe','PGPtray.exe','ccSvcHst.exe') group by ResourceID,Caption0) T1\n" + "on T0.ResourceID=t1.ResourceID \n" + ") a where Name0='" + computerName + "'"; DriverManagerDataSource dataSource=new DriverManagerDataSource(); setupDataSource2(dataSource); JdbcTemplate jdbcTemplate=new JdbcTemplate(dataSource); jdbcTemplate.query(sql, new RowCallbackHandler() { public void processRow(ResultSet resultSet) throws SQLException { result.add(resultSet.getString("Process_Name")); } }); return result; } public void setupDataSource2(DriverManagerDataSource dataSource){ String[] params = getSAPConfig("IT00022serviceconfig").getString("ashost").split("#"); dataSource.setUrl(params[4]); dataSource.setDriverClassName("com.microsoft.sqlserver.jdbc.SQLServerDriver"); dataSource.setUsername(params[5]); dataSource.setPassword(params[6]); }或者通过配置文件切换数据源 在resources文件夹下，创建 application.properties application-prd.properties application-qas.properties application-dev.properties在主文件，修改spring.profiles.active切换数据源 spring.profiles.active=qas server.port=8770
一个SpringBoot项目，同时连接两个数据库：比如一个是pgsql数据库，一个是oracle数据库 （啥数据库都一样，连接两个同为oracle的数据库，或两个不同的数据库，只需要更改对应的driver-class-name和jdbc-url等即可） 注意：连接什么数据库，要引入对应数据库的包。 三、实现步骤 1、修改application.yml，添加一个数据库连接配置 server: port: 7101 spring: jpa: show-sql: true datasource: test1: driver-class-name: org.postgresql.Driver jdbc-url: jdbc:postgresql://127.0.0.1:5432/test #测试数据库 username: root password: root test2: driver-class-name: oracle.jdbc.driver.OracleDriver jdbc-url: jdbc:oracle:thin:@127.0.0.1:8888:orcl #测试数据库 username: root password: root特别注意： （1）使用test1、test2区分两个数据库连接 （2）url改为：jdbc-url 2、使用代码进行数据源注入，和扫描dao层路径（以前是在yml文件里配置mybatis扫描dao的路径）新建config包，包含数据库1和数据库2的配置文件 特别注意： （1）主数据库DataSource1Config都有 @Primary注解，从数据库DataSource2Config都没有 （2）第二个数据库DataSource2Config作为从数据库 DataSource2Config.java package com.test.config; import org.apache.ibatis.session.SqlSessionFactory; import org.mybatis.spring.SqlSessionFactoryBean; import org.mybatis.spring.SqlSessionTemplate; 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 javax.sql.DataSource; @Configuration @MapperScan(basePackages = "com.test.dao.test2", sqlSessionTemplateRef = "test2SqlSessionTemplate") public class DataSource2Config { @Bean(name = "test2DataSource") @ConfigurationProperties(prefix = "spring.datasource.test2") public DataSource testDataSource() { return DataSourceBuilder.create().build(); } @Bean(name = "test2SqlSessionFactory") public SqlSessionFactory testSqlSessionFactory(@Qualifier("test2DataSource") DataSource dataSource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(dataSource); bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:test2/*.xml")); return bean.getObject(); } @Bean(name = "test2TransactionManager") public DataSourceTransactionManager testTransactionManager(@Qualifier("test2DataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } @Bean(name = "test2SqlSessionTemplate") public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("test2SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); } } 3、 在dao文件夹下，新建test1和test2两个包，分别放两个不同数据库的dao层文件（1）TestDao1.java @Component public interface TestDao1 { List selectDailyActivity(); }（2）TestDao2.java @Component public interface TestDao2 { List selectDailyActivity(); } 4、 在resource下新建test1和test2两个文件夹，分别放入对应dao层的xml文件（我原来项目的dao的xml文件在resource目录下，你们在自己的项目对应目录下即可） 注意dao的java文件和dao的xml文件名字要一致 （1）TestDao1.xml DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> SELECT * FROM daily_activity_data_middle（2）TestDao2.xml DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> SELECT * FROM movieshowtest 5、测试在controller文件里，注入两个数据库的dao，分别查询数据 @RestController public class TestController extends BaseController{ @Autowired private PropertiesUtils propertiesUtils; @Autowired private TestDao1 testDao1; @Autowired private TestDao2 testDao2; @RequestMapping(value = {"/test/test1"},method = RequestMethod.POST) public Result DataStatistics (@RequestBody JSONObject body) throws Exception { Result result = new Result(ICommon.SUCCESS, propertiesUtils.get(ICommon.SUCCESS)); JSONObject object = new JSONObject(); object.put("data",testDao1.selectDailyActivity()); result.setResult(object); return result; } @RequestMapping(value = {"/test/test2"},method = RequestMethod.POST) public Result DataStatisticsaa (@RequestBody JSONObject body) throws Exception { Result result = new Result(ICommon.SUCCESS, propertiesUtils.get(ICommon.SUCCESS)); JSONObject object = new JSONObject(); object.put("data",testDao2.selectDailyActivity()); result.setResult(object); return result; } }原文链接 https://blog.csdn.net/qq_18432653/article/details/107715127 |
为了改进，现在使用SpringBoot配置连接两个数据源。
（1）第一个数据库作为主数据库，项目启动默认连接此数据库 DataSource1Config.java【本文地址】
今日新闻 |
推荐新闻 |