コミュニティ 学ぶ ツールライブラリ レジャー
検索
日本語
ホームページ > Java > ＆＃＆チュートリアル > 本文

Java Spring で複数の異なるデータベースに同時にアクセスするためのコード例を共有する

黄舟
リリース： 2017-03-21 11:03:34
オリジナル
1595 人が閲覧しました

エンタープライズ アプリケーションを開発する場合、複数の異なるデータベースに同時にアクセスするという問題に遭遇することがよくあります。場合によっては、データをある種のデータ ウェアハウスにアーカイブする必要があり、場合によってはデータの変更をサードパーティのデータベースにプッシュする必要があります。 Spring フレームワーク を使用する場合、単一のデータベースを使用するのは非常に簡単ですが、複数のデータベースに同時にアクセスしたい場合、イベントはさらに複雑になります。

この記事では、Spring フレームワークでの SpringMVC プログラムの開発を例として、複数のデータベースに同時にアクセスし、構成変更を可能な限り簡素化する方法を示します。

データベースを構築する

この例に従って、2 つのデータベースを同時にセットアップすることをお勧めします。この記事では、PostgreSQL と MySQL を使用しました。

次のスクリプトの内容は、テーブルを作成し、2 つのデータベースにデータを挿入するコマンドです。

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) を使用します:

  • [ファイル] -> [新規] -> [Spring スターター プロジェクト] をクリックします。

  • ダイアログ ボックスにプロジェクト名、Maven 座標、説明、パッケージ情報を入力し、[次へ] をクリックします。

  • ブート依存関係で「Web」を選択し、「次へ」をクリックします。

  • 「完了」をクリックします。 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 はブートのデフォルトの標準ポートです)。

その他の 属性:

  • 「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" は、他のすべての 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 テンプレート クラスの作成も担当します。

これら 4 つの関数を見てみましょう: 

@Bean(name = "mysqlDb")
@ConfigurationProperties(prefix = "spring.ds_mysql")
public DataSource mysqlDataSource() {
return DataSourceBuilder.create().build();
}
ログイン後にコピー

上記のコードの最初の行は、mysqlDb Bean を作成します。
2 行目は、@Bean がプレフィックス spring.ds_mysql を持つすべてのプロパティをロードするのに役立ちます。
4 行目は DataSource クラスを作成して初期化し、mysqlDb DataSource オブジェクトを作成します。 

@Bean(name = "mysqlJdbcTemplate")
public JdbcTemplate jdbcTemplate(@Qualifier("mysqlDb") DataSource dsMySQL) {
     return new JdbcTemplate(dsMySQL);
}
ログイン後にコピー

最初の行は、mysqlJdbcTemplate という名前の JdbcTemplate タイプの新しい Bean を作成します。
2 行目は、1 行目で作成した DataSource タイプの新しいパラメーターを関数に渡し、修飾子として mysqlDB を使用します。
3 行目は、DataSource オブジェクトを使用して JdbcTemplate インスタンスを初期化します。 

@Bean(name = "postgresDb")
@ConfigurationProperties(prefix = "spring.ds_post")
public DataSource postgresDataSource() {
   return  DataSourceBuilder.create().build();
}
ログイン後にコピー

最初の行では、DataSource インスタンス pos​​tgresDb を作成します。
2 行目は、@Bean が spring.ds_post というプレフィックスが付いたすべての設定をロードするのに役立ちます。
4 行目は、DataSource インスタンス pos​​tgresDb を作成して初期化します。 

@Bean(name = "postgresJdbcTemplate")
public JdbcTemplate postgresJdbcTemplate(@Qualifier("postgresDb")
DataSource dsPostgres) {
  return new JdbcTemplate(dsPostgres);
}
ログイン後にコピー

最初の行は、postgresJdbcTemplate という名前でタイプ JdbcTemplate の新しい Bean を作成します。
2 行目は DataSource タイプのパラメータを受け入れ、修飾子として postgresDb を使用します。
3 行目は、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数据库并以字符串形式返回数据。

以上がJava Spring で複数の異なるデータベースに同時にアクセスするためのコード例を共有するの詳細内容です。詳細については、PHP 中国語 Web サイトの他の関連記事を参照してください。

関連ラベル：
Java ，Spring，数据库
ソース：php.cn
前の記事：Java の自己インクリメントおよび自己デクリメント操作プロセスの詳細な紹介 次の記事：Java の try-with-resource サンプル コードの詳細な紹介
このウェブサイトの声明
この記事の内容はネチズンが自主的に寄稿したものであり、著作権は原著者に帰属します。このサイトは、それに相当する法的責任を負いません。盗作または侵害の疑いのあるコンテンツを見つけた場合は、admin@php.cn までご連絡ください。
著者別の最新記事
最新の問題
単語と一致する正規表現 新しいジョブ名をデータベース内の既存のジョブ名と照合しようとするスクリプトがあります。 SELECTa.titleASJobTitle,j.DescriptionASMatched...
から 2024-04-06 21:24:04
0
1
606
MySQL SQLクエリを使用して別のテーブルのフィールドの合計を計算する 次のようなスキーマがあります。 属性「user_id」と「username」を持つユーザーテーブルと、属性「customer_id」（user_idのFK）と「finalPrice...
から 2024-04-06 19:39:29
0
1
441
Laravel 8 - /{editable_text} ルートを /{user} ルートにリダイレクトする方法 ユーザープロファイルに誘導するリダイレクトルートを作成しようとしています。リダイレクト ルートはユーザー データベースからの文字列/テキストである必要があり、同じユーザー プロファ...
から 2024-04-06 17:26:11
0
1
410
エンティティ ウェアハウスは JpaRepository<Entity, Id> および JpaSpecificExecutor<Entity> を拡張し、EntitySpec は Specific<Entity> を拡張します。 これは私のエンドポイントです http://localhost:8080/country/all 返信はすべての国に対して問題ありません。フィルターしたい場合は、空の国が見つからず...
から 2024-04-06 17:11:03
0
1
421
部分的な値の条件でクエリを記録する - SQL スキルの共有 zipcode というテーブルがあり、code という列があります。コード列には、郵便番号のプレフィックスが含まれています (例: 395453302120312)。指定された郵便...
から 2024-04-06 16:01:26
0
1
395
関連トピック
詳細>
人気のおすすめ
人気のチュートリアル
詳細>
関連するチュートリアル
人気のおすすめ
最新のコース
最新のダウンロード
詳細>
ウェブエフェクト
公式サイト
サイト素材
フロントエンドテンプレート