【第7回】マイクロサービスの結合試験コード実装¶

package org.debugroom.mynavi.sample.continuous.integration.backend.domain.service;

// omit
import com.github.springtestdbunit.DbUnitTestExecutionListener;
import com.github.springtestdbunit.annotation.DbUnitConfiguration;
import com.github.springtestdbunit.annotation.ExpectedDatabase;
import com.github.springtestdbunit.annotation.ExpectedDatabases;
import com.github.springtestdbunit.assertion.DatabaseAssertionMode;
import com.github.springtestdbunit.dataset.AbstractDataSetLoader;

import org.dbunit.dataset.IDataSet;
import org.dbunit.dataset.csv.CsvDataSet;

import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.test.context.TestExecutionListeners;
import org.springframework.test.context.junit4.SpringRunner;
import org.springframework.test.context.support.DependencyInjectionTestExecutionListener;
import org.springframework.test.context.support.DirtiesContextTestExecutionListener;
import org.springframework.test.context.transaction.TransactionalTestExecutionListener;

// omit

@RunWith(SpringRunner.class)                                                 // …(A)
@SpringBootTest(classes = {
      TestConfig.ServiceTestConfig.class,
}, webEnvironment =  SpringBootTest.WebEnvironment.NONE)                     // …(B)
@TestExecutionListeners({ DependencyInjectionTestExecutionListener.class,
      DirtiesContextTestExecutionListener.class,
      TransactionalTestExecutionListener.class,
      DbUnitTestExecutionListener.class })                                   // …(C)
@DbUnitConfiguration(dataSetLoader = IntegrationTest.CsvDataSetLoader.class) // …(D)
@ActiveProfiles("dev")
public static class IntegrationTest{

    public static class CsvDataSetLoader extends AbstractDataSetLoader{  // …(E)
        @Override
        protected IDataSet createDataSet(Resource resource) throws Exception {
            return new CsvDataSet(resource.getFile());
        }
    }

    // omit

    @Autowired
    SampleService sampleService;

    @Test
    @ExpectedDatabases({                                                       // …(F)
          @ExpectedDatabase(
                  value = "classpath:/META-INF/dbunit/domain/service/SampleServiceImplTest/add",
                  table = "usr", assertionMode = DatabaseAssertionMode.NON_STRICT),
          @ExpectedDatabase(
                  value = "classpath:/META-INF/dbunit/domain/service/SampleServiceImplTest/add",
                  table = "address", assertionMode = DatabaseAssertionMode.NON_STRICT),
          @ExpectedDatabase(
                  value = "classpath:/META-INF/dbunit/domain/service/SampleServiceImplTest/add",
                  table = "email", assertionMode = DatabaseAssertionMode.NON_STRICT_UNORDERED),
          @ExpectedDatabase(
                  value = "classpath:/META-INF/dbunit/domain/service/SampleServiceImplTest/add",
                  table = "membership", assertionMode = DatabaseAssertionMode.NON_STRICT_UNORDERED),
    })
    public void addNormalTest() throws BusinessException{
        // omit
        User addUser = User.builder()
              .firstName("saburo")
              .familyName("mynavi")
              .loginId("saburo.mynavi")
              .isLogin(false)
              .addressByUserId(addAddress)
              .emailsByUserId(Arrays.asList(new Email[]{addEmail1, addEmail2}))
              .membershipsByUserId(Arrays.asList(new Membership[]{membership1}))
              .build();
       sampleService.add(addUser);
    }

package org.debugroom.mynavi.sample.continuous.integration.backend.config;

import javax.sql.DataSource;

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.context.annotation.Profile;
import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseBuilder;
import org.springframework.jdbc.datasource.embedded.EmbeddedDatabaseType;

@Profile("dev")
@Configuration
public class DevConfig {

    @Bean
    public DataSource dataSource(){
        return (new EmbeddedDatabaseBuilder())
          .setType(EmbeddedDatabaseType.HSQL)
          .addScript("classpath:ddl/schema.sql")
          .addScript("classpath:ddl/data.sql")
          .build();
    }
}

package org.debugroom.mynavi.sample.continuous.integration.backend.app.web;

// omit

import org.springframework.boot.test.context.SpringBootTest;
import org.springframework.boot.test.web.client.TestRestTemplate;
import org.springframework.boot.web.server.LocalServerPort;
import org.springframework.test.context.junit4.SpringRunner;

// omit

@RunWith(SpringRunner.class)                                      // …(A)
@SpringBootTest(classes = TestConfig.ControllerTestConfig.class,
   webEnvironment = SpringBootTest.WebEnvironment.RANDOM_PORT)    // …(B)
public static class IntegrationTest{

    private static final String testServer = "localhost";

    @Autowired
    TestRestTemplate testRestTemplate;                           // …(C)

    @LocalServerPort
    int port;                                                    // …(D)

    private String testServerURL;

    @Before
    public void setUp(){
        testServerURL = "http://" + testServer + ":" + port;     // …(E)
    }

    @Test
    public void getUsersNormalTest(){
        ResponseEntity<UserResource[]> responseEntity = testRestTemplate
          .getForEntity(testServerURL + "/api/v1/users", UserResource[].class);

        List<UserResource> userResources = Arrays.asList(responseEntity.getBody());

        assertThat(userResources.size(), is(3));
        userResources.forEach(userResource -> {
            switch (Long.toString(userResource.getUserId())){
                case "1":
                    assertThat(userResource.getFirstName(), is("hanako"));
                    assertThat(userResource.getFamilyName(), is("mynavi"));
                    break;
                // omit
            }
        });

   }