鲨鱼网
Java Spring中同时访问多种不同数据库
创始人
2025-02-12 13:11:04
0次

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

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

搭建数据库

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

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

PostgreSQL

  1. CREATE TABLE usermaster (  
  2.    id integer,  
  3.    name character varying,  
  4.    emailid character varying,  
  5.    phoneno character varying(10),  
  6.    location character varying)  
  7.  
  8. INSERT INTO usermaster(id, name, emailid, phoneno, location)VALUES (1, 'name_postgres', 'email@email.com', '1234567890', 'IN');  

MySQL

  1. CREATE TABLE `usermaster` (   `id` int(11) NOT NULL,  
  2.    `name` varchar(255) DEFAULT NULL,  
  3.    `emailid` varchar(20) DEFAULT NULL,  
  4.    `phoneno` varchar(20) DEFAULT NULL,  
  5.    `location` varchar(20) DEFAULT NULL,  
  6.    PRIMARY KEY (`id`)  
  7. )INSERT INTO `kode12`.`usermaster`  
  8.   (`id`, `name`, `emailid`, `phoneno`, `location`)VALUES 
  9.   ('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中包含了所有需要的依赖和插件映射关系。

代码：

  2.     xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" 
  3.     xsi:schemaLocation="http://maven.apache.org/POM/4.0.0  
  4.     http://maven.apache.org/xsd/maven-4.0.0.xsd"> 
  5.     4.0.0 
  6.  
  7.     com.aegis 
  8.     MultipleDBConnect 
  9.     0.0.1-SNAPSHOT 
  10.     jar 
  11.  
  12.     MultipleDB 
  13.     MultipleDB with Spring Boot 
  14.  
  15.      
  16.         org.springframework.boot 
  17.         spring-boot-starter-parent 
  18.         1.3.5.RELEASE 
  19.          
  20.      
  21.  
  22.      
  23.         UTF-8 
  24.         1.8 
  25.      
  26.  
  27.      
  28.          
  29.             org.springframework.boot 
  30.             spring-boot-starter-web 
  31.          
  32.  
  33.          
  34.             org.springframework.boot 
  35.             spring-boot-starter-test 
  36.             test 
  37.          
  38.  
  39.          
  40.             org.springframework.boot 
  41.             spring-boot-starter-jdbc 
  42.          
  43.  
  44.          
  45.             org.postgresql 
  46.             postgresql 
  47.          
  48.  
  49.          
  50.             mysql 
  51.             mysql-connector-java 
  52.             5.1.38 
  53.          
  54.      
  55.  
  56.      
  57.          
  58.              
  59.                 org.springframework.boot 
  60.                 spring-boot-maven-plugin 
  61.              
  62.          
  63.       

解释：

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

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文件来提供这些配置信息。

  1. server.port=6060spring.ds_post.url =jdbc:postgresql://localhost:5432/kode12spring.ds_post.username =postgres 
  2. spring.ds_post.password =root 
  3. spring.ds_post.driverClassName=org.postgresql.Driverspring.ds_mysql.url = jdbc:mysql://localhost:3306/kode12spring.ds_mysql.username = root 
  4. spring.ds_mysql.password = root 
  5. 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

  1. package com.aegis;import org.springframework.boot.SpringApplication;import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplicationpublic MultipleDbApplication {    public static void main(String[] args) { 
  2.         SpringApplication.run(MultipleDbApplication.class, args); 
  3.     } 
  4. } 

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

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

其他注解:

  1. @Configuration@EnableAutoConfiguration@ComponentScan 

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

MultipleDBConfig.java

  1. package com.aegis.config;import javax.sql.DataSource;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.boot.autoconfigure.jdbc.DataSourceBuilder;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; 
  2.  
  3. @Configurationpublic class MultipleDBConfig { 
  4.     @Bean(name = "mysqlDb") 
  5.     @ConfigurationProperties(prefix = "spring.ds_mysql") 
  6.     public DataSource mysqlDataSource() {        return DataSourceBuilder.create().build(); 
  7.     } 
  8.  
  9.     @Bean(name = "mysqlJdbcTemplate") 
  10.     public JdbcTemplate jdbcTemplate(@Qualifier("mysqlDb") DataSource dsMySQL) {        return new JdbcTemplate(dsMySQL); 
  11.     } 
  12.  
  13.     @Bean(name = "postgresDb") 
  14.     @ConfigurationProperties(prefix = "spring.ds_post") 
  15.     public DataSource postgresDataSource() {        return  DataSourceBuilder.create().build(); 
  16.     } 
  17.  
  18.     @Bean(name = "postgresJdbcTemplate") 
  19.     public JdbcTemplate postgresJdbcTemplate(@Qualifier("postgresDb")  
  20.                                               DataSource dsPostgres) {        return new JdbcTemplate(dsPostgres); 
  21.     } 
  22. } 

 解释：

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

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

  1. @Bean(name = "mysqlDb")@ConfigurationProperties(prefix = "spring.ds_mysql")public DataSource mysqlDataSource() {return DataSourceBuilder.create().build(); 
  2. }  

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

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

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

  1. @Bean(name = "mysqlJdbcTemplate")public JdbcTemplate jdbcTemplate(@Qualifier("mysqlDb") DataSource dsMySQL) {     return new JdbcTemplate(dsMySQL); 
  2. }  

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

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

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

  1. @Bean(name = "postgresDb")@ConfigurationProperties(prefix = "spring.ds_post")public DataSource postgresDataSource() { return DataSourceBuilder.create().build(); 
  2.  
  3. }  

***行创建DataSource实例postgresDb。

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

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

  1. @Bean(name = "postgresJdbcTemplate")public JdbcTemplate postgresJdbcTemplate(@Qualifier("postgresDb") 
  2.  
  3. DataSource dsPostgres) { return new JdbcTemplate(dsPostgres); 
  4.  
  5. } 

 

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

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

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

DemoController.java

  1. package com.aegis.controller;import java.util.HashMap;import java.util.Map;import org.springframework.beans.factory.annotation.Autowired;import org.springframework.beans.factory.annotation.Qualifier;import org.springframework.jdbc.core.JdbcTemplate;import org.springframework.web.bind.annotation.PathVariable;import org.springframework.web.bind.annotation.RequestMapping;import org.springframework.web.bind.annotation.RestController; 
  2.  
  3. @RestControllerpublic class DemoController { 
  4.  
  5.     @Autowired 
  6.     @Qualifier("postgresJdbcTemplate")    private JdbcTemplate postgresTemplate; 
  7.  
  8.     @Autowired 
  9.     @Qualifier("mysqlJdbcTemplate")    private JdbcTemplate mysqlTemplate; 
  10.  
  11.     @RequestMapping(value = "/getPGUser")    public String getPGUser() {        Map map = new HashMap();        String query = " select * from usermaster";        try {            map = postgresTemplate.queryForMap(query); 
  12.         } catch (Exception e) { 
  13.             e.printStackTrace(); 
  14.         }        return "PostgreSQL Data: " + map.toString(); 
  15.     } 
  16.  
  17.     @RequestMapping(value = "/getMYUser")    public String getMYUser() {        Map map = new HashMap();        String query = " select * from usermaster";        try {            map = mysqlTemplate.queryForMap(query); 
  18.         } catch (Exception e) { 
  19.             e.printStackTrace(); 
  20.         }        return "MySQL Data: " + map.toString(); 
  21.     } 
  22. } 

解释：

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

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

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

  1. @Autowired@Qualifier("postgresJdbcTemplate")private JdbcTemplate postgresTemplate; 

这里我们用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联系他。 

上一篇：重塑企业与客户的连接:销售易发布伙伴云、客服云和现场云三款重磅产品

下一篇：网利宝与北京银行签署资金存管协议

相关内容

热门资讯

PHP新手之PHP入门 PHP是一种易于学习和使用的服务器端脚本语言。只需要很少的编程知识你就能使用PHP建立一个真正交互的...
网络中立的未来 网络中立性是什... 《牛津词典》中对“网络中立”的解释是“电信运营商应秉持的一种原则，即不考虑来源地提供所有内容和应用的...
各种千兆交换机的数据接口类型详... 千兆交换机有很多值得学习的地方，这里我们主要介绍各种千兆交换机的数据接口类型，作为局域网的主要连接设...
粉嫩如何诠释霸道 东芝M805... “霸道粉”是个什么玩意东芝M805拿过来的时候，笔者扑哧笑了，不是笑这款笔记本，而是笑这款产品的颜色...
如何利用交换机和端口设置来管理... 在网络管理中，总是有些人让管理员头疼。下面我们就将介绍一下一个网管员利用交换机以及端口设置等来进行D...
什么是大数据安全 什么是大数据... 在《为什么需要大数据安全分析》一文中，我们已经阐述了一个重要观点，即：安全要素信息呈现出大数据的特征...
只需三步，让你掌握阿尔法路由器... 请参照以下阿尔法路由器设置方法，通过浏览器进入及设置宽带路由器。经过这三个步骤的设置，基本上能够熟悉...
如何更省钱? 近期特价热门硒鼓... 如今激光打印设备已经成为商务或企业的绝对主力办公设备，但采购者往往忽视了激光打印设备所用的耗材，相对...
全面诠释网络负载均衡 负载均衡的出现大大缓解了服务器的压力，更是有效的利用了资源，提高了效率。那么我们现在来说一下网络负载...
如何允许远程连接到MySQL数... [[277004]]【51CTO.com快译】默认情况下，MySQL服务器仅侦听来自localhos...