springboot整合oracle并实现多数据源

前文：
        工作之余忽然想写一个springboot+oracle+vue的项目，想把工作老掉牙的spring+struts+jsp项目给换掉！老项目维护起来真难熬啊！新项目开始的时间遇到了多数据源的问题，网上找了很多多少代码案例，但是都没有解决问题！于是总结了一个demo，方便大家学习使用！
1.项目准备

1.项目创建

我这里是直接用的maven项目，然后自己导入的依靠！

2.导入依靠

项目结构如下：

导入依靠：

1. <?xml version="1.0" encoding="UTF-8"?>
2. <project xmlns="http://maven.apache.org/POM/4.0.0"
3.          xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
4.          xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
5.     <modelVersion>4.0.0</modelVersion>
7.     <groupId>org.example</groupId>
8.     <artifactId>demo</artifactId>
9.     <version>1.0-SNAPSHOT</version>
11.     <properties>
12.         <maven.compiler.source>8</maven.compiler.source>
13.         <maven.compiler.target>8</maven.compiler.target>
14.     </properties>
15.     <parent>
16.         <groupId>org.springframework.boot</groupId>
17.         <artifactId>spring-boot-starter-parent</artifactId>
18.         <version>2.7.17</version>
19.         <relativePath/> <!-- lookup parent from repository -->
20.     </parent>
21.     <dependencies>
22.         <!--Web依赖-->
23.         <dependency>
24.             <groupId>org.springframework.boot</groupId>
25.             <artifactId>spring-boot-starter-web</artifactId>
26.         </dependency>
27.         <!--lombok依赖-->
28.         <dependency>
29.             <groupId>org.projectlombok</groupId>
30.             <artifactId>lombok</artifactId>
31.             <version>1.18.22</version>
32.             <scope>provided</scope>
33.         </dependency>
34.         <!--jdbc依赖-->
35.         <dependency>
36.             <groupId>org.springframework.boot</groupId>
37.             <artifactId>spring-boot-starter-jdbc</artifactId>
38.         </dependency>
39.         <!--oracle依赖-->
40.         <dependency>
41.             <groupId>com.oracle.database.jdbc</groupId>
42.             <artifactId>ojdbc8</artifactId>
43.             <version>19.3.0.0</version>
44.         </dependency>
45.     </dependencies>
47. </project>

复制代码

3.添加配置文件

新建一个application.properties

1. # database1
2. spring.datasource.primary.url=jdbc:oracle:thin:@localhost:1521:orcl20
3. spring.datasource.primary.username=test1
4. spring.datasource.primary.password=test1
5. spring.datasource.primary.driver-class-name=oracle.jdbc.driver.OracleDriver
7. # database2
8. spring.datasource.secondary.url=jdbc:oracle:thin:@localhost:1521:orcl3
9. spring.datasource.secondary.username=test2
10. spring.datasource.secondary.password=test2
11. spring.datasource.secondary.driver-class-name=oracle.jdbc.driver.OracleDriver

复制代码

4.启动类创建

创建com.xyl.Application.java文件

1. package com.xyl;
3. import org.springframework.boot.SpringApplication;
4. import org.springframework.boot.autoconfigure.SpringBootApplication;
7. @SpringBootApplication
8. public class Application {
9.     public static void main(String[] args) {
10.         SpringApplication.run(Application.class,args);
11.     }
12. }

复制代码

5.数据源配置类

创建com.xyl.config.DataSourceConfig.java文件

1. package com.xyl.config;
3. import com.zaxxer.hikari.HikariConfig;
4. import com.zaxxer.hikari.HikariDataSource;
5. import org.springframework.beans.factory.annotation.Qualifier;
6. import org.springframework.beans.factory.annotation.Value;
7. import org.springframework.context.annotation.Bean;
8. import org.springframework.context.annotation.Configuration;
9. import org.springframework.jdbc.core.JdbcTemplate;
11. import javax.sql.DataSource;
13. @Configuration
14. public class DataSourceConfig {
16.     @Bean(name = "primaryDataSource")
17.     public DataSource primaryDataSource(@Value("${spring.datasource.primary.url}") String url,
18.                                         @Value("${spring.datasource.primary.username}") String username,
19.                                         @Value("${spring.datasource.primary.password}") String password,
20.                                         @Value("${spring.datasource.primary.driver-class-name}") String driverClassName) {
21.         HikariConfig config = new HikariConfig();
22.         config.setJdbcUrl(url);
23.         config.setUsername(username);
24.         config.setPassword(password);
25.         config.setDriverClassName(driverClassName);
26.         return new HikariDataSource(config);
27.     }
29.     @Bean(name = "secondaryDataSource")
30.     public DataSource secondaryDataSource(@Value("${spring.datasource.secondary.url}") String url,
31.                                           @Value("${spring.datasource.secondary.username}") String username,
32.                                           @Value("${spring.datasource.secondary.password}") String password,
33.                                           @Value("${spring.datasource.secondary.driver-class-name}") String driverClassName) {
34.         HikariConfig config = new HikariConfig();
35.         config.setJdbcUrl(url);
36.         config.setUsername(username);
37.         config.setPassword(password);
38.         config.setDriverClassName(driverClassName);
39.         return new HikariDataSource(config);
40.     }
42.     @Bean(name = "oneTemplate")
43.     public JdbcTemplate primaryJdbcTemplate(@Qualifier("primaryDataSource") DataSource dataSource) {
44.         return new JdbcTemplate(dataSource);
45.     }
47.     @Bean(name = "twoTemplate")
48.     public JdbcTemplate secondaryJdbcTemplate(@Qualifier("secondaryDataSource") DataSource dataSource) {
49.         return new JdbcTemplate(dataSource);
50.     }
51. }

复制代码

6.dao和controller创建

这里为了测试，只创建dao和controller类，接口也没去写。大家工作和学习中万万别学我这样啊！
com.xyl.dao.TestDao.java
com.xyl.controller.TestController.java

1. package com.xyl.dao;
3. import lombok.extern.slf4j.Slf4j;
4. import org.springframework.beans.factory.annotation.Autowired;
5. import org.springframework.jdbc.core.JdbcTemplate;
6. import org.springframework.stereotype.Repository;
8. import javax.annotation.Resource;
9. import java.util.List;
10. import java.util.Map;
13. @Slf4j
14. @Repository
15. public class TestDao {
16.     @Resource
17.     private JdbcTemplate oneTemplate;
18.     @Resource
19.     private JdbcTemplate twoTemplate;
21.     public List<Map<String,Object>> getTest(){
22.         String sql = " select * from AAA where ROWNUM <= 10";
23.         List<Map<String, Object>> tableData = oneTemplate.queryForList(sql);
24.         log.info("这是在database1中获取的数据：{}",tableData);
25.         sql = " select * from AA  where ROWNUM <= 10";
26.         return twoTemplate.queryForList(sql);
27.     }
28. }

复制代码

1. package com.xyl.controller;
3. import com.xyl.dao.TestDao;
4. import org.springframework.web.bind.annotation.RequestMapping;
5. import org.springframework.web.bind.annotation.RestController;
7. import javax.annotation.Resource;
8. import java.util.List;
9. import java.util.Map;
12. @RequestMapping("/test")
13. @RestController
14. public class TestController {
15.     @Resource
16.     private TestDao testDao;
17.     @RequestMapping("/get")
18.     public List<Map<String,Object>> getTest(){
19.         return testDao.getTest();
20.     }
21. }

复制代码

7.启动项目看运行结果 

 抱歉哈，database2里面AA表忘记添加数据啦！
总结：demo到这里就已经结束啦。盼望可能帮到各位！

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。