多資料來源配置

application.properties
配置兩個資料庫

#資料庫配置#
spring.datasource.primary.driverClassName = com.mysql.jdbc.Driver
spring.datasource.primary.url = jdbc:mysql://x.x.x.x:3306/hll
spring.datasource.primary.username = ****
spring.datasource.primary.password = ****

spring.datasource.secondary.driverClassName =
 
 com.mysql.jdbc.Driver
spring.datasource.secondary.url = jdbc:mysql://localhost:3306/mydata
spring.datasource.secondary.username = root
spring.datasource.secondary.password = root

建立主資料來源配置檔案

package com.hll.hlladmin.config;

import java.util.Map;

import javax.persistence.EntityManager;
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.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;

/**
 * @author hll
 */
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
		entityManagerFactoryRef="entityManagerFactoryPrimary", 
		transactionManagerRef="transactionManagerPrimary", 
		basePackages = {"com.hll.hlladmin.dao.primary"} ) //basePackages。Repository所在的位置，主資料來源要和次資料來源所在的包要分開
public class PrimaryConfig {

	@Autowired
	@Qualifier("primaryDataSource")
	private DataSource primaryDataSource;
	
	@Autowired
    private JpaProperties jpaProperties;
	
	@Primary //該註解表示為主資料來源
    @Bean(name = "entityManagerPrimary")
    public EntityManager entityManager(EntityManagerFactoryBuilder builder) {
        return entityManagerFactoryPrimary(builder).getObject().createEntityManager();
    }
	
	@Primary
    @Bean(name = "entityManagerFactoryPrimary")
	public LocalContainerEntityManagerFactoryBean entityManagerFactoryPrimary(EntityManagerFactoryBuilder builder) {
		return builder.dataSource(primaryDataSource)
				.properties(getVendorProperties(primaryDataSource))
				.packages("com.hll.hlladmin.model.primary") //主資料來源實體所在位置
				.persistenceUnit("primaryPersistenceUnit")
				.build();
	}
	
	private Map<String, String> getVendorProperties(DataSource dataSource) {
        return jpaProperties.getHibernateProperties(dataSource);
    }
	
	@Primary
    @Bean(name = "transactionManagerPrimary")
    public PlatformTransactionManager transactionManagerPrimary(EntityManagerFactoryBuilder builder) {
        return new JpaTransactionManager(entityManagerFactoryPrimary(builder).getObject());
    }
}

建立次資料來源配置檔案

package com.hll.hlladmin.config;

import java.util.Map;

import javax.persistence.EntityManager;
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;

/**
 * @author hll
 */
@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(
		entityManagerFactoryRef="entityManagerFactorySecondary",
		transactionManagerRef="transactionManagerSecondary",
		basePackages = {"com.hll.hlladmin.dao.secondary"}) //次資料來源repository所在位置
public class SecondaryConfig {

	@Autowired
	@Qualifier("secondaryDataSource")
	private DataSource secondaryDataSource;
	
	@Bean(name="entityManagerSecondary")
	public EntityManager entityManager(EntityManagerFactoryBuilder builder) {
		return entityManagerFactorySecondary(builder).getObject().createEntityManager();
	}
	
	@Bean(name="entityManagerFactorySecondary")
	public LocalContainerEntityManagerFactoryBean entityManagerFactorySecondary(EntityManagerFactoryBuilder builder) {
		return builder.dataSource(secondaryDataSource)
				.properties(getVendorProperties(secondaryDataSource))
				.packages("com.hll.hlladmin.model.secondary") //次資料來源實體所在位置
				.persistenceUnit("secondaryPersistenceUnit")
				.build();
	}
	
	@Autowired
	private JpaProperties jpaProperties;
	
	private Map<String, String> getVendorProperties(DataSource dataSource) {
		return jpaProperties.getHibernateProperties(dataSource);
	}
	
	@Bean(name="transactionManagerSecondary")
	PlatformTransactionManager transactionManagerSecondary(EntityManagerFactoryBuilder builder) {
		return new JpaTransactionManager(entityManagerFactorySecondary(builder).getObject());
	}
}

######主資料來源和次資料來源下dao類，model類省略了
######注意主次資料來源下的dao類和model類的位置

建立請求Controller

package com.hll.hlladmin.controller;

import java.util.HashMap;
import java.util.LinkedHashMap;
import java.util.Map;

import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Controller;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.ResponseBody;

import com.hll.hlladmin.dao.primary.UserDao;
import com.hll.hlladmin.dao.secondary.ConfigDao;
import com.hll.hlladmin.model.primary.User;
import com.hll.hlladmin.model.secondary.Config;
import com.hll.hlladmin.utils.JsonResult;

/**
 * @author hll 
 */
@Controller
@RequestMapping(value = "/hlladmin/test")
public class TestController {
	
	@Autowired
	private UserDao userDao;
	@Autowired
	private ConfigDao configDao;
	
	@RequestMapping(value = "test")
	@ResponseBody
	public JsonResult test() {
		User user = userDao.findAll().get(0);
		
		Config config = configDao.findAll().get(0);
		
		Map<String, String> map = new LinkedHashMap<String, String>();
		map.put("資料來源1：", user.toString());
		map.put("資料來源2：", config.toString());
		return new JsonResult(200, "查詢成功", map);
	}
	
}

{“code”:200,“msg”:“查詢成功”,“data”:{“資料來源1：”:“User [id=1, name=主資料來源]”,“資料來源2：”:“Config [id=1, name=次資料來源]”}}