springboot干货——（十）多数据源配置之JDBC

缺乏、安全感 2021-09-26 12:34 423阅读 0赞

前言

前面有讲到单一数据源的jdbc项目实战，但是在实际项目中我们可能不仅会面临单一数据源的状况，甚至还会遇到多数据源的状况，那本篇博客就基于jdbc方式带大家来学习如何使用springboot配置多数据源。

正文

实战

1.项目结构

![SouthEast][]

数据库

![SouthEast 1][]

2.pom.xml

<parent>
    		<groupId>org.springframework.boot</groupId>
    		<artifactId>spring-boot-starter-parent</artifactId>
    		<version>1.5.9.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>com.alibaba</groupId>  
                <artifactId>druid</artifactId>  
                <version>1.0.29</version>  
            </dependency>  
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-test</artifactId>
    			<scope>test</scope>
    		</dependency>
    		<dependency>
    		    <groupId>mysql</groupId>
    		    <artifactId>mysql-connector-java</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-jdbc</artifactId>
    		</dependency>
    		<dependency>
    			<groupId>org.springframework.boot</groupId>
    			<artifactId>spring-boot-starter-web</artifactId>
    		</dependency>
    	</dependencies>
    
    	<build>
    		<plugins>
    			<plugin>
    				<groupId>org.springframework.boot</groupId>
    				<artifactId>spring-boot-maven-plugin</artifactId>
    			</plugin>
    		</plugins>
    	</build>

2.application.properties

spring.datasource.primary.url=jdbc:mysql://localhost:3306/test
    spring.datasource.primary.username=root
    spring.datasource.primary.password=XXXXXXX
    spring.datasource.primary.driver-class-name=com.mysql.jdbc.Driver
    
    spring.datasource.secondary.url=jdbc:mysql://localhost:3306/myweb
    spring.datasource.secondary.username=root
    spring.datasource.secondary.password=XXXXXXX
    spring.datasource.secondary.driver-class-name=com.mysql.jdbc.Driver

3.创建DataSourceConfig类

【注意】这边用的是DruidDataSource，另外这边的 @ConfigurationProperties(prefix="spring.datasource.secondary")需要和application.properties里面的内容对应。

@Primary的意思是在众多相同的bean中，优先使用用@Primary注解的bean.而@Qualifier这个注解则指定某个bean有没有资格进行注入。

import javax.sql.DataSource;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.boot.context.properties.ConfigurationProperties;
    import org.springframework.context.annotation.Bean;
    import org.springframework.context.annotation.Configuration;
    import org.springframework.context.annotation.Primary;
    import org.springframework.jdbc.core.JdbcTemplate;
    
    
    /** 
    * @ProjectName spring-boot
    * @author JackHisen(gu.weidong) 
    * @Date 2018年2月14日 下午2:55:09    
    * @Version 1.0 
    * @Description:
    */
    @Configuration
    public class DataSourceConfig {
    	@Bean(name = "primaryDataSource")
        @Qualifier("primaryDataSource")
        @ConfigurationProperties(prefix="spring.datasource.primary")
        public DataSource primaryDataSource() {
    		DataSource dataSource = new com.alibaba.druid.pool.DruidDataSource();
            return dataSource;
        }
    
        @Bean(name = "secondaryDataSource")
        @Qualifier("secondaryDataSource")
        @Primary
        @ConfigurationProperties(prefix="spring.datasource.secondary")
        public DataSource secondaryDataSource() {
        	DataSource dataSource = new com.alibaba.druid.pool.DruidDataSource();
            return dataSource;
        }
        
        @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);
    	}
    }

4.StuServiceImpl和UserServiceImpl

User和Stu对应数据库，由mybatis自动生成的model

import java.util.List;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.jdbc.core.BeanPropertyRowMapper;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.stereotype.Service;
    import com.gwd.model.User;
    import com.gwd.service.UserService;
    
    /** 
    * @ProjectName spring-boot
    * @author JackHisen(gu.weidong) 
    * @Date 2018年2月14日 下午9:38:51    
    * @Version 1.0 
    * @Description:
    */
    @Service
    public class UserServiceImpl implements UserService {
    	@Autowired
    	@Qualifier("secondaryJdbcTemplate")
    	protected JdbcTemplate jdbcTemplate2;
    	
    	public User getUserById(int id) {
    		String sql ="select * from users where id =?";
    		List<User> user = jdbcTemplate2.query(sql, new Object[] {id},new BeanPropertyRowMapper<User>(User.class));
    		return user.get(0);
    	}
    }

import java.util.List;
    import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.beans.factory.annotation.Qualifier;
    import org.springframework.jdbc.core.BeanPropertyRowMapper;
    import org.springframework.jdbc.core.JdbcTemplate;
    import org.springframework.stereotype.Service;
    import com.gwd.model.Stu;
    import com.gwd.service.StuService;
    /** 
    * @ProjectName spring-boot
    * @author JackHisen(gu.weidong) 
    * @Date 2018年2月14日 下午2:48:51    
    * @Version 1.0 
    * @Description:
    */
    @Service
    public class StuServiceImpl implements StuService{
    	@Autowired
    	@Qualifier("primaryJdbcTemplate")
    	protected JdbcTemplate jdbcTemplate1;
    
    	
    	@Override
    	public Stu getStuById(int id) {
    		String sql="select * from stu where id=?";
    		List<Stu> stu1 = jdbcTemplate1.query(sql,  new Object[]{id},new BeanPropertyRowMapper<Stu>(Stu.class));
    		return stu1.get(0);
    	}
    }

5.Controller

import org.springframework.beans.factory.annotation.Autowired;
    import org.springframework.web.bind.annotation.RequestMapping;
    import org.springframework.web.bind.annotation.RestController;
    import com.gwd.service.StuService;
    import com.gwd.service.UserService;
    /** 
    * @ProjectName spring-boot
    * @author JackHisen(gu.weidong) 
    * @Date 2018年2月14日 下午3:07:43    
    * @Version 1.0 
    * @Description:
    */
    @RestController 
    public class TestController{
    	@Autowired
    	StuService stuService;
    	@Autowired
    	UserService userService;
    	
    	@RequestMapping("/testStu")
    	public String testStu()  {
    		return stuService.getStuById(1).getName();
    	}
    	
    	@RequestMapping("/testUser")
    	public String testUser() {
    		return userService.getUserById(6).getUsername();
    	}
    }

结果：

成功！！！

![SouthEast 2][]

![SouthEast 3][]

[SouthEast]: /images/20210923/346c6a21f4164cd780134c2ec2baf260.png
[SouthEast 1]: /images/20210923/9181c50cf1ae45289b8e58d8e95b5efb.png
[SouthEast 2]: /images/20210923/128c9722da704fed8993ce14034eafb6.png
[SouthEast 3]: /images/20210923/776ad75d2bfb47638058d35cc3b452d5.png