Spring Boot学习(七)之Web应用使用jdbctemplate多数据源配置

<?xmlversion="1.0"encoding="UTF-8"?>
<projectxmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://maven.apache.org/POM/4.0.0>'target='_blank'>http://maven.apache.org/xsd/maven-4.0.0.xsd"><modelVersion>4.0.0</modelVersion>

<groupId>com.xiaojingg</groupId>
<artifactId>springbootstudy-demo7-jdbctemplate-more</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>

<name>springbootstudy-demo7-jdbctemplate-more</name>
<description>DemoprojectforSpringBoot</description>

<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.5.8.RELEASE</version>
<relativePath/><!--lookupparentfromrepository-->
</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>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.21</version>
</dependency>

<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>

</dependencies>

<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build>

</project>

01

package

com.xiaojingg;

02

03

import

org.springframework.beans.factory.annotation.Qualifier;

04

import

org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;

05

import

org.springframework.boot.context.properties.ConfigurationProperties;

06

import

org.springframework.context.annotation.Bean;

07

import

org.springframework.context.annotation.Configuration;

08

import

org.springframework.context.annotation.Primary;

09

import

org.springframework.jdbc.core.JdbcTemplate;

10

11

import

javax.sql.DataSource;

12

13

/**

14

*
筱进GG

15

*/

16

@Configuration

17

public

class

DataSourceConfig
{

18

19

@Bean

(name
=

"primaryDataSource"

)

20

@Qualifier

(

"primaryDataSource"

)

21

@ConfigurationProperties

(prefix=

"spring.datasource.primary"

)

22

public

DataSource
primaryDataSource(){

23

return

DataSourceBuilder.create().build();

24

}

25

26

@Bean

(name
=

"secondaryDataSource"

)

27

@Qualifier

(

"secondaryDataSource"

)

28

@Primary

29

@ConfigurationProperties

(prefix=

"spring.datasource.secondary"

)

30

public

DataSource
secondaryDataSource(){

31

return

DataSourceBuilder.create().build();

32

}

33

34

@Bean

(name
=

"primaryJdbcTemplate"

)

35

public

JdbcTemplate
primaryJdbcTemplate(

36

@Qualifier

(

"primaryDataSource"

)
DataSourcedataSource){

37

return

new

JdbcTemplate(dataSource);

38

}

39

40

@Bean

(name
=

"secondaryJdbcTemplate"

)

41

public

JdbcTemplate
secondaryJdbcTemplate(

42

@Qualifier

(

"secondaryDataSource"

)
DataSourcedataSource){

43

return

new

JdbcTemplate(dataSource);

44

}

45

46

}

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

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

packagecom.xiaojingg;

importorg.junit.Assert;
importorg.junit.Before;
importorg.junit.Test;
importorg.junit.runner.RunWith;
importorg.springframework.beans.factory.annotation.Autowired;
importorg.springframework.beans.factory.annotation.Qualifier;
importorg.springframework.boot.test.context.SpringBootTest;
importorg.springframework.jdbc.core.JdbcTemplate;
importorg.springframework.test.context.junit4.SpringRunner;

@RunWith(SpringRunner.class)
@SpringBootTest
publicclassSpringbootstudyDemo7JdbctemplateMoreApplicationTests{

@Autowired
@Qualifier("primaryJdbcTemplate")
protectedJdbcTemplatejdbcTemplate1;

@Autowired
@Qualifier("secondaryJdbcTemplate")
protectedJdbcTemplatejdbcTemplate2;

@Before
publicvoidsetUp(){
jdbcTemplate1.update("DELETEFROMUSER");
jdbcTemplate2.update("DELETEFROMUSER");
}

@Test
publicvoidtest()throwsException{

//往第一个数据源中插入两条数据
jdbcTemplate1.update("insertintouser(id,name,age)values(?,?,?)",1,"aaa",20);
jdbcTemplate1.update("insertintouser(id,name,age)values(?,?,?)",2,"bbb",30);

//往第二个数据源中插入一条数据，若插入的是第一个数据源，则会主键冲突报错
jdbcTemplate2.update("insertintouser(id,name,age)values(?,?,?)",1,"aaa",20);

//查一下第一个数据源中是否有两条数据，验证插入是否成功
Assert.assertEquals("2",jdbcTemplate1.queryForObject("selectcount(1)fromuser",String.class));

//查一下第一个数据源中是否有两条数据，验证插入是否成功
Assert.assertEquals("1",jdbcTemplate2.queryForObject("selectcount(1)fromuser",String.class));

}

}