我的 springboot 应用程序尝试从两个数据源(emwbis 和 backupemwbis)读取数据。我按照以下链接配置我的 springboot 应用程序以从两个不同的数据源读取数据。
http://www.baeldung.com/spring-data-jpa-multiple-databases
我的应用程序当前的问题是它总是从主数据源(emwbis)读取数据。我写了下面的代码。
主数据源和备份数据源的模型类:
package com.jl.models.primary;
@Entity
@Table(name = "crsbis",schema="emwbis")
@Data
public class CrsBIS {
@Id
private String id;
@NotNull
private String email;
package com.jl.models.backup;
import lombok.Data;
@Entity
@Table(name = "crsbis",schema="backupemwbis")
@Data
public class CrsBIS {
@Id
private String id;
@NotNull
private String email;
主数据源和备份数据源的数据源配置类:
@Configuration
@PropertySource("classpath:persistence-multiple-db.properties")
@EnableJpaRepositories(basePackages = "com.jl.dao.backup", entityManagerFactoryRef = "crsBISBackUpEntityManager", transactionManagerRef = "crsBISBackupTransactionManager")
public class BackupCrsBISDatabaseConfig {
@Configuration
@PropertySource("classpath:persistence-multiple-db.properties")
@EnableJpaRepositories(basePackages = "com.jl.dao.primary", entityManagerFactoryRef = "crsBISEntityManager", transactionManagerRef = "crsBISTransactionManager")
public class CrsBISDatabaseConfig {
主数据源和备份数据源的存储库接口:
@Transactional
public interface CrsBISRepository extends JpaRepository<CrsBIS, String> {
public CrsBIS findById(String id);
}
@Transactional
public interface CrBisBackupRepository extends JpaRepository<CrsBIS, String>{
public CrsBIS findById(String id);
}
持久数据库属性文件:
jdbc.driverClassName=com.mysql.jdbc.Driver
crsbis.jdbc.url=jdbc:mysql://localhost:3306/emwbis
backupcrsbis.jdbc.url=jdbc:mysql://localhost:3306/backupemwbis
jdbc.user=root
jdbc.pass=Password1
用于测试两个数据源的控制器类:
@Controller
public class CrsBISController {
@Autowired
private CrsBISRepository crsBISRepository;
@Autowired
private CrBisBackupRepository crsBackupRepository;
@RequestMapping("/get-by-id")
@ResponseBody
public String getById(String id){
String email="";
try{
CrsBIS crsBIS = crsBISRepository.findById(id);
email = String.valueOf(crsBIS.getEmail());
}catch (Exception e) {
e.printStackTrace();
return "id not found!";
}
return "The email is : "+email;
}
@RequestMapping("/get-by-id-backup")
@ResponseBody
public String getByIdFromBackup(String id){
String email="";
try{
com.jl.models.backup.CrsBIS crsBIS = crsBackupRepository.findById(id);
email = String.valueOf(crsBIS.getEmail());
}catch (Exception e) {
// TODO: handle exception
e.printStackTrace();
return "id not found!";
}
return "The email is : "+email;
}
虽然,我已经在模型类和数据库配置文件中分离了数据库模式,但控制器类中的两种方法都命中了同一个数据库(emwbis)。我希望getByIdFromBackup
控制器类中的方法从辅助数据库(backupemwbis)中读取数据。
有人可以让我知道我的代码中的错误吗?或者你可以建议/指导我实现我的目标?
从第一个配置文件中,您将创建一个名为 myDatasource 的主数据源 bean 定义,并在第二个 emf 中注入相同的数据源引用。导致问题的 Bean 是这个
只需更改第二个 Bean 数据源名称并在第二个 EMF 中使用它。
希望这能解决它。