您好,登錄后才能下訂單哦!
這篇文章給大家分享的是有關(guān)Springboot怎么同時裝配兩個相同類型數(shù)據(jù)庫的內(nèi)容。小編覺得挺實(shí)用的,因此分享給大家做個參考,一起跟隨小編過來看看吧。
1.配置文件:
spring: profiles: active: dev datasource: primary: jdbc-url: jdbc:sqlserver://localhost:1111;DatabaseName=DB1 driverClassName: com.microsoft.sqlserver.jdbc.SQLServerDriver type: com.alibaba.druid.pool.DruidDataSource username: root password: root secondary: jdbc-url: jdbc:sqlserver://localhost:1111;DatabaseName=DB2 driverClassName: com.microsoft.sqlserver.jdbc.SQLServerDriver type: com.alibaba.druid.pool.DruidDataSource username: root password: root
2.配置類:
①主配置類:DataSourceConfigPrimary
@Configuration @MapperScan(basePackages = "com.message.dao.primary", sqlSessionFactoryRef = "primarySqlSessionFactory") public class DataSourceConfigPrimary { // 將這個對象放入Spring容器中 @Bean(name = "primaryDataSource") // 表示這個數(shù)據(jù)源是默認(rèn)數(shù)據(jù)源 @Primary // 讀取application.properties中的配置參數(shù)映射成為一個對象 // prefix表示參數(shù)的前綴 @ConfigurationProperties(prefix = "spring.datasource.primary") public DataSource getDateSourcePrimary() { return DataSourceBuilder.create().build(); } @Bean(name = "primarySqlSessionFactory") // 表示這個數(shù)據(jù)源是默認(rèn)數(shù)據(jù)源 @Primary // @Qualifier表示查找Spring容器中名字為test1DataSource的對象 public SqlSessionFactory primarySqlSessionFactory(@Qualifier("primaryDataSource") DataSource datasource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(datasource); bean.setMapperLocations( // 設(shè)置mybatis的xml所在位置 new PathMatchingResourcePatternResolver().getResources("classpath:mapper/primary/*.xml")); return bean.getObject(); } @Bean("primarySqlSessionTemplate") // 表示這個數(shù)據(jù)源是默認(rèn)數(shù)據(jù)源 @Primary public SqlSessionTemplate primarySqlSessionTemplate( @Qualifier("primarySqlSessionFactory") SqlSessionFactory sessionFactory) { return new SqlSessionTemplate(sessionFactory); } }
②次配置類:DataSourceConfigSecondary
@Configuration @MapperScan(basePackages = "com.message.dao.secondary", sqlSessionFactoryRef = "secondarySqlSessionFactory") public class DataSourceConfigSecondary { @Bean(name = "secondaryDataSource") @ConfigurationProperties(prefix = "spring.datasource.secondary") public DataSource getDateSource2() { return DataSourceBuilder.create().build(); } @Bean(name = "secondarySqlSessionFactory") public SqlSessionFactory secondarySqlSessionFactory(@Qualifier("secondaryDataSource") DataSource datasource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(datasource); bean.setMapperLocations( new PathMatchingResourcePatternResolver().getResources("classpath:mapper/secondary/*.xml")); return bean.getObject(); } @Bean("secondarySqlSessionTemplate") public SqlSessionTemplate secondarySqlSessionTemplate( @Qualifier("secondarySqlSessionFactory") SqlSessionFactory sessionFactory) { return new SqlSessionTemplate(sessionFactory); } }
3.掃描XML
4.啟動類:
@SpringBootApplication(scanBasePackages = {"com.lalal.*"}) public class MessageApplication extends SpringBootServletInitializer { public static void main(String[] args) { SpringApplication.run(MessageApplication.class, args); } @Bean public RestTemplate restTemplate(){ return new RestTemplate(); } }
背景:
項(xiàng)目中需要從兩個不同的數(shù)據(jù)庫查詢數(shù)據(jù),之前實(shí)現(xiàn)方法是:springboot配置連接一個數(shù)據(jù)源,另一個使用jdbc代碼連接。
為了改進(jìn),現(xiàn)在使用SpringBoot配置連接兩個數(shù)據(jù)源
實(shí)現(xiàn)效果:
一個SpringBoot項(xiàng)目,同時連接兩個數(shù)據(jù)庫:比如一個是pgsql數(shù)據(jù)庫,一個是oracle數(shù)據(jù)庫
(啥數(shù)據(jù)庫都一樣,連接兩個同為oracle的數(shù)據(jù)庫,或兩個不同的數(shù)據(jù)庫,只需要更改對應(yīng)的driver-class-name和jdbc-url等即可)
注意:連接什么數(shù)據(jù)庫,要引入對應(yīng)數(shù)據(jù)庫的包
實(shí)現(xiàn)步驟:
1、修改application.yml,添加一個數(shù)據(jù)庫連接配置
(我這里是yml格式,后綴為properties格式是一樣的
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 #測試數(shù)據(jù)庫 username: root password: root test2: driver-class-name: oracle.jdbc.driver.OracleDriver jdbc-url: jdbc:oracle:thin:@127.0.0.1:8888:orcl #測試數(shù)據(jù)庫 username: root password: root
特別注意:
(1)使用test1、test2區(qū)分兩個數(shù)據(jù)庫連接
(2)url改為:jdbc-url
2、使用代碼進(jìn)行數(shù)據(jù)源注入,和掃描dao層路徑(以前是在yml文件里配置mybatis掃描dao的路徑)
新建config包,包含數(shù)據(jù)庫1和數(shù)據(jù)庫2的配置文件
(1)第一個數(shù)據(jù)庫作為主數(shù)據(jù)庫,項(xiàng)目啟動默認(rèn)連接此數(shù)據(jù)庫
DataSource1Config.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.context.annotation.Primary; import org.springframework.core.io.support.PathMatchingResourcePatternResolver; import org.springframework.jdbc.datasource.DataSourceTransactionManager; import javax.sql.DataSource; @Configuration @MapperScan(basePackages = "com.test.dao.test1", sqlSessionTemplateRef = "test1SqlSessionTemplate") public class DataSource1Config { @Bean(name = "test1DataSource") @ConfigurationProperties(prefix = "spring.datasource.test1") @Primary public DataSource testDataSource() { return DataSourceBuilder.create().build(); } @Bean(name = "test1SqlSessionFactory") @Primary public SqlSessionFactory testSqlSessionFactory(@Qualifier("test1DataSource") DataSource dataSource) throws Exception { SqlSessionFactoryBean bean = new SqlSessionFactoryBean(); bean.setDataSource(dataSource); bean.setMapperLocations(new PathMatchingResourcePatternResolver().getResources("classpath:test1/*.xml")); return bean.getObject(); } @Bean(name = "test1TransactionManager") @Primary public DataSourceTransactionManager testTransactionManager(@Qualifier("test1DataSource") DataSource dataSource) { return new DataSourceTransactionManager(dataSource); } @Bean(name = "test1SqlSessionTemplate") @Primary public SqlSessionTemplate testSqlSessionTemplate(@Qualifier("test1SqlSessionFactory") SqlSessionFactory sqlSessionFactory) throws Exception { return new SqlSessionTemplate(sqlSessionFactory); } }
特別注意:
(1)主數(shù)據(jù)庫都有 @Primary注解,從數(shù)據(jù)庫都沒有
(2)第二個數(shù)據(jù)庫作為從數(shù)據(jù)庫
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兩個包,分別放兩個不同數(shù)據(jù)庫的dao層文件
(1)TestDao1.java
@Component public interface TestDao1 { List<DailyActivityDataMiddle> selectDailyActivity(); }
(2)TestDao2.java
@Component public interface TestDao2 { List<MovieShowTest> selectDailyActivity(); }
4、 在resource下新建test1和test2兩個文件夾,分別放入對應(yīng)dao層的xml文件
(我原來項(xiàng)目的dao的xml文件在resource目錄下,你們在自己的項(xiàng)目對應(yīng)目錄下即可)
注意dao的java文件和dao的xml文件名字要一致
(1)TestDao1.xml
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.test.dao.test1.TestDao1"> <select id="selectDailyActivity" resultType="com.test.pojo.DailyActivityDataMiddle"> SELECT * FROM daily_activity_data_middle </select> </mapper>
(2)TestDao2.xml
<?xml version="1.0" encoding="UTF-8"?> <!DOCTYPE mapper PUBLIC "-//mybatis.org//DTD Mapper 3.0//EN" "http://mybatis.org/dtd/mybatis-3-mapper.dtd"> <mapper namespace="com.test.dao.test2.TestDao2"> <select id="selectDailyActivity" resultType="com.test.pojo.MovieShowTest"> SELECT * FROM movieshowtest </select> </mapper>
5、測試
在controller文件里,注入兩個數(shù)據(jù)庫的dao,分別查詢數(shù)據(jù)
@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<JSONObject> DataStatistics (@RequestBody JSONObject body) throws Exception { Result<JSONObject> 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<JSONObject> DataStatisticsaa (@RequestBody JSONObject body) throws Exception { Result<JSONObject> result = new Result<>(ICommon.SUCCESS, propertiesUtils.get(ICommon.SUCCESS)); JSONObject object = new JSONObject(); object.put("data",testDao2.selectDailyActivity()); result.setResult(object); return result; } }
感謝各位的閱讀!關(guān)于“Springboot怎么同時裝配兩個相同類型數(shù)據(jù)庫”這篇文章就分享到這里了,希望以上內(nèi)容可以對大家有一定的幫助,讓大家可以學(xué)到更多知識,如果覺得文章不錯,可以把它分享出去讓更多的人看到吧!
免責(zé)聲明:本站發(fā)布的內(nèi)容(圖片、視頻和文字)以原創(chuàng)、轉(zhuǎn)載和分享為主,文章觀點(diǎn)不代表本網(wǎng)站立場,如果涉及侵權(quán)請聯(lián)系站長郵箱:is@yisu.com進(jìn)行舉報,并提供相關(guān)證據(jù),一經(jīng)查實(shí),將立刻刪除涉嫌侵權(quán)內(nèi)容。