Springboot怎么同时装配两个相同类型数据库(springboot,数据库,开发技术)

同时装配两个相同类型数据库

1.配置文件：

spring:profiles:active:devdatasource:primary:jdbc-url:jdbc:sqlserver://localhost:1111;DatabaseName=DB1driverClassName:com.microsoft.sqlserver.jdbc.SQLServerDrivertype:com.alibaba.druid.pool.DruidDataSourceusername:rootpassword:rootsecondary:jdbc-url:jdbc:sqlserver://localhost:1111;DatabaseName=DB2driverClassName:com.microsoft.sqlserver.jdbc.SQLServerDrivertype:com.alibaba.druid.pool.DruidDataSourceusername:rootpassword:root

2.配置类：

①主配置类：DataSourceConfigPrimary

@Configuration@MapperScan(basePackages="com.message.dao.primary",sqlSessionFactoryRef="primarySqlSessionFactory")publicclassDataSourceConfigPrimary{//将这个对象放入Spring容器中@Bean(name="primaryDataSource")//表示这个数据源是默认数据源@Primary//读取application.properties中的配置参数映射成为一个对象//prefix表示参数的前缀@ConfigurationProperties(prefix="spring.datasource.primary")publicDataSourcegetDateSourcePrimary(){returnDataSourceBuilder.create().build();}@Bean(name="primarySqlSessionFactory")//表示这个数据源是默认数据源@Primary//@Qualifier表示查找Spring容器中名字为test1DataSource的对象publicSqlSessionFactoryprimarySqlSessionFactory(@Qualifier("primaryDataSource")DataSourcedatasource)throwsException{SqlSessionFactoryBeanbean=newSqlSessionFactoryBean();bean.setDataSource(datasource);bean.setMapperLocations(//设置mybatis的xml所在位置newPathMatchingResourcePatternResolver().getResources("classpath:mapper/primary/*.xml"));returnbean.getObject();}@Bean("primarySqlSessionTemplate")//表示这个数据源是默认数据源@PrimarypublicSqlSessionTemplateprimarySqlSessionTemplate(@Qualifier("primarySqlSessionFactory")SqlSessionFactorysessionFactory){returnnewSqlSessionTemplate(sessionFactory);}}

②次配置类：DataSourceConfigSecondary

@Configuration@MapperScan(basePackages="com.message.dao.secondary",sqlSessionFactoryRef="secondarySqlSessionFactory")publicclassDataSourceConfigSecondary{@Bean(name="secondaryDataSource")@ConfigurationProperties(prefix="spring.datasource.secondary")publicDataSourcegetDateSource2(){returnDataSourceBuilder.create().build();}@Bean(name="secondarySqlSessionFactory")publicSqlSessionFactorysecondarySqlSessionFactory(@Qualifier("secondaryDataSource")DataSourcedatasource)throwsException{SqlSessionFactoryBeanbean=newSqlSessionFactoryBean();bean.setDataSource(datasource);bean.setMapperLocations(newPathMatchingResourcePatternResolver().getResources("classpath:mapper/secondary/*.xml"));returnbean.getObject();}@Bean("secondarySqlSessionTemplate")publicSqlSessionTemplatesecondarySqlSessionTemplate(@Qualifier("secondarySqlSessionFactory")SqlSessionFactorysessionFactory){returnnewSqlSessionTemplate(sessionFactory);}}

3.扫描XML

4.启动类：

@SpringBootApplication(scanBasePackages={"com.lalal.*"})publicclassMessageApplicationextendsSpringBootServletInitializer{publicstaticvoidmain(String[]args){SpringApplication.run(MessageApplication.class,args);}@BeanpublicRestTemplaterestTemplate(){returnnewRestTemplate();}}

配置连接两个或多个数据库

背景：

项目中需要从两个不同的数据库查询数据，之前实现方法是：springboot配置连接一个数据源，另一个使用jdbc代码连接。

为了改进，现在使用SpringBoot配置连接两个数据源

实现效果：

一个SpringBoot项目，同时连接两个数据库：比如一个是pgsql数据库，一个是oracle数据库

（啥数据库都一样，连接两个同为oracle的数据库，或两个不同的数据库，只需要更改对应的driver-class-name和jdbc-url等即可）

注意：连接什么数据库，要引入对应数据库的包

实现步骤：

1、修改application.yml，添加一个数据库连接配置

（我这里是yml格式，后缀为properties格式是一样的

server:port:7101spring:jpa:show-sql:truedatasource:test1:driver-class-name:org.postgresql.Driverjdbc-url:jdbc:postgresql://127.0.0.1:5432/test#测试数据库username:rootpassword:roottest2:driver-class-name:oracle.jdbc.driver.OracleDriverjdbc-url:jdbc:oracle:thin:@127.0.0.1:8888:orcl#测试数据库username:rootpassword:root

特别注意：

（1）使用test1、test2区分两个数据库连接

（2）url改为：jdbc-url

2、使用代码进行数据源注入，和扫描dao层路径（以前是在yml文件里配置mybatis扫描dao的路径）

新建config包，包含数据库1和数据库2的配置文件

（1）第一个数据库作为主数据库，项目启动默认连接此数据库

DataSource1Config.java

packagecom.test.config;importorg.apache.ibatis.session.SqlSessionFactory;importorg.mybatis.spring.SqlSessionFactoryBean;importorg.mybatis.spring.SqlSessionTemplate;importorg.mybatis.spring.annotation.MapperScan;importorg.springframework.beans.factory.annotation.Qualifier;importorg.springframework.boot.context.properties.ConfigurationProperties;importorg.springframework.boot.jdbc.DataSourceBuilder;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.context.annotation.Primary;importorg.springframework.core.io.support.PathMatchingResourcePatternResolver;importorg.springframework.jdbc.datasource.DataSourceTransactionManager;importjavax.sql.DataSource;@Configuration@MapperScan(basePackages="com.test.dao.test1",sqlSessionTemplateRef="test1SqlSessionTemplate")publicclassDataSource1Config{@Bean(name="test1DataSource")@ConfigurationProperties(prefix="spring.datasource.test1")@PrimarypublicDataSourcetestDataSource(){returnDataSourceBuilder.create().build();}@Bean(name="test1SqlSessionFactory")@PrimarypublicSqlSessionFactorytestSqlSessionFactory(@Qualifier("test1DataSource")DataSourcedataSource)throwsException{SqlSessionFactoryBeanbean=newSqlSessionFactoryBean();bean.setDataSource(dataSource);bean.setMapperLocations(newPathMatchingResourcePatternResolver().getResources("classpath:test1/*.xml"));returnbean.getObject();}@Bean(name="test1TransactionManager")@PrimarypublicDataSourceTransactionManagertestTransactionManager(@Qualifier("test1DataSource")DataSourcedataSource){returnnewDataSourceTransactionManager(dataSource);}@Bean(name="test1SqlSessionTemplate")@PrimarypublicSqlSessionTemplatetestSqlSessionTemplate(@Qualifier("test1SqlSessionFactory")SqlSessionFactorysqlSessionFactory)throwsException{returnnewSqlSessionTemplate(sqlSessionFactory);}}

特别注意：

（1）主数据库都有 @Primary注解，从数据库都没有

（2）第二个数据库作为从数据库

DataSource2Config.java

packagecom.test.config;importorg.apache.ibatis.session.SqlSessionFactory;importorg.mybatis.spring.SqlSessionFactoryBean;importorg.mybatis.spring.SqlSessionTemplate;importorg.mybatis.spring.annotation.MapperScan;importorg.springframework.beans.factory.annotation.Qualifier;importorg.springframework.boot.context.properties.ConfigurationProperties;importorg.springframework.boot.jdbc.DataSourceBuilder;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.core.io.support.PathMatchingResourcePatternResolver;importorg.springframework.jdbc.datasource.DataSourceTransactionManager;importjavax.sql.DataSource;@Configuration@MapperScan(basePackages="com.test.dao.test2",sqlSessionTemplateRef="test2SqlSessionTemplate")publicclassDataSource2Config{@Bean(name="test2DataSource")@ConfigurationProperties(prefix="spring.datasource.test2")publicDataSourcetestDataSource(){returnDataSourceBuilder.create().build();}@Bean(name="test2SqlSessionFactory")publicSqlSessionFactorytestSqlSessionFactory(@Qualifier("test2DataSource")DataSourcedataSource)throwsException{SqlSessionFactoryBeanbean=newSqlSessionFactoryBean();bean.setDataSource(dataSource);bean.setMapperLocations(newPathMatchingResourcePatternResolver().getResources("classpath:test2/*.xml"));returnbean.getObject();}@Bean(name="test2TransactionManager")publicDataSourceTransactionManagertestTransactionManager(@Qualifier("test2DataSource")DataSourcedataSource){returnnewDataSourceTransactionManager(dataSource);}@Bean(name="test2SqlSessionTemplate")publicSqlSessionTemplatetestSqlSessionTemplate(@Qualifier("test2SqlSessionFactory")SqlSessionFactorysqlSessionFactory)throwsException{returnnewSqlSessionTemplate(sqlSessionFactory);}}

3、 在dao文件夹下，新建test1和test2两个包，分别放两个不同数据库的dao层文件

（1）TestDao1.java

@ComponentpublicinterfaceTestDao1{List<DailyActivityDataMiddle>selectDailyActivity();}

（2）TestDao2.java

@ComponentpublicinterfaceTestDao2{List<MovieShowTest>selectDailyActivity();}

4、 在resource下新建test1和test2两个文件夹，分别放入对应dao层的xml文件

（我原来项目的dao的xml文件在resource目录下，你们在自己的项目对应目录下即可）

注意dao的java文件和dao的xml文件名字要一致

（1）TestDao1.xml

<?xmlversion="1.0"encoding="UTF-8"?><!DOCTYPEmapperPUBLIC"-//mybatis.org//DTDMapper3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mappernamespace="com.test.dao.test1.TestDao1"><selectid="selectDailyActivity"resultType="com.test.pojo.DailyActivityDataMiddle">SELECT*FROMdaily_activity_data_middle</select></mapper>

（2）TestDao2.xml

<?xmlversion="1.0"encoding="UTF-8"?><!DOCTYPEmapperPUBLIC"-//mybatis.org//DTDMapper3.0//EN""http://mybatis.org/dtd/mybatis-3-mapper.dtd"><mappernamespace="com.test.dao.test2.TestDao2"><selectid="selectDailyActivity"resultType="com.test.pojo.MovieShowTest">SELECT*FROMmovieshowtest</select></mapper>

5、测试

在controller文件里，注入两个数据库的dao，分别查询数据

@RestControllerpublicclassTestControllerextendsBaseController{@AutowiredprivatePropertiesUtilspropertiesUtils;@AutowiredprivateTestDao1testDao1;@AutowiredprivateTestDao2testDao2;@RequestMapping(value={"/test/test1"},method=RequestMethod.POST)publicResult<JSONObject>DataStatistics(@RequestBodyJSONObjectbody)throwsException{Result<JSONObject>result=newResult<>(ICommon.SUCCESS,propertiesUtils.get(ICommon.SUCCESS));JSONObjectobject=newJSONObject();object.put("data",testDao1.selectDailyActivity());result.setResult(object);returnresult;}@RequestMapping(value={"/test/test2"},method=RequestMethod.POST)publicResult<JSONObject>DataStatisticsaa(@RequestBodyJSONObjectbody)throwsException{Result<JSONObject>result=newResult<>(ICommon.SUCCESS,propertiesUtils.get(ICommon.SUCCESS));JSONObjectobject=newJSONObject();object.put("data",testDao2.selectDailyActivity());result.setResult(object);returnresult;}}