Java Spring中同时访问多种不同数据库

本文以在Spring框架下开发一个SpringMVC程序为例，示范了一种同时访问多种数据库的方法，而且尽量地简化配置改动。

开发企业应用时我们常常遇到要同时访问多种不同数据库的问题，有时是必须把数据归档到某种数据仓库中，有时是要把数据变更推送到第三方数据库中。使用Spring框架时，使用单一数据库是非常容易的，但如果要同时访问多个数据库的话事件就变得复杂多了。

本文以在Spring框架下开发一个SpringMVC程序为例，示范了一种同时访问多种数据库的方法，而且尽量地简化配置改动。

搭建数据库

建议你也同时搭好两个数据库来跟进我们的示例。本文中我们用了PostgreSQL和MySQL。

下面的脚本内容是在两个数据库中建表和插入数据的命令。

PostgreSQL

CREATETABLEusermaster(
idinteger,
namecharactervarying,
emailidcharactervarying,
phonenocharactervarying(10),
locationcharactervarying)
INSERTINTOusermaster(id,name,emailid,phoneno,location)VALUES(1,'name_postgres','email@email.com','1234567890','IN');

MySQL

CREATETABLE`usermaster`(`id`int(11)NOTNULL,
`name`varchar(255)DEFAULTNULL,
`emailid`varchar(20)DEFAULTNULL,
`phoneno`varchar(20)DEFAULTNULL,
`location`varchar(20)DEFAULTNULL,
PRIMARYKEY(`id`)
)INSERTINTO`kode12`.`usermaster`
(`id`,`name`,`emailid`,`phoneno`,`location`)VALUES
('1','name_mysql','test@tset.com','9876543210','IN');

搭建项目

我们用Spring Tool Suite (STS)来构建这个例子:

点击File -> New -> Spring Starter Project。

在对话框中输入项目名、Maven坐标、描述和包信息等，点击Next。

在boot dependency中选择Web，点击Next。

点击Finish。STS会自动按照项目依赖关系从Spring仓库中下载所需要的内容。

创建完的项目如下图所示:

[[191743]]

接下来我们仔细研究一下项目中的各个相关文件内容。

pom.xml

pom中包含了所有需要的依赖和插件映射关系。

代码：

<?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
http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>com.aegis</groupId>
<artifactId>MultipleDBConnect</artifactId>
<version>0.0.1-SNAPSHOT</version>
<packaging>jar</packaging>
<name>MultipleDB</name>
<description>MultipleDBwithSpringBoot</description>
<parent>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-parent</artifactId>
<version>1.3.5.RELEASE</version>
<relativePath/>
</parent>
<properties>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<java.version>1.8</java.version>
</properties>
<dependencies>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-web</artifactId>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-test</artifactId>
<scope>test</scope>
</dependency>
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-jdbc</artifactId>
</dependency>
<dependency>
<groupId>org.postgresql</groupId>
<artifactId>postgresql</artifactId>
</dependency>
<dependency>
<groupId>mysql</groupId>
<artifactId>mysql-connector-java</artifactId>
<version>5.1.38</version>
</dependency>
</dependencies>
<build>
<plugins>
<plugin>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-maven-plugin</artifactId>
</plugin>
</plugins>
</build></project>

解释：

下面详细解释各种依赖关系的细节:

spring-boot-starter-web：为Web开发和MVC提供支持。

spring-boot-starter-test:提供JUnit、Mockito等测试依赖。

spring-boot-starter-jdbc：提供JDBC支持。

postgresql：PostgreSQL数据库的JDBC驱动。

mysql-connector-java：MySQL数据库的JDBC驱动。

application.properties

包含程序需要的所有配置信息。在旧版的Spring中我们要通过多个XML文件来提供这些配置信息。

server.port=6060spring.ds_post.url=jdbc:postgresql://localhost:5432/kode12spring.ds_post.username=postgres
spring.ds_post.password=root
spring.ds_post.driverClassName=org.postgresql.Driverspring.ds_mysql.url=jdbc:mysql://localhost:3306/kode12spring.ds_mysql.username=root
spring.ds_mysql.password=root
spring.ds_mysql.driverClassName=com.mysql.jdbc.Driver

解释：

“server.port=6060”声明你的嵌入式服务器启动后会使用6060端口(port.server.port是Boot默认的标准端口)。

其他属性中：

以“spring.ds_*”为前缀的是用户定义属性。

以“spring.ds_post.*”为前缀的是为PostgreSQL数据库定义的属性。

以“spring.ds_mysql.*”为前缀的是为MySQL数据库定义的属性。

MultipleDbApplication.java

packagecom.aegis;importorg.springframework.boot.SpringApplication;importorg.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplicationpublicMultipleDbApplication{publicstaticvoidmain(String[]args){
SpringApplication.run(MultipleDbApplication.class,args);
}
}

这个文件包含了启动我们的Boot程序的主函数。注解“@SpringBootApplication”是所有其他Spring注解和Java注解的组合，包括：

@Configuration@EnableAutoConfiguration@ComponentScan@Target(value={TYPE})@Retention(value=RUNTIME)@Documented@Inherited

其他注解:

@Configuration@EnableAutoConfiguration@ComponentScan

上述注解会让容器通过这个类来加载我们的配置。

MultipleDBConfig.java

packagecom.aegis.config;importjavax.sql.DataSource;importorg.springframework.beans.factory.annotation.Qualifier;importorg.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;importorg.springframework.boot.context.properties.ConfigurationProperties;importorg.springframework.context.annotation.Bean;importorg.springframework.context.annotation.Configuration;importorg.springframework.context.annotation.Primary;importorg.springframework.jdbc.core.JdbcTemplate;
@ConfigurationpublicclassMultipleDBConfig{
@Bean(name="mysqlDb")
@ConfigurationProperties(prefix="spring.ds_mysql")
publicDataSourcemysqlDataSource(){returnDataSourceBuilder.create().build();
}
@Bean(name="mysqlJdbcTemplate")
publicJdbcTemplatejdbcTemplate(@Qualifier("mysqlDb")DataSourcedsMySQL){returnnewJdbcTemplate(dsMySQL);
}
@Bean(name="postgresDb")
@ConfigurationProperties(prefix="spring.ds_post")
publicDataSourcepostgresDataSource(){returnDataSourceBuilder.create().build();
}
@Bean(name="postgresJdbcTemplate")
publicJdbcTemplatepostgresJdbcTemplate(@Qualifier("postgresDb")
DataSourcedsPostgres){returnnewJdbcTemplate(dsPostgres);
}
}

解释：

这是加了注解的配置类，包含加载我们的PostgreSQL和MySQL数据库配置的函数和注解。这也会负责为每一种数据库创建JDBC模板类。

下面我们看一下这四个函数：

@Bean(name="mysqlDb")@ConfigurationProperties(prefix="spring.ds_mysql")publicDataSourcemysqlDataSource(){returnDataSourceBuilder.create().build();
}

上面代码***行创建了mysqlDb bean。

第二行帮助@Bean加载了所有有前缀spring.ds_mysql的属性。

第四行创建并初始化了DataSource类，并创建了mysqlDb DataSource对象。

@Bean(name="mysqlJdbcTemplate")publicJdbcTemplatejdbcTemplate(@Qualifier("mysqlDb")DataSourcedsMySQL){returnnewJdbcTemplate(dsMySQL);
}

***行以mysqlJdbcTemplate为名创建了一个JdbcTemplate类型的新Bean。

第二行将***行中创建的DataSource类型新参数传入函数，并以mysqlDB为qualifier。

第三行用DataSource对象初始化JdbcTemplate实例。

@Bean(name="postgresDb")@ConfigurationProperties(prefix="spring.ds_post")publicDataSourcepostgresDataSource(){returnDataSourceBuilder.create().build();
}

***行创建DataSource实例postgresDb。

第二行帮助@Bean加载所有以spring.ds_post为前缀的配置。

第四行创建并初始化DataSource实例postgresDb。

@Bean(name="postgresJdbcTemplate")publicJdbcTemplatepostgresJdbcTemplate(@Qualifier("postgresDb")
DataSourcedsPostgres){returnnewJdbcTemplate(dsPostgres);
}

***行以postgresJdbcTemplate为名创建JdbcTemplate类型的新bean。

第二行接受DataSource类型的参数，并以postgresDb为qualifier。

第三行用DataSource对象初始化JdbcTemplate实例。

DemoController.java

packagecom.aegis.controller;importjava.util.HashMap;importjava.util.Map;importorg.springframework.beans.factory.annotation.Autowired;importorg.springframework.beans.factory.annotation.Qualifier;importorg.springframework.jdbc.core.JdbcTemplate;importorg.springframework.web.bind.annotation.PathVariable;importorg.springframework.web.bind.annotation.RequestMapping;importorg.springframework.web.bind.annotation.RestController;
@RestControllerpublicclassDemoController{
@Autowired
@Qualifier("postgresJdbcTemplate")privateJdbcTemplatepostgresTemplate;
@Autowired
@Qualifier("mysqlJdbcTemplate")privateJdbcTemplatemysqlTemplate;
@RequestMapping(value="/getPGUser")publicStringgetPGUser(){Map<String,Object>map=newHashMap<String,Object>();Stringquery="select*fromusermaster";try{map=postgresTemplate.queryForMap(query);
}catch(Exceptione){
e.printStackTrace();
}return"PostgreSQLData:"+map.toString();
}
@RequestMapping(value="/getMYUser")publicStringgetMYUser(){Map<String,Object>map=newHashMap<String,Object>();Stringquery="select*fromusermaster";try{map=mysqlTemplate.queryForMap(query);
}catch(Exceptione){
e.printStackTrace();
}return"MySQLData:"+map.toString();
}
}

解释：

@RestController类注解表明这个类中定义的所有函数都被默认绑定到响应中。

上面代码段创建了一个JdbcTemplate实例。@Qualifier用于生成一个对应类型的模板。代码中提供的是postgresJdbcTemplate作为Qualifier参数，所以它会加载MultipleDBConfig实例的jdbcTemplate(…)函数创建的Bean。

这样Spring就会根据你的要求来调用合适的JDBC模板。在调用URL “/getPGUser”时Spring会用PostgreSQL模板，调用URL “/getMYUser”时Spring会用MySQL模板。

@Autowired@Qualifier("postgresJdbcTemplate")privateJdbcTemplatepostgresTemplate;

这里我们用queryForMap(String query)函数来使用JDBC模板从数据库中获取数据，queryForMap(…)返回一个map，以字段名为Key，Value为实际字段值。

演示

执行类MultipleDbApplication中的main (…)函数就可以看到演示效果。在你常用的浏览器中点击下面URL：

URL: http://localhost:6060/getMYUser

上面的URL会查询MySQL数据库并以字符串形式返回数据。

Url: http://localhost:6060/getPGUser

上面的URL会查询PostgreSQL数据库并以字符串形式返回数据。

关于作者

Aaron Jacobson是个经验丰富的Java Web程序员，在外包与咨询公司Technoligent担任Java开发程序员10年以上。他的主要贡献包括Java、Python、Asp.Net和手机应用等一系列Web解决方案。可以通过Twitter @Techno_Ligent或Facebook @TechnoLigent联系他。