Springboot 非web项目，多数据源配置

谁践踏了优雅 2022-04-23 00:58 175阅读 0赞

1. application.properties文件

springboot 1 .0配置数据源的过程中主要是写成：spring.datasource.url 和spring.datasource.driverClassName。

springboot 2.0升级之后需要变更成：spring.datasource.jdbc-url和spring.datasource.driver-class-name即可解决！![watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NjM1ODc0_size_16_color_FFFFFF_t_70][]

2. DataSourceConfig类

@Configuration
    public class DataSourceConfig {
    	@Bean(name = "primaryDataSource")
    	@Qualifier("primaryDataSource")
    	@ConfigurationProperties(prefix = "spring.datasource.primary")
    	public DataSource primaryDataSource() {
    		return DataSourceBuilder.create().build();
    	}
    
    	@Bean(name = "secondaryDataSource")
    	@Qualifier("secondaryDataSource")
    	@Primary
    	@ConfigurationProperties(prefix = "spring.datasource.secondary")
    	public DataSource secondaryDataSource() {
    		return DataSourceBuilder.create().build();
    	}
    	 @Bean(name = "primaryJdbcTemplate")
    	    public JdbcTemplate primaryJdbcTemplate(
    	            @Qualifier("primaryDataSource") DataSource dataSource) {
    	        return new JdbcTemplate(dataSource);
    	    }
    
    	    @Bean(name = "secondaryJdbcTemplate")
    	    public JdbcTemplate secondaryJdbcTemplate(
    	            @Qualifier("secondaryDataSource") DataSource dataSource) {
    	        return new JdbcTemplate(dataSource);
    	    }
    
    }

3. 测试类

@RunWith(SpringRunner.class)
    @SpringBootTest
    public class VCenterApplicationTests {
    
    	@Autowired
        @Qualifier("primaryJdbcTemplate")
        protected JdbcTemplate jdbcTemplate1;
    
        @Autowired
        @Qualifier("secondaryJdbcTemplate")
        protected JdbcTemplate jdbcTemplate2;
    	
    	@Test
    	public void contextLoads() {
    	}
    
    	 @Test
        public void test() throws Exception {
    
            // 往第一个数据源中插入两条数据
           /* jdbcTemplate1.update("insert into user(id,name,age) values(?, ?, ?)", 1, "aaa", 20);
            jdbcTemplate1.update("insert into user(id,name,age) values(?, ?, ?)", 2, "bbb", 30);
    
            // 往第二个数据源中插入一条数据，若插入的是第一个数据源，则会主键冲突报错
            jdbcTemplate2.update("insert into user(id,name,age) values(?, ?, ?)", 1, "aaa", 20);*/
    
            // 查一下第一个数据源中是否有两条数据，验证插入是否成功
    		 List<String> list= jdbcTemplate1.queryForList("select description from log_messages where description like '%启动%' and ip != '127.0.0.1'", String.class);
    
            // 查一下第一个数据源中是否有两条数据，验证插入是否成功
            Assert.assertEquals("1", jdbcTemplate2.queryForObject("select count(1) from user", String.class));
    
        }
    
    }

4. 部分pom.xml

<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>2.1.1.RELEASE</version>
    		<relativePath/> 
    	</parent>
    
    	<properties>
    		<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
    		<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
    		<java.version>1.8</java.version>
    	</properties>
    
    	<dependencies>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter</artifactId>
    		</dependency>
    
    
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    		
    		
    	<dependency>
    		    <groupId>com.jcraft</groupId>
    		    <artifactId>jsch</artifactId>
    		    <version>0.1.54</version>
    		</dependency>
    		
    		
    		<dependency>
    		    <groupId>org.hamcrest</groupId>
    		    <artifactId>hamcrest-all</artifactId>
    		    <version>1.3</version>
    		    <scope>test</scope>
    		</dependency>
    		
    		
    	    <dependency>
    		    <groupId>org.springframework.boot</groupId>
    		    <artifactId>spring-boot-starter-jdbc</artifactId>
    	    </dependency>
    	    
    	    <dependency>
    	     <groupId>mysql</groupId>
    	     <artifactId>mysql-connector-java</artifactId>
            </dependency>
    		
    
    
    
    
    
    
      	   
            <dependency>
                <groupId>org.apache.commons</groupId>
                <artifactId>commons-lang3</artifactId>
                <version>3.6</version>
            </dependency>
    	</dependencies>

[watermark_type_ZmFuZ3poZW5naGVpdGk_shadow_10_text_aHR0cHM6Ly9ibG9nLmNzZG4ubmV0L3FxXzM3NjM1ODc0_size_16_color_FFFFFF_t_70]: /images/20220323/9efc4177bd5a4f219dff2558c868828e.png