Java Spring中同时访问多种不同数据库
开发企业应用时我们常常遇到要同时访问多种不同数据库的问题,有时是必须把数据归档到某种数据仓库中,有时是要把数据变更推送到第三方数据库中。使用Spring框架时,使用单一数据库是非常容易的,但如果要同时访问多个数据库的话事件就变得复杂多了。
本文以在Spring框架下开发一个SpringMVC程序为例,示范了一种同时访问多种数据库的方法,而且尽量地简化配置改动。
搭建数据库
建议你也同时搭好两个数据库来跟进我们的示例。本文中我们用了PostgreSQL和MySQL。
下面的脚本内容是在两个数据库中建表和插入数据的命令。
PostgreSQL
CREATE TABLE usermaster ( id integer, name character varying, emailid character varying, phoneno character varying(10), location character varying
) INSERT INTO usermaster(id, name, emailid, phoneno, location)
VALUES (1, 'name_postgres', 'email@email.com', '1234567890', 'IN');
MySQL
CREATE TABLE `usermaster` (`id` int(11) NOT NULL, `name` varchar(255) DEFAULT NULL, `emailid` varchar(20) DEFAULT NULL, `phoneno` varchar(20) DEFAULT NULL, `location` varchar(20) DEFAULT NULL, PRIMARY KEY (`id`)
)INSERT INTO `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仓库中下载所需要的内容。
创建完的项目如下图所示:
接下来我们仔细研究一下项目中的各个相关文件内容。
pom.xml
pom中包含了所有需要的依赖和插件映射关系。
代码:
<?xml version="1.0" encoding="UTF-8"?>
<project xmlns="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>MultipleDB with Spring Boot</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=6060
spring.ds_post.url =jdbc:postgresql://localhost:5432/kode12
spring.ds_post.username =postgres
spring.ds_post.password =root
spring.ds_post.driverClassName=org.postgresql.Driver
spring.ds_mysql.url = jdbc:mysql://localhost:3306/kode12
spring.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
package com.aegis;import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;@SpringBootApplication
public MultipleDbApplication {public static void main(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
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;@Configuration
public class MultipleDBConfig {@Bean(name = "mysqlDb")@ConfigurationProperties(prefix = "spring.ds_mysql")public DataSource mysqlDataSource() {return DataSourceBuilder.create().build();}@Bean(name = "mysqlJdbcTemplate")public JdbcTemplate jdbcTemplate(@Qualifier("mysqlDb") DataSource dsMySQL) {return new JdbcTemplate(dsMySQL);}@Bean(name = "postgresDb")@ConfigurationProperties(prefix = "spring.ds_post")public DataSource postgresDataSource() {return DataSourceBuilder.create().build();}@Bean(name = "postgresJdbcTemplate")public JdbcTemplate postgresJdbcTemplate(@Qualifier("postgresDb") DataSource dsPostgres) {return new JdbcTemplate(dsPostgres);}
}
解释:
这是加了注解的配置类,包含加载我们的PostgreSQL和MySQL数据库配置的函数和注解。这也会负责为每一种数据库创建JDBC模板类。
下面我们看一下这四个函数:
@Bean(name = "mysqlDb")
@ConfigurationProperties(prefix = "spring.ds_mysql")
public DataSource mysqlDataSource() {return DataSourceBuilder.create().build();
}
上面代码第一行创建了mysqlDb bean。
第二行帮助@Bean加载了所有有前缀spring.ds_mysql的属性。
第四行创建并初始化了DataSource类,并创建了mysqlDb DataSource对象。
@Bean(name = "mysqlJdbcTemplate")
public JdbcTemplate jdbcTemplate(@Qualifier("mysqlDb") DataSource dsMySQL) {return new JdbcTemplate(dsMySQL);
}
第一行以mysqlJdbcTemplate为名创建了一个JdbcTemplate类型的新Bean。
第二行将第一行中创建的DataSource类型新参数传入函数,并以mysqlDB为qualifier。
第三行用DataSource对象初始化JdbcTemplate实例。
@Bean(name = "postgresDb")
@ConfigurationProperties(prefix = "spring.ds_post")
public DataSource postgresDataSource() {return DataSourceBuilder.create().build();
}
第一行创建DataSource实例postgresDb。
第二行帮助@Bean加载所有以spring.ds_post为前缀的配置。
第四行创建并初始化DataSource实例postgresDb。
@Bean(name = "postgresJdbcTemplate")
public JdbcTemplate postgresJdbcTemplate(@Qualifier("postgresDb")DataSource dsPostgres) {return new JdbcTemplate(dsPostgres);
}
第一行以postgresJdbcTemplate为名创建JdbcTemplate类型的新bean。
第二行接受DataSource类型的参数,并以postgresDb为qualifier。
第三行用DataSource对象初始化JdbcTemplate实例。
DemoController.java
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;@RestController
public class DemoController {@Autowired@Qualifier("postgresJdbcTemplate")private JdbcTemplate postgresTemplate;@Autowired@Qualifier("mysqlJdbcTemplate")private JdbcTemplate mysqlTemplate;@RequestMapping(value = "/getPGUser")public String getPGUser() {Map<String, Object> map = new HashMap<String, Object>();String query = " select * from usermaster";try {map = postgresTemplate.queryForMap(query);} catch (Exception e) {e.printStackTrace();}return "PostgreSQL Data: " + map.toString();}@RequestMapping(value = "/getMYUser")public String getMYUser() {Map<String, Object> map = new HashMap<String, Object>();String query = " select * from usermaster";try {map = mysqlTemplate.queryForMap(query);} catch (Exception e) {e.printStackTrace();}return "MySQL Data: " + map.toString();}
}
解释:
@RestController类注解表明这个类中定义的所有函数都被默认绑定到响应中。
上面代码段创建了一个JdbcTemplate实例。@Qualifier用于生成一个对应类型的模板。代码中提供的是postgresJdbcTemplate作为Qualifier参数,所以它会加载MultipleDBConfig实例的jdbcTemplate(…)函数创建的Bean。
这样Spring就会根据你的要求来调用合适的JDBC模板。在调用URL “/getPGUser”时Spring会用PostgreSQL模板,调用URL “/getMYUser”时Spring会用MySQL模板。
@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联系他。
Java Spring中同时访问多种不同数据库相关推荐
- java php同时访问数据库,Java Spring中同时访问多种不同数据库的代码实例分享
开发企业应用时我们常常遇到要同时访问多种不同数据库的问题,有时是必须把数据归档到某种数据仓库中,有时是要把数据变更推送到第三方数据库中.使用Spring框架时,使用单一数据库是非常容易的,但如果要同时 ...
- java接口如何定义常量 c_在Java接口中怎样访问定义的常量呢?
java接口是一系列方法的声明,是一些方法特征的集合,一个接口只有方法的特征没有方法的实现,因此这些方法可以在不同的地方被不同的类实现,而这些实现可以具有不同的行为(功能).那么我们在Java接口中怎 ...
- Java语言中的-----访问修饰符
day04 Java语言中的----访问修饰符 一.访问修饰符概述: 访问修饰符就是对变量或者是方法或者是类的一个修饰,通过修饰以后实现一些必要的权限,主要是说明类成员如何被使用的作用. 二.访问修饰 ...
- java 接口中 常量_在Java接口中怎样访问定义的常量呢?
java接口是一系列方法的声明,是一些方法特征的集合,一个接口只有方法的特征没有方法的实现,因此这些方法可以在不同的地方被不同的类实现,而这些实现可以具有不同的行为(功能).那么我们在Java接口中怎 ...
- java spring 打包后找不到路径,java - Spring中的类路径问题:找不到文件异常 - 堆栈内存溢出...
我有一个简单的Java Spring IO项目,其中的一个类应该从csv文件读取,对于每个读取的记录,参数都存储在帐户对象列表中. 我正在使用Force IDE Luna,并且读取文件的Class C ...
- spring中怎么访问MySQL过程_【FunnyBear的Java之旅 - Spring篇】7步连接MySQL
准备工作: a) 启动MySQL服务器, 使用MySQL Workbench新建数据库 b) 下载Eclipse EE, 并安装Maven和Spring Framework插件 c) 由于默认的Mav ...
- java web中Jdbc访问数据库步骤通俗解释(吃饭),与MVC的通俗解释(做饭)
一.Jdbc访问数据库步骤通俗解释(吃饭) 1)加载驱动 Class.forName("com.microsoft.jdbc.sqlserver.SQLServer"); 2) 与 ...
- spring中的mongoTemplate连接mongo数据库及其多数据源
提前声明下使用的是JAVA语言Maven打包依赖工具和springboot全家桶套餐 一.在pom.xm中引用依赖 现在这里提上一嘴,使用mongo数据库,必然会使用mongo集群,起码得两个节点,需 ...
- java语言中的访问权限控制符有哪些,18.Java的访问控制符
Java的访问控制符 一.类的成员的可见性 对于类的成员变量和成员方法,我们可以通过设定一定的访问可见性来限定应用范围. (一).private private表示当前类访问权限.如果类里的一个成员( ...
最新文章
- 腾讯AI Lab开源世界首款自动化模型压缩框架PocketFlow:将深度学习装进口袋
- 简单三步,用 Python 发邮件
- 后端接收到信息并返回了但是前端无响应_Bug的噩梦:前端调试必备的7个“大杀器”...
- 为什么恋舞显示连接服务器失败,恋舞模式全攻略与技巧
- C#Convert.ToInt32(char)方法-将char值转换为int
- Vue组件相关的知识
- HTML知识积累及实践(五) - 表单元素
- 新闻丨智链万源受邀参加世界动物福利科学大会
- 到底何为产品架构师?
- 【离散数学】陪集的详解
- Geek 极客大挑战2021 web
- dlna 服务器 性能,dlna 使用体验,供大家参考,欢迎交流
- 数据库管理系统MFC实现
- vscode中 5k多个挂起的更改 怎么解决?
- 浅析错误:software IO TLB: coherent allocation failed for device
- 接入微信分享 以及使用eclipse调试cocos2dx
- 《游戏学习》 java经典纸牌类小游戏《斗地主》源码
- 用ubuntu的使用习惯使用windows (by quqi99)
- 微信公众平台商业模式探索
- 推荐系统-task03-矩阵分解