Не могу сделать УДАЛЕНИЕ в Java, JPA

Question

У меня есть следующий код.Проблема в том, что во второй строке я получаю «org.apache.openjpa.persistence.TransactionRequiredException: может выполнять операцию только при активной транзакции»

Первая строка выполнена нормально.В чем моя ошибка?

//em is some EntityManager
String s = (String)em.createQuery("SELECT something FROM something WHERE something = something").getSingleResult();

em.createQuery("DELETE FROM something WHERE something = something").executeUpdate();

Answer 1

Операции чтения обрабатываются иначе, чем операции записи в JPA. Операции записи (будь то создание, обновление или удаление) обычно должны выполняться в контексте транзакции. Граница транзакции разграничивает вызовы, которые вы делаете, с менеджером сеанса или сущности и определяет, когда транзакция будет зафиксирована (например, она может вызвать фиксацию при выходе из вызова метода при использовании транзакций, управляемых контейнером ).

Для JPA все вызовы для сохранения, удаления, обновления и объединения должны выполняться в транзакции. Вызовы запроса должны выполняться в транзакции, если они вызывают executeUpdate. И вызов getResultList() или getUniqueResult() должен быть сделан в контексте транзакции, если режим блокировки не LockMode.NONE.

В зависимости от потребностей вашего приложения вы будете использовать либо управляемые контейнером транзакции (CMT) , либо управляемые компонентом транзакции (BMT) ,

Для CMT, убедитесь, что ваш блок персистентности определяет ваш источник данных как JTA, и затем соответствующим образом аннотируйте ваш класс или метод. Например:

<persistence xmlns="http://java.sun.com/xml/ns/persistence"
             xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
             xsi:schemaLocation="http://java.sun.com/xml/ns/persistence http://java.sun.com/xml/ns/persistence/persistence_2_0.xsd"
             version="2.0">
   <persistence-unit name="sample" transaction-type="JTA">
      <jta-data-source>java:/DefaultDS</jta-data-source>
      <properties>
         <property name="hibernate.dialect" value="org.hibernate.dialect.HSQLDialect"/>
         <property name="hibernate.hbm2ddl.auto" value="create-drop"/>
      </properties>
   </persistence-unit>
</persistence>

А затем аннотируйте свой класс / метод соответствующим типом транзакции:

@ TransactionAttribute(TransactionAttributeType.REQUIRED)
public void doSomething() {
    em.createQuery("DELETE FROM something WHERE something = something").executeUpdate();
}

Если вы используете BMT, вы должны явно управлять транзакциями:

public void doSomething() throws Exception {
    em.getTransaction().begin();

    try {
        em.createQuery("DELETE FROM something WHERE something = something").executeUpdate();
    } catch(Exception e) {
        em.getTransaction().setRollbackOnly();
    } finally {
        em.getTransaction().commit();
    }
}

Answer 2

Вы можете изменять данные в базе данных, только когда транзакция активна. Вы начинаете транзакцию с

em.getTransaction().begin();

и успешно завершите его с помощью

em.getTransaction().commit();

или завершить откат изменений с помощью

em.getTransaction().rollback();