CDI 根据用户输入注入 @PersistenceContext

Question

我正在尝试弄清楚如何使用 CDI。我正在开发一个用户能够连接到多个数据库的应用程序。应用程序询问他们想要连接到哪个，他们也可以断开连接并连接到不同的数据库。这是一个使用 Seam for CDI 和 Hibernate for JPA 的 Java SE 应用程序。我想弄清楚的是如何利用 CDI 连接@PersistenceContext，同时使其动态化，以便可以访问不同的数据库。我只是不确定我将使用 CDI 执行此操作的模式或技术。想法？

Answer 1

所以我想我通过使用javax.enterprise.inject.Instance 想出了我想要做什么。首先定义一个简单的bean：

@Alternative
public class Foo {
    private int value;

    public void setValue(int value) {
        this.value = value;
    }
    public int getValue() {
        return value;
    }
}

它被定义为@Alternative，因此CDI 不会混淆它和生产者方法（如下所示）。更好的解决方案是将Foo 定义为接口，然后FooImpl 将使用@Typed 进行注释，因此CDI 认为它只是FooImpl bean 类型。不管怎样，接下来是生产者类。

@ApplicationScoped
public class FooProducer {
    private int value;
    public FooProducer() {
        value = -1;
    }
    public int getValue() {
        return value;
    }
    public void setValue(int value) {
        this.value = value;
    }
    @Produces
    public Foo getFoo() {
        Foo p = new Foo();
        p.setValue(getValue());
        return p;
    }
}

getFoo() 方法生成具有不同值的新 Foo 对象。该值可以通过setValue(int) 方法更改。接下来我使用javax.enterprise.inject.Instance 注入Foo。

@Inject
Instance<Foo> fooInstance;

@Inject
FooProducer fooProducer;

....

fooProducer.setValue(10);

Foo foo = fooInstance.get();
System.out.printf("foo = %s, %d\n", foo.getValue());

fooProducer.setValue(10000);

foo = fooInstance.get();
System.out.printf("foo = %s, %d\n", foo.getValue());

这里我使用注入的fooProducer.setValue() 方法来改变生产者将如何产生Foo。当fooInstance.get() 第一次被调用时，Foo 将包含值 10，第二次将包含值 10000。

鉴于这个简单的示例，很容易应用在运行时将EntityManager 实例获取到不同的数据库。生成 EntityManager 的代码还有更多内容，但不会太多。

Answer 2

PersistenceContext 由 EJB 容器处理。由于您不在 EJB 容器中，因此请忘记持久性上下文并考虑使用 CDI 生产者。

@ApplicationScoped
public class EntityManagerFactoryProvider {

  private EntityManagerFactory emf;

  public void voidApplicationEMF() {
    //load the EMF here based on dynamic properties
    this.emf = Persistence.createEntityManagerFactpry(Map of loaded properties);
  }

  @Produces
  public EntityManager em() {
    return emf.createEntityManager();
  }
}

然后在你的代码中的某个地方

@SessionScoped
public class MyEntityController {
  @Inject
  private EntityManager emf;
}

还有交易等问题需要处理

在 JSE 环境中，您必须显式启动和提交/回滚事务。 由于您使用的是 CDI，因此您可以使用拦截器来启动/检查事务状态并根据需要回滚/提交。

@Interceptor
public class MyInterceptor {
  @Inject
  private EntityManager em;

  @AroundInvoke
  public Object intercept(InvocationContext ic) {
    try {
      //initiate transaction
      em.getTransaction().start ....
      return ic.proceed();
    }catch(Exception ex) { //rollback if necessary }
    finally {//commit transaction if necessary }
  }
}