Блог

@Transactional кажется, не работает в моем приложении.

Я пытаюсь обновить объект во время процесса, в другой транзакции ответом должен был быть объект с самым актуальным значением.

Все методы являются общедоступными и аннотированными, даже с REQUIRED_NEW и Isolation .READ_UNCOMMITTED, результат остается тем же.

выполнение http://localhost:8888/example для начала.

вызов http://localhost:8888/example/1 я обновляю и возвращаю:

 {"id":1,"value":"OK"}
  

Но в конце первой транзакции результат неверный:

 {"id":1,"value":"NOT"}
  

org.springframework.data.jpa.repository.JpaRepository Работает ли с @Transaction ?

Или я что-то упускаю …?

пример: https://github.com/jbrasileiro/stackoverflow-transaction

 @EnableTransactionManagement
@EnableJpaRepositories("com.example.demo")
@EntityScan(basePackages = {"com.example.demo"})
@SpringBootApplication
public class DemoApplication {

    public static void main(final String[] args) {
        SpringApplication.run(DemoApplication.class, args);
    }

}
  

 @Repository
public interface ExampleRepository extends JpaRepository<Example, Long> {}
  

 @Service
public class ExampleService {

    @Autowired
    private ExampleRepository repository;
    
    @Transactional(propagation = Propagation.REQUIRES_NEW, isolation = Isolation.READ_UNCOMMITTED)
    public Example get(final Long id) {
        return repository.findById(id).orElseThrow();
    }

    @Transactional(propagation = Propagation.REQUIRES_NEW, isolation = Isolation.READ_UNCOMMITTED)
    public Example save() {
        return repository.save(Example.builder()
                .value("NOT OK")
                .build());
    }
    
    @Transactional(propagation = Propagation.REQUIRES_NEW, isolation = Isolation.READ_UNCOMMITTED)
    public Example update(final Long id) {
        Example entity = repository.getOne(id);
        entity.setValue("OK");
        Example save = repository.save(entity);
        System.err.println(save);
        return save;
    }
}

  

 @RestController
@RequestMapping("/example")
public class ExampleController {

    @Autowired
    private ExampleService service;

    @GetMapping
    public ResponseEntity<Example> execute(){
        Example entity = service.save();
        Long id = entity.getId();
        LocalDateTime envio = LocalDateTime.now();
        LocalDateTime timeout = envio.plusSeconds(30);
        do {
            
            try {
                Thread.sleep(5000);
            } catch (InterruptedException e) {
                 Thread.currentThread().interrupt();
                throw new IllegalStateException(e);
            }
            System.err.println(service.get(id));
        }
        while (LocalDateTime.now().isBefore(timeout));
        return ResponseEntity.ok(service.get(id));
    }
    

    @GetMapping("{id}")
    public ResponseEntity<Example> update(@PathVariable(value = "id") final Long id){
        return ResponseEntity.ok(service.update(id));
    }
}

  

ВЕДЕНИЕ ЖУРНАЛА:

 2020-09-17 16:04:44.659 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Getting transaction for [com.example.demo.ExampleService.save]
2020-09-17 16:04:44.674 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Getting transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.save]
2020-09-17 16:04:44.693 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Completing transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.save]
2020-09-17 16:04:44.693 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Completing transaction for [com.example.demo.ExampleService.save]
2020-09-17 16:04:49.700 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Getting transaction for [com.example.demo.ExampleService.get]
2020-09-17 16:04:49.704 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Getting transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.findById]
2020-09-17 16:04:49.708 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Completing transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.findById]
2020-09-17 16:04:49.708 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Completing transaction for [com.example.demo.ExampleService.get]
Example(id=1, value=NOT OK)
2020-09-17 16:04:51.639 TRACE 660 --- [nio-8888-exec-2] o.s.t.i.TransactionInterceptor           : Getting transaction for [com.example.demo.ExampleService.update]
2020-09-17 16:04:51.640 TRACE 660 --- [nio-8888-exec-2] o.s.t.i.TransactionInterceptor           : Getting transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.getOne]
2020-09-17 16:04:51.641 TRACE 660 --- [nio-8888-exec-2] o.s.t.i.TransactionInterceptor           : Completing transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.getOne]
2020-09-17 16:04:51.644 TRACE 660 --- [nio-8888-exec-2] o.s.t.i.TransactionInterceptor           : Getting transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.save]
2020-09-17 16:04:51.645 TRACE 660 --- [nio-8888-exec-2] o.s.t.i.TransactionInterceptor           : Completing transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.save]
Example(id=1, value=OK)
2020-09-17 16:04:51.645 TRACE 660 --- [nio-8888-exec-2] o.s.t.i.TransactionInterceptor           : Completing transaction for [com.example.demo.ExampleService.update]
2020-09-17 16:04:54.715 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Getting transaction for [com.example.demo.ExampleService.get]
2020-09-17 16:04:54.716 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Getting transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.findById]
2020-09-17 16:04:54.718 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Completing transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.findById]
2020-09-17 16:04:54.718 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Completing transaction for [com.example.demo.ExampleService.get]
Example(id=1, value=NOT OK)
2020-09-17 16:04:59.722 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Getting transaction for [com.example.demo.ExampleService.get]
2020-09-17 16:04:59.723 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Getting transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.findById]
2020-09-17 16:04:59.724 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Completing transaction for [org.springframework.data.jpa.repository.support.SimpleJpaRepository.findById]
2020-09-17 16:04:59.724 TRACE 660 --- [nio-8888-exec-1] o.s.t.i.TransactionInterceptor           : Completing transaction for [com.example.demo.ExampleService.get]
Example(id=1, value=NOT OK)