Java Spring에서 동시에 여러 데이터베이스에 액세스하기 위한 코드 예제 공유
- 黄舟원래의
- 2017-03-21 11:03:341599검색
엔터프라이즈 애플리케이션을 개발할 때 여러 다른 데이터베이스에 동시에 액세스하는 문제에 자주 직면합니다. 때로는 데이터를 일종의 데이터 웨어하우스에 보관해야 하고 때로는 데이터 변경 사항을 타사 데이터베이스에 푸시해야 합니다. 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)를 사용합니다. ) 이 예제를 빌드하려면:
파일 -> New ->
대화상자에 프로젝트 이름, Maven 좌표, 설명, 패키지 정보를 입력하고 Next를 클릭합니다.
부팅 종속성에서 웹을 선택하고 다음을 클릭합니다.
마침을 클릭하세요. 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: 웹 개발 및 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);
}
}이 파일에는 부팅 프로그램을 시작하는 기본 함수가 포함되어 있습니다. "@SpringBootApplication" 주석은 @Configuration
@EnableAutoConfiguration
@ComponentScan
@Target(value={TYPE})
@Retention(value=RUNTIME)
@Documented
@Inherited기타 주석:
@Configuration @EnableAutoConfiguration @ComponentScan
를 포함하여 다른 모든 Spring 주석과
Java 주석의 조합입니다. 컨테이너는 이 클래스를 전달합니다. 구성을 로드합니다.
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를 한정자로 사용합니다.
세 번째 줄은 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를 한정자로 사용합니다.
세 번째 줄은 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: http://localhost:6060/getPGUser
上面的URL会查询PostgreSQL数据库并以字符串形式返回数据。
위 내용은 Java Spring에서 동시에 여러 데이터베이스에 액세스하기 위한 코드 예제 공유의 상세 내용입니다. 자세한 내용은 PHP 중국어 웹사이트의 기타 관련 기사를 참조하세요!