spring boot + hibernate 多資料來源（註解方式）

阿新 • • 發佈：2019-02-02

一）spring boot + hibernate 多資料來源（XML）

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.EnableAutoConfiguration;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.boot.autoconfigure.jdbc.DataSourceAutoConfiguration;
import org.springframework.boot.builder.SpringApplicationBuilder;
import org.springframework.boot.web.support.SpringBootServletInitializer;
import org.springframework.context.annotation.ComponentScan;
import org.springframework.context.annotation.ImportResource;

@SpringBootApplication
@EnableAutoConfiguration(exclude = { DataSourceAutoConfiguration.class })
@ComponentScan(basePackages = "com.opentrans.kit")
@ImportResource({ "classpath:META-INF/spring/applicationContext.xml" })
public class KitApplication extends SpringBootServletInitializer {

    public static void main(String[] args) {
        SpringApplication.run(KitApplication.class, args);
    }

    @Override
    protected SpringApplicationBuilder configure(SpringApplicationBuilder builder) {
        return builder.sources(KitApplication.class);
    }
}

二） properties 配置

## DB properties:
spring.datasource.kit.url=jdbc:postgresql://localhost:5432/kit
spring.datasource.kit.username=jetty
spring.datasource.kit.password=jetty
spring.datasource.kit.driver-class-name=org.postgresql.Driver
spring.datasource.kit.initial-size=10
spring.datasource.kit.min-idle=10
spring.datasource.kit.max-active=100


## DB otmsxtt
spring.datasource.xtt.url=jdbc:postgresql://192.168.3.74:5432/otmsxtt2k
spring.datasource.xtt.username=jetty
spring.datasource.xtt.password=jetty
spring.datasource.xtt.driver-class-name=org.postgresql.Driver
spring.datasource.xtt.initial-size=5
spring.datasource.xtt.min-idle=10
spring.datasource.xtt.max-active=100

## JPA Configuration:
spring.jpa.show-sql=true
## Spring.jpa.generate-ddl=true
spring.jpa.hibernate.ddl-auto=none
spring.jpa.database-platform=org.hibernate.dialect.PostgreSQLDialect

## log4j
logging.config=classpath:log4j2.xml

三）註解式資料來源配置

1. 資料來源配置類 DataSourceConfigration.java ，多資料來源時必須指定一個數據源首選項註解@Primary（prefix對應properties資料庫配置的字首）

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 javax.sql.DataSource;

@Configuration
public class DataSourceConfigration {

    @Primary
    @Bean(name = "dataSourceKit")
    @ConfigurationProperties(prefix = "spring.datasource.kit")
    public DataSource dataSourceKit() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "dataSourceOtms")
    @ConfigurationProperties(prefix = "spring.datasource.otms")
    public DataSource dataSourceOtms() {
        return DataSourceBuilder.create().build();
    }

    @Bean(name = "dataSourceXtt")
    @ConfigurationProperties(prefix = "spring.datasource.xtt")
    public DataSource dataSourceXtt() {
        return DataSourceBuilder.create().build();
    }
}

2. 資料庫A的配置類 KitDefine.java

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Primary;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

import javax.sql.DataSource;
import java.util.Map;

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef = "entityManagerFactoryKit",
        transactionManagerRef = "transactionManagerKit",
        basePackages = {"com.opentrans.kit.jpa.kit.repository" })
public class KitDefine {

    @Autowired
    private JpaProperties jpaProperties;

    @Autowired
    @Qualifier("dataSourceKit")
    private DataSource dataSourceKit;

    @Primary
    @Bean(name = "entityManagerFactoryKit")
    public LocalContainerEntityManagerFactoryBean entityManagerFactoryKit(EntityManagerFactoryBuilder builder) {
        LocalContainerEntityManagerFactoryBean em = builder.dataSource(dataSourceKit)
                .properties(getVendorProperties(dataSourceKit))
                .packages("com.opentrans.kit.jpa.kit.entity")
                .persistenceUnit("kitPersistenceUnit").build();
        return em;
    }

    @Primary
    @Bean(name = "transactionManagerKit")
    PlatformTransactionManager transactionManagerKit(EntityManagerFactoryBuilder builder) {
        return new JpaTransactionManager(entityManagerFactoryKit(builder).getObject());
    }

    private Map<String, String> getVendorProperties(DataSource dataSource) {
        return jpaProperties.getHibernateProperties(dataSource);
    }
}

3. 資料庫B配置類 OtmsXttDefine.java

import java.util.Map;
import javax.sql.DataSource;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.boot.autoconfigure.orm.jpa.JpaProperties;
import org.springframework.boot.orm.jpa.EntityManagerFactoryBuilder;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.data.jpa.repository.config.EnableJpaRepositories;
import org.springframework.orm.jpa.JpaTransactionManager;
import org.springframework.orm.jpa.LocalContainerEntityManagerFactoryBean;
import org.springframework.transaction.PlatformTransactionManager;
import org.springframework.transaction.annotation.EnableTransactionManagement;

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
        entityManagerFactoryRef = "entityManagerFactoryXtt",
        transactionManagerRef = "transactionManagerXtt",
        basePackages = {"com.opentrans.kit.jpa.xtt.repository" })
public class OtmsXttDefine {

    @Autowired
    private JpaProperties jpaProperties;

    @Autowired
    @Qualifier("dataSourceXtt")
    private DataSource dataSourceXtt;

    @Bean(name = "entityManagerFactoryXtt")
    public LocalContainerEntityManagerFactoryBean entityManagerFactoryXtt(EntityManagerFactoryBuilder builder) {
        LocalContainerEntityManagerFactoryBean em = builder.dataSource(dataSourceXtt)
                .properties(getVendorProperties(dataSourceXtt))
                .packages("com.opentrans.kit.jpa.xtt.entity")
                .persistenceUnit("XttPersistenceUnit").build();
        return em;
    }

    @Bean(name = "transactionManagerXtt")
    PlatformTransactionManager transactionManagerXtt(EntityManagerFactoryBuilder builder) {
        return new JpaTransactionManager(entityManagerFactoryXtt(builder).getObject());
    }

    private Map<String, String> getVendorProperties(DataSource dataSource) {
        return jpaProperties.getHibernateProperties(dataSource);
    }
}

四）pom.xml - maven

<?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.otms.field</groupId>
    <artifactId>toolkit</artifactId>
    <version>1.0-SNAPSHOT</version>
    <name>toolkit</name>
    <description>Team field engineering toolkit</description>
    <parent>
        <groupId>org.springframework.boot</groupId>
        <artifactId>spring-boot-starter-parent</artifactId>
        <version>1.5.1.RELEASE</version>
        <relativePath/>
    </parent>

    <properties>
        <postgres.version>8.4-702.jdbc4</postgres.version>
        <fastjson.version>1.2.16</fastjson.version>
    </properties>

    <dependencies>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-actuator</artifactId>
            <exclusions>
                <exclusion>
                    <groupId>org.springframework.boot</groupId>
                    <artifactId>spring-boot-starter-logging</artifactId>
                </exclusion>
            </exclusions>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-web</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-websocket</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-log4j2</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-amqp</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-thymeleaf</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-security</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-data-jpa</artifactId>
        </dependency>
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-test</artifactId>
        </dependency>
   <!--     <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
        </dependency>-->
        <dependency>
            <groupId>org.springframework.boot</groupId>
            <artifactId>spring-boot-starter-websocket</artifactId>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpclient</artifactId>
            <version>4.5.3</version>
        </dependency>
        <dependency>
            <groupId>org.apache.httpcomponents</groupId>
            <artifactId>httpcore</artifactId>
            <version>4.4.6</version>
        </dependency>
        <dependency>
            <groupId>com.google.code.gson</groupId>
            <artifactId>gson</artifactId>
            <version>2.8.0</version>
        </dependency>
        <dependency>
            <groupId>joda-time</groupId>
            <artifactId>joda-time</artifactId>
        </dependency>
        <dependency>
            <groupId>postgresql</groupId>
            <artifactId>postgresql</artifactId>
            <version>${postgres.version}</version>
        </dependency>
        <dependency>
            <groupId>com.alibaba</groupId>
            <artifactId>fastjson</artifactId>
            <version>${fastjson.version}</version>
        </dependency>
    </dependencies>

    <build>
        <finalName>${project.artifactId}</finalName>
        <plugins>
            <plugin>
                <groupId>org.springframework.boot</groupId>
                <artifactId>spring-boot-maven-plugin</artifactId>
                <configuration>
                    <fork>true</fork>
                </configuration>
            </plugin>
        </plugins>
    </build>
</project>

spring boot + hibernate 多資料來源（註解方式）

一）spring boot + hibernate 多資料來源（XML） import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.En

【十七】Spring Boot 之多資料來源（擴充套件AbstractRoutingDataSource類，實現動態資料來源。使用AOP註解動態切換資料來源）

在一個專案中操作多個不同的資料來源時，需要用到多資料來源的配置。 pom.xml <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0

Spring框架的AOP技術（註解方式）

1. 步驟一：建立JavaWEB專案，引入具體的開發的jar包 * 先引入Spring框架開發的基本開發包 * 再引入Spring框架的AOP的開發包 * spring的傳統AOP的開發的包 * spring-aop-4.2.4.RELEASE.jar

10 Spring框架的AOP技術（註解方式）

引入Spring框架開發的基本開發包,spring的傳統AOP的開發的包與aspectJ的開發包建立spring配置檔案 applicationContext.xml <beans xmlns="http://www.springfra

Spring boot+Mybatis 使用DruidDataSource 以註解方式動態整合mysql，sqlserver多資料來源

配置檔案#多源資料庫配置 datasource: mysql: type: com.alibaba.druid.pool.DruidDataSource driverClassName: com.mysql.jdbc.Driver ur

Spring Boot MyBatis配置Druid多資料來源（附原始碼）

Spring Boot MyBatis配置Druid多資料來源回顧在Spring中配置MyBatis SqlSessionFactory的配置：  <bean id="sqlSessionF

Spring boot（七）：Spring boot+ mybatis 多資料來源最簡解決方案

多資料來源一般解決哪些問題？主從模式或者業務比較複雜需要連線不同的分庫來支援業務。直接上程式碼。配置檔案 pom包依賴，該依賴的依賴。主要是資料庫這邊的配置： mybatis.config-locations=classpath:mybatis/mybati

Spring Boot筆記之多資料來源（Mysql+MyBatis）

Mysql+MyBatis多資料來源配置 SpringBoot單資料來源配置 pom.xml application.yml SpringBoot多資料來源配置修改application.yml Confi

spring的bean管理（註解方式）

elasticsearch1.Spring的Bean管理的中常用的註解@Component:組件.(作用在類上)public interface UserDao { public void sayHello(); } @Component(value="userDao")

spring boot 配置多資料來源

1.application.yml配置 server: port: 8088 spring: http: multipart: max-file-size: 50Mb max-request-size: 50Mb enabl

Spring Boot +Mybatis 多資料來源的配置和使用

1、在application.properties中新增資料庫連線配置 mybatis.type-aliases-package=com.yc.edusys.bean mybatis.mapper-locations=cla

Spring Boot Jpa多資料來源配置

前言隨著業務量發展，我們通常會進行資料庫拆分或是引入其他資料庫，從而我們需要配置多個數據源，如：user一個庫，business一個庫。那麼接下來我們就要考慮怎麼去在spring boot中實現多個數據源的配置。 ××× 實現建表首先是建表語句，我們要建立兩個資料庫，並各庫內新建一張表user表mysql

Spring --13.Spring中AOP程式設計（註解方式）

1、基於註解AOP入門案例 1.2、建立工程引入依賴 pom.xml <dependencies> <dependency> <groupId>org.springframework</groupId&

Spring Boot使用多資料來源配置JdbcTemplate.md

多資料來源配置建立一個Spring配置類，定義兩個DataSource用來讀取application.properties中的不同配置。如下例子中，主資料來源配置為spring.datasource.primary開頭的配置，第二資

Spring Boot 初級入門教程（十八） —— 整合 MyBatis 另外一種開發方式

在前面兩篇文章《Spring Boot 初級入門教程（十五） —— 整合 MyBatis》和《Spring Boot 初級入門教程（十七） —— 通過 Oracle 資料庫測試已整合 MyBatis（附原始碼）》中，介紹瞭如何在 SpringBoot 中整合 MyBatis 以及通過 MySQL

spring-boot-mybatis-多資料來源

sql 語句 DROP TABLE IF EXISTS `users`; CREATE TABLE `users` ( `id` bigint(20) NOT NULL AUTO_INCREMENT COMMENT '主鍵id', `userName` varchar(32) DEFAULT NUL

Spring Boot + Mybatis 多資料來源配置實現讀寫分離

本文來自網易雲社群作者：王超應用場景：專案中有一些報表統計與查詢功能，對資料實時性要求不高，因此考慮對報表的統計與查詢去操作slave db，減少對master的壓力。根據網上多份資料測試發現總是使用master資料來源，無法切換到slave，經過多次除錯修改現已完美通過，現

Spring Boot配置多資料來源並實現Druid自動切換

SpringBoot多資料來源切換,先上配置檔案: 1.pom: <?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0"

spring事務的傳播屬性和事務隔離級別及配置事務（註解方式）

一、Propagation （事務的傳播屬性） Propagation ：　　key屬性確定代理應該給哪個方法增加事務行為。這樣的屬性最重要的部份是傳播行為。有以下選項可供使用： PROPAGATION_REQUIRED--支援當前事務，如果當前沒有事務，就新建一個事務。這是最常見的選擇。 PROPAG

Spring Boot+Mybatis多資料來源讀寫分離

兩天搭建了一個SpringBoot,Mybatis多資料來源讀寫分離，redis實現session共享的例子。記錄一下～～～前提條件：Spring Boot,Mybatis 單資料庫能正常執行一、Spring Boot整合Mybatis實現讀寫分離（後續會做Mysql

spring boot + hibernate 多資料來源（註解方式）

相關推薦