问题描述
我已经用两个 MysqL 数据库配置了一个 Micronaut 应用程序,但它总是使用默认数据源执行操作。
如何使用多个数据库?
这是我的 application.yml 配置:
datasources:
default:
url: jdbc:MysqL://localhost:3306/micronaut_demo
username: root
password: goti@181994
dialect: MysqL
target:
url: jdbc:MysqL://localhost:3306/micronaut_demo_target
username: root
password: goti@181994
dialect: MysqL
jpa:
default:
packages-to-scan:
- 'com.example'
properties:
hibernate:
hbm2ddl:
auto: create-drop
show_sql: true
target:
properties:
hibernate:
hbm2ddl:
auto: create-drop
show_sql: true
这是我的 Repository
声明:
@Singleton
@Repository("target")
public class DepartmentRepositoryImpl implements DepartmentRepository {
private EntityManager entityManager;
public DepartmentRepositoryImpl(EntityManager entityManager) {
this.entityManager = entityManager;
}
@Override
@ReadOnly
public Optional<Department> findById(Long id) {
return Optional.ofNullable(entityManager.find(Department.class,id));
}
@Override
@Transactional
public Department save(String name) {
//save logic
}
}
如您所见,我指定了要使用的数据源:
@Repository("target")
解决方法
您可以使用 @Repository
注释来注释您的 @EachBean
bean,指定 EntityManager
作为依赖类型允许 Microanut 为每个创建的 {{1 }}(以及引擎盖下的每个 EntityManager
):
DataSource
然后您可以根据所需的目标 @EachBean(EntityManager.class)
@Repository
public class DepartmentRepositoryImpl implements DepartmentRepository {
private EntityManager entityManager;
public DepartmentRepositoryImpl(EntityManager entityManager) {
this.entityManager = entityManager;
}
@Override
@ReadOnly
public Optional<Department> findById(Long id) {
return Optional.ofNullable(entityManager.find(Department.class,id));
}
@Override
@Transactional
public Department save(String name) {
//save logic
}
}
注入合格的 DepartmentRepository
:
DataSource
或者动态使用注入的 @Singleton
public class ServiceImpl implements Service {
private DepartmentRepository departmentRepository;
public ServiceImpl(@Named("target") DepartmentRepository departmentRepository) {
this.departmentRepository = departmentRepository;
}
@Override
public Department save(String name) {
return this.departmentRepository.save(name);
}
}
:
ApplicationContext