【发布时间】：2019-05-06 22:25:08
【问题描述】：
更新
当我尝试连接到 2 个相同的数据库（具有相同的表）然后选择其中一个来发出请求时，我遇到了 Spring 框架的问题。我为此使用了 3 个配置文件 DbConfig、AbstractRoutingDataSource 和一个 application.properties 文件。 我目前在启动我的应用程序时没有收到任何错误，但是每当我使用我的 restful 网络服务时，我都会得到空数据，请检查下面的控制器文件。
注意：我已经关注了所有这些链接，但仍然没有结果：
- Baeldung AbstractRoutingDataSource guide
- Alexander guide
- Dynamic DataSource Routing on Spring website
我正在开发 Spring Boot v2.0.5。
注意：如果您对 AbstractRoutingDataSource 类及其工作原理没有任何想法，请不要回答我。
我的 application.properties 文件
spring.jpa.database=mysql
spring.jpa.open-in-view=false
# Main database DEV_database1
first.datasource.url = jdbc:mysql://localhost:3306/DEV_database1
first.datasource.username = root
first.datasource.password =
first.datasource.driver-class-name = com.mysql.jdbc.Driver
# second database DEV_database2
second.datasource.url = jdbc:mysql://localhost:3306/DEV_database2
second.datasource.username = root
second.datasource.password =
second.datasource.driver-class-name = com.mysql.jdbc.Driver
spring.jpa.database-platform = org.hibernate.dialect.H2Dialect
spring.jpa.show-sql = true
spring.jpa.hibernate.naming.implicit-strategy=org.hibernate.boot.model.naming.ImplicitNamingStrategyLegacyJpaImpl
spring.jpa.hibernate.naming.physical-strategy=org.hibernate.boot.model.naming.PhysicalNamingStrategyStandardImpl
#...
[更新]我的 DbConfig 文件
@Configuration
public class DbConfig {
@Bean
@Primary
@ConfigurationProperties("first.datasource")
public DataSourceProperties firstDataSourceProperties() {
return new DataSourceProperties();
}
@Bean
@Primary
public HikariDataSource firstDataSource() {
return firstDataSourceProperties().initializeDataSourceBuilder().type(HikariDataSource.class).build();
}
@Bean
@ConfigurationProperties("second.datasource")
public DataSourceProperties secondDataSourceProperties() {
return new DataSourceProperties();
}
@Bean
public HikariDataSource secondDataSource() {
return secondDataSourceProperties().initializeDataSourceBuilder().type(HikariDataSource.class).build();
}
@Bean
DataSource dataSources() {
AbstractRoutingDataSource dataSource = new CustomerRoutingDataSource();
Map<Object, Object> resolvedDataSources = new HashMap<>();
resolvedDataSources.put(DbType.DATASOURCE1, firstDataSource());
resolvedDataSources.put(DbType.DATASOURCE2, secondDataSource());
dataSource.setDefaultTargetDataSource(firstDataSource()); // << default
dataSource.setTargetDataSources(resolvedDataSources);
return dataSource;
}
}
我的 CustomerRoutingDataSource.java
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.jdbc.datasource.lookup.AbstractRoutingDataSource;
/**
* AbstractRoutingDatasource can be used in place of standard DataSource implementations and enables a mechanism to
* determine which concrete DataSource to use for each operation at runtime.
*
* @author fre
*/
public class CustomerRoutingDataSource extends AbstractRoutingDataSource {
private static final Logger log = LoggerFactory.getLogger(CustomerRoutingDataSource.class);
@Override
protected Object determineCurrentLookupKey() {
log.info(">>> determineCurrentLookupKey thread: {}", Thread.currentThread().getName() );
log.info(">>> RoutingDataSource: {}", DbContextHolder.getDbType());
return DbContextHolder.getDbType();
}
}
我的 DbContextHolder.java
public class DbContextHolder {
private static final ThreadLocal<DbType> contextHolder =
new ThreadLocal<DbType>();
// set the datasource
public static void setDbType(DbType dbType) {
if(dbType == null){
throw new NullPointerException();
}
contextHolder.set(dbType);
}
// get the current datasource in use
public static DbType getDbType() {
return (DbType) contextHolder.get();
}
// clear datasource
public static void clearDbType() {
contextHolder.remove();
}
}
DbType.java
public enum DbType {
DATASOURCE1,
DATASOURCE2,
}
这就是我在 Controller 中使用它的方式：
我的控制器
@RestController
@RequestMapping("/api/user")
public class MembreController extends MainController {
@Autowired
MembreRepository membreRepository;
@GetMapping("/login")
public ResponseString login(String userName, String password) {
// setting the datasouce to DATASOURCE1
DbContextHolder.setDbType(DbType.DATASOURCE1);
// finding the list of user in DataSource1
List<Membres> list = membreRepository.findAll();
// clearing the current datasource
DbContextHolder.clearDbType();
for (Iterator<Membres> membreIter = list.iterator(); membreIter.hasNext();) {
Membres membre = membreIter.next();
if (membre.getUserName().equals(userName) && membre.getPassword().equals(password)) {
return new ResponseString("Welcome" + membre.getFirstName() + " " + membre.getLastName());
}
}
return new ResponseString("User not found");
}
}
我的 Application.java 文件
@ComponentScan
@SpringBootApplication
public class Application extends SpringBootServletInitializer {
/**
* main method
*
* @param args
*/
public static void main(String[] args) {
SpringApplication.run(Application.class, args);
}
@Override
protected SpringApplicationBuilder configure(SpringApplicationBuilder application) {
return application.sources(Application.class);
}
}
【问题讨论】：
-
什么不起作用？你得到什么错误？此外，您正在使用 Spring Boot，那么您将如何加载该 XML 配置文件。看起来你正在混合你不应该混合的东西（或者至少以错误的方式混合它们）。
-
我实际上没有收到任何错误，您建议我将xml文件中的配置更改为java文件吗？
-
不，我想知道您为什么使用 XML 和 Spring Boot。我还怀疑这是通过（重新）定义事物而不是使用 Spring Boot 来解决问题的一部分。此外，我建议将
spring.jpa.open-in-view=false添加到您的属性中，如果您没有在您有时间为AbstractRoutingDataSource设置正确值之前很早就打开Entitymanager和Connection。还从您的 xml 中删除application.properties的加载，因为这应该由 Spring Boot 处理。此外，您的spring.jpa属性也没有用，因为您正在自己配置 JPA。 -
好的 appContext.xml 文件呢？我必须删除它吗？
-
我照你说的做了，没有任何改变:(
标签： spring-boot jpa datasource multiple-databases spring-config