使用实体管理器本机查询插入JPA

gal*_*lao 14 jpa entitymanager

我试图在我的数据库中插入数据,我在我的项目中使用JPA.

这就是我的bean的样子.

@PersistenceContext
EntityManager em;

    em.createNativeQuery("INSERT INTO testtable ('column1','column2') VALUES ('test1','test2')").executeUpdate();
Run Code Online (Sandbox Code Playgroud)

myfacade:

@Stateless
public class TestFacade extends AbstractFacade<Test> {
    @PersistenceContext(unitName = "TEST2PU")
    private EntityManager em;

    @Override
    protected EntityManager getEntityManager() {
        return em;
    }

    public TestFacade() {
        super(Test.class);
    }
Run Code Online (Sandbox Code Playgroud)

我收到一个错误:

javax.persistence.TransactionRequiredException: executeUpdate is not supported for a Query object obtained through non-transactional access of a container-managed transactional EntityManager
Run Code Online (Sandbox Code Playgroud)

如果我不使用 @PersistenceContext for EntityManager

EntityManagerFactory emf = Persistence.createEntityManagerFactory("TEST2PU");
EntityManager em = emf.createEntityManager();
em.createNativeQuery("INSERT INTO testtable ('column1','column2') VALUES ('test1','test2')").executeUpdate();
Run Code Online (Sandbox Code Playgroud)

这是我的错误:

javax.persistence.TransactionRequiredException: 
Exception Description: No externally managed transaction is currently active for this thread
Run Code Online (Sandbox Code Playgroud)

注意:确实需要使用本机查询.

Sae*_*fam 13

您可以使用NativeQuery及其executeUpdate方法来执行此操作:

String query = "insert into Employee values(1,?)";

em.createNativeQuery(query)
   .setParameter(1, "Tom")
   .executeUpdate();
Run Code Online (Sandbox Code Playgroud)

  • 如何使用此查询获取最后插入的ID? (4认同)
  • @Kumaresan Perumal“插入表(a,b)值('a','b')返回id;” 尝试将其与 getResultList() 和 postgresql 结合使用。 (2认同)

Bor*_* Y. 8

我有同样的问题.这是解决方案.

EntityManager em = getEntityManager();
EntityTransaction et = em.getTransaction();
et.begin();
em.createNativeQuery("UPDATE ... ;").executeUpdate();
et.commit();
Run Code Online (Sandbox Code Playgroud)


小智 6

您可以用来createNativeQuery编写特定于数据库语言的查询。

String query = "INSERT INTO userinfo ( login, upassword, email, mobile, fax, dob)"
             + " VALUES ( :a, :b, :c, :d, :e, :f)"

em.createNativeQuery(query)
    .setParameter("a", objUser.getLogin())
    .setParameter("b", objUser.getUpassword())
    .setParameter("c", objUser.getEmail())
    .setParameter("d", objUser.getMobile())
    .setParameter("e", objUser.getFax())
    .setParameter("f", objUser.getDob())
    .executeUpdate();

Run Code Online (Sandbox Code Playgroud)

  • 一些解释会显着提高你的答案的质量。 (3认同)

Gab*_*ica 4

假设您使用的是容器管理的entityManager(注入@PersistenceContext),您只是错过了@TransactionnalTestFacade 方法上方的注释。