Spring Boot Spring Data JPA事务无法正常工作

3 回答

• 2

  将Transactional批注更改为@Transactional（rollbackFor = Exception.class）

  回复于 2024-04-26T08:15:54+08:00
• 3

  来自comment @ m-deinum：

  使您的PersonService公开以及您正在调用的方法 .

  这似乎已成为几个用户的诀窍 . 同样的事情也包含在this answer中，引用manual saying：

  使用代理时，应仅将@Transactional注释应用于具有公共可见性的方法 . 如果使用@Transactional批注对protected，private或package-visible方法进行批注，则不会引发错误，但带注释的方法不会显示已配置的事务设置 . 如果需要注释非公共方法，请考虑使用AspectJ（见下文） .

  回复于 2024-04-26T08:15:54+08:00
• 0

  我使用SpringBoot v1.2.0和v1.5.2进行了测试，并且所有工作都按预期工作，您不需要使用实体管理器也不需要@Transactional（rollbackFor = Exception.class） .

  我无法看到你配置错误的部分，乍一看似乎都很好，所以我只是将所有配置作为参考发布，带有更新的注释和H2嵌入式内存DB：

  application.properties

  # Embedded memory database
  spring.jpa.hibernate.ddl-auto=create
  spring.datasource.url=jdbc:h2:~/test;AUTO_SERVER=TRUE
  

  pom.xml

  <project xmlns="http://maven.apache.org/POM/4.0.0"
           xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
           xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
      <modelVersion>4.0.0</modelVersion>
  
      <groupId>com.demo</groupId>
      <artifactId>jpaDemo</artifactId>
      <version>1.0-SNAPSHOT</version>
  
      <properties>
          <maven.compiler.source>1.8</maven.compiler.source>
          <maven.compiler.target>1.8</maven.compiler.target>
      </properties>
  
      <parent>
          <groupId>org.springframework.boot</groupId>
          <artifactId>spring-boot-starter-parent</artifactId>
          <version>1.5.2.RELEASE</version>
      </parent>
  
      <dependencies>
          <dependency>
              <groupId>org.springframework.boot</groupId>
              <artifactId>spring-boot-starter-data-jpa</artifactId>
          </dependency>
          <dependency>
              <groupId>com.h2database</groupId>
              <artifactId>h2</artifactId>
          </dependency>
          <dependency>
              <groupId>org.springframework.boot</groupId>
              <artifactId>spring-boot-starter-test</artifactId>
              <scope>test</scope>
          </dependency>
          <dependency>
              <groupId>junit</groupId>
              <artifactId>junit</artifactId>
          </dependency>
      </dependencies>
  </project>
  

  Person.java

  @Entity
  public class Person
  {
      @Id
      @GeneratedValue(strategy= GenerationType.AUTO)
      private Integer id;
      private String name;
  
      public Person() {}
      public Person(String name) {this.name = name;}
      public Integer getId() {return id;}
      public void setId(Integer id) {this.id = id;}
      public String getName() {return name;}
      public void setName(String name) {this.name = name;}
  }
  

  PersonRepository.java

  @Repository
  public interface PersonRepository extends JpaRepository<Person, Integer> {}
  

  PersonService.java

  @Service
  public class PersonService
  {
      @Autowired
      PersonRepository personRepository;
  
      @Transactional
      public void saveTransactional(List<Person> persons){
          savePersons(persons);
      }
  
      public void saveNonTransactional(List<Person> persons){
          savePersons(persons);
      }
  
      private void savePersons(List<Person> persons){
          for (Person person : persons) {
              if("xxx".equals(person.getName())){
                  throw new RuntimeException("boooom!!!");
              }
              personRepository.save(person);
          }
      }
  }
  

  Application.java

  @SpringBootApplication
  public class Application {
      public static void main(String[] args) {
          SpringApplication.run(Application.class, args);
      }
  }
  

  PersonServiceTest.java

  @RunWith(SpringRunner.class)
  @SpringBootTest
  public class PersonServiceTest {
  
      @Autowired
      PersonService personService;
  
      @Autowired
      PersonRepository personRepository;
  
      @Test
      public void person_table_size_1() {
          List<Person> persons = getPersons();
          try {personService.saveNonTransactional(persons);}
          catch (RuntimeException e) {}
  
          List<Person> personsOnDB = personRepository.findAll();
          assertEquals(1, personsOnDB.size());
      }
  
      @Test
      public void person_table_size_0() {
          List<Person> persons = getPersons();
          try {personService.saveTransactional(persons);}
          catch (RuntimeException e) {}
  
          List<Person> personsOnDB = personRepository.findAll();
          assertEquals(0, personsOnDB.size());
      }
  
      public List<Person> getPersons(){
          List<Person> persons = new ArrayList() {{
              add(new Person("aaa"));
              add(new Person("xxx"));
              add(new Person("sss"));
          }};
  
          return persons;
      }
  }
  

  *为每个测试清除并重新初始化数据库，以便我们始终针对已知状态进行验证

  回复于 2024-04-26T08:15:54+08:00