取引先の更新処理

CompanyRepository.java

    public void update(String objectId, Company company, AuthenticationResult authenticationResult) {
        salesforceWebClient.patch() // 更新はPATCH
                .uri( salesforceProperties.getApplicationPath()+ "/sobjects/Account/" + objectId) // 更新対処の取引先のオブジェクトIDを指定
                .header("Authorization", authenticationResult.bearerToken())  // 認証結果
                .contentType(MediaType.APPLICATION_JSON)
                .body(Mono.just(company), Company.class).retrieve()
                .toBodilessEntity()
                .block();
    }

SalesforceUpdateTest.groovy

package com.github.apz.salesforcesample.repository

import com.github.apz.salesforcesample.model.Company
import org.springframework.beans.factory.annotation.Autowired
import org.springframework.boot.test.context.SpringBootTest
import spock.lang.Specification

@SpringBootTest
class SalesforceUpdateTest extends Specification {
    @Autowired
    SalesforceAuthentication authentication

    @Autowired
    CompanyRepository repository

    def "更新"() {
        when:
        def company = new Company()
        company.setName("更新テストを行った会社")

        def authenticationResult = authentication.authentication()
        repository.update("0010l00001dKU2XAAW", company, authenticationResult)  // 第1引数のidは、登録した取引先のidを指定

        then:
        noExceptionThrown()
    }
  
    def "更新失敗"() {
        when:
        def company = new Company()
        company.setName("更新テストを失敗する会社")

        def authenticationResult = authentication.authentication()
        repository.update("faildata", company, authenticationResult)

        then:
        WebClientResponseException ex = thrown()
        ex.statusCode == HttpStatus.NOT_FOUND
    }
}