多线程环境集成测试类上使用@Transactional注释的问题

Question

应用程序堆栈：Spring boot 2.1V+测试容器PostgreSQL 1.10.3V+JUnit 4.12V

DB testcontainers配置

@TestConfiguration
public class DatabaseTestConfig {

    private static JdbcDatabaseContainer PSQL;

    static {

        PSQL = (PostgreSQLContainer) new PostgreSQLContainer("mdillon/postgis:9.4").withUsername("test")
                .withPassword("test")
                .withDatabaseName("test");
        PSQL.start();

        Arrays.asList("main_data.sql")
                .forEach(DatabaseTestConfig::restoreDump);

        /*
           set db properties
        */

    }

    public void restoreDump(String fileName){
         /*
           insert sql data 
           PSQL.copyFileToContainer(fileName)...
        */
    }

}

基本集成测试类

@RunWith(SpringRunner.class)
@SpringBootTest(classes = { DatabaseTestConfig.class, ProjectApplication.class })
@ActiveProfiles("test-int")
@AutoConfigureMockMvc
@Sql(scripts = "classpath:extra_data.sql") // insert some extra data for all integration tests
public abstract class AbstractIntTest {
    @Autowired
    protected MockMvc mockMvc;

在任何事情发生的地方调用服务的集成测试

@Transactional
public class SomeIntegrationTest extends AbstractIntTest {


    @Before
    public void setUp() throws IOException {
      //...
    }

    @Test
    public void callServiceTest() throws Exception {
      //mockMvc.perform(post(ENDPOINT_URL)
    }

逻辑简化的服务

@Service
@AllArgsConstructor
public class SomeService {
    private final SomeJpaReporistory repo;
    private final ExecutorService executor;

    @Override
    @Transactional
    public SomeData call(){
        return CompletableFuture.supplyAsync(() -> {
            return repo.findAll(); 
        }, executor).exceptionally(e -> {
            throw new BadRequestException(e.getMessage());
        });
    }

Answer 1

当您将测试变为事务性时，extra_data.SQL中的SQL查询将在事务中执行。该事务绑定到特定的线程，并在测试方法执行之前开始，在测试方法完成后回滚：

1. 开始事务
2. 执行extra_data.sql
3. 调用测试方法
4. 回滚事务

在第3步中，由于您的服务使用了SupplyAsync，您将在一个单独的线程上调用repo.findall()。由于事务绑定到特定的线程，所以这个findall()调用不是执行extra_data.sql的事务的一部分。为了能够读取extra_data.sql添加的数据，它必须能够读取未提交的更改并执行脏读。Postgres不支持读未提交隔离级别，所以这是不可能的。