Micronaut，JPA，EntityManager：如果没有来自application.yml的数据源，则会出现错误没有配置事务管理器

Question

我试图使用JPA事务管理与使用Micronaut Postgresql的批处理插入。

|Micronaut版本：1.1.3 | JVM版本：1.8.0 |

我已经配置了Micronaut项目在build.gradle.中使用micronaut-hibernet-jpa

compile "io.micronaut.configuration:micronaut-hibernate-jpa"

高级方法是这样的，当在应用程序中定义数据源时，它可以正常工作。yml。

我的界面

interface myrepository
{
  savebatch (@NotNull List<ConsumerRecord<String, MyBusinessClass>> buffer
}

我的接口实现

@Slf4j
@Singleton
@EnableTransactionManagement
class myrepositoryimpl implements myrepository
{
  @PersistenceContext
  private EntityManager entityManager

  myrepositoryimpl(@CurrentSession EntityManager entityManager){
   this.entityManager = entityManager
  }

  @Override
  @Transactional    
  public savebatch (...)
  {
      ..some business logic
       entity.persist(...)
    ....
      entity.flush()
      entity.clear()
   }
}

如果我使用应用程序中的数据源，上面的代码运行良好。yml。

我的要求是：我的应用程序需要在运行时创建数据源。所以我删除了dagtasource

用于动态方法。我正在用下面的代码片段初始化构造函数中的EntityManger，但它抛出的运行时错误为“未配置事务管理器”

HibernatePersistenceProvider hibernatePersistenceProvider = new HibernatePersistenceProvider();

Map <String,Object> properties = new HashMap<String,Object>();

properties.put(org.hibernate.cfg.AvailableSettings.JPA_JDBC_DRIVER, 'org.postgresql.Driver')
properties.put(org.hibernate.cfg.AvailableSettings.JPA_JDBC_URL, 'jdbc:postgresql://...')
properties.put(org.hibernate.cfg.AvailableSettings.DIALECT, PostgreSQL10Dialect.class)
properties.put(org.hibernate.cfg.AvailableSettings.JPA_JDBC_USER, '...')
properties.put(org.hibernate.cfg.AvailableSettings.JPA_JDBC_PASSWORD, '...')

properties.put(org.hibernate.cfg.AvailableSettings.SHOW_SQL, false)

EntityManagerFactory entityManagerFactory = hibernatePersistenceProvider
        .createContainerEntityManagerFactory(persistenceUnitInfo, properties);

def entityManager = entityManagerFactory.createEntityManager()

log.info "Setting entity manager factory "
JpaTransactionManager txManager = new JpaTransactionManager();

txManager.setEntityManagerFactory((EntityManagerFactory)entityManagerFactory);
DataSource dataSource = DataSourceBuilder.create()
        .driverClassName('org.postgresql.Driver')
        .url('jdbc:postgresql://...')
        .password('...')
        .username('...')
        .build()

if (dataSource!= null){
    log.info "Valid datasource created"
    txManager.setDataSource(dataSource);
}

context.registerSingleton(entityManager)

return entityManager

}

下面几个链接和谷歌。

https://guides.micronaut.io/micronaut-data-access-jpa-hibernate/guide/index.html

https://micronaut-projects.github.io/micronaut-data/latest/guide/#graalJPA

如何将entitymanager与Micronaut一起使用？

Answer 1

我不确定您为什么要手动创建实体管理器，这是不必要的，因为Micronaut已经包含了为您自动设置实体管理器的功能。看https://micronaut-projects.github.io/micronaut-sql/latest/guide/#hibernate

然而，如果您必须这样做，那么在注册单例时，您必须用“默认”的命名限定符注册它，因为这是Micronaut期望调用的默认数据源，您还必须将数据源本身注册为bean。

context.registerSingleton(dataSource, Qualifiers.byName("default"));
context.registerSingleton(entityManager, Qualifiers.byName("default"));

然而，就像我说的，这不是一个支持或推荐的方法来配置实体管理器工厂