[Domain Driven Design] 11. 애그리거트 간 집합 연관, 애그리거트의 팩토리 역할

애그리거트 간 집합 연관

애그리거트 간 1:N, N:1 연관에 대해 알아보자. 이 두 연관은 컬렉션(Collection)을 이용한 연관이다. 카테고리와 상품 간의 연관이 대표적이다.

• 카테고리 입장에서 한 카테고리에 한 개 이상의 상품이 속할 수 있으니 카테고리와 상품은 1:N 관계이다.
• 한 상품이 한 카테고리에만 속할 수 있다면 상품과 카테고리 관계는 N:1 관계이다.

 

애그리거트 간 1:N 관계는 Set과 같은 컬렉션을 이용해서 표현할 수 있다.

 

예를 들어 다음 코드처럼 Category가 연관된 Product를 값으로 갖는 컬렉션을 필드로 정의할 수 있다.

public class Category {
    private Set<Product> products; // 다른 애그리거트에 대한 1:N 연관
    ...
}

개념적으로 존재하는 애그리거트 간의 1:N 연관을 실제 구현에 반영하는 것이 요구사항을 충족하는 것과는 상관없을 때가 있다. 특정 카테고리에 속한 상품 목록을 보여주는 요구사항을 생각해보자. 보통 목록 관련 요구사항은 한번에 전체 상품을 보여주기 보다는 페이징을 이용해서 나눠서 보여준다. 이 기능을 카테고리 입장에서 1:N 연관을 이용해 구현하면 다음과 같은 방식으로 코드를 작성해야한다.

public class Category {
    private Set<Product> products;
    
    public List<Product> getProducts(int page, int size) {
        List<Product> sortedProducts = sortById(products);
        return sortedProducts.subList((page - 1) * size, page * size);
    }
    ...
 }

위 코드는 Category에 속한 모든 Propduct를 조회하게된다. Product 개수가 수만개 정도로 많다면? 이 코드는 실행될때마다 실행 속도가 급격히 느려진다. 개념적으로는 애그리거트 간에 1:N 연관이 있더라도 성능 문제 떄문에 애그리거트 간의 1:N 연관을 실제 구현에 반영하지 않는다.

 

▶ 카테고리에 속한 상품을 구할 필요가 있을 경우

상품 입장에서 자신이 속한 카테고리를 N:1로 연관지어 구하면 된다.

이를 구현 모델에 반영하면 Product에 다음과 같이 Category로의 연관을 추가하고 그 연관을 이용해서 특정 Category에 속한 Product 목록을 구하면 된다. 

public class Product {
    ...
    private CategoryId categoryId;
    ...
}

카테고리에 속한 상품 목록을 제공하는 응용 서비스는 ProductRepository를 이용해서 categoryId가 지정한 카테고리 식별자인 Product 목록을 구한다.

 

ProductRepository.java

public class ProductListService {
    public Page<Product> getProductOfCategory(Long categoryId, int page, int size) {
        Category category = categoryRepository.findById(categoryId);
        checkCategory(category);
        
        // categoryID에 해당하는 product list 조회
        List<Product> products = productRepository.findByCategoryId(category.getId(), page, size);
        int totalCount = productRepository.countsByCategoryId(category.getId());
        return new Page(page, size, totalCount, products);
    }
}

M:N 연관은 개념적으로 양쪽 애그리거트에 컬렉션으로 연관을 만든다. 상품이 여러 카테고리에 속할 수 있다고 가정하면 카테고리와 상품은 M:N 연관을 맺는다. 1:N 연관처럼 M:N 연관도 실제 요구사항을 고려하여 M:N 연관을 구현에 포함시킬지를 결정해야한다.

 

보통 특정 카테고리에 속한 상품 목록을 보여줄때 목록 화면에서 각 상품이 속한 모든 카테고리를 상품 정보에 표시하지는 않는다. 제품이 속한 모든 카테고리가 필요한 화면은 상품 상세 화면이다. 이러한 요구사항을 고려할때 카테고리에서 상품으로의 집합 연관은 필요하지 않다. 

 

상품에서 카테고리로의 집합 연관만 존재하면 된다.

public class Product {
    private Set<CategoryId> categoryIDs;
    ...
}

 

조인 테이블을 이용한 M:N 연관 매핑

https://incheol-jung.gitbook.io/docs/study/ddd-start/3

 

JPA를 이용하면 매핑 설정을 사용해서 ID 참조를 이용한 M:N 단방향 연관을 구현할 수 있다.

 

Product.java

@Entity
@Table(name = "product")
public class Product {
    @EmbeddedId
    private ProductId id;

    @ElementCollection(fetch = FetchType.LAZY)
    @CollectionTable(name = "product_category",
            joinColumns = @JoinColumn(name = "product_id"))
    private Set<CategoryId> categoryIds;
    
    ...
}

이 매핑은 카테고리 ID 목록을 보완하기 위해 밸류 타입에 대한 컬렉션 매핑을 이용했다. 이 매핑을 사용하면 다음과 같이 JPQL의 member of 연산자를 이용해서 특정 Category에 속한 Product 목록을 구하는 기능을 구현할 수 있다.

@Repository
public class JpaProductRepository implements ProductRepository {
	@PersistenceContext
	private EntityManager entityManager;

	@Override
	public List<Product> findByCategoryId(CategoryId categoryId, int page, int size) {
		TypedQuery<Product> query = entityManager.createQuery(
				"select p from Product p" + "where :catId member of p.categoryIds order by p.id.id desc",
				Product.class);
                
		query.setParameter("catId", categoryId);
		query.setFirstResult((page - 1) * size);
		query.setMaxResults(size);
        
		return query.getResultList();
	}
    
    ...
}

1) categoryIds 컬렉션에 catId로 지정한 값이 존재하는지 검사

:catId member of p.categoryIds

 

 

애그리거트를 팩토리로 사용하기

고객에 특정 상점을 여러 차례 신고해서 해당 상점이 더이상 물건을 등록하지 못하도록 차단한 상태라고 해보자.

상품 등록 기능을 구현한 응용 서비스는 다음과 같이 상점 계정이 차단 상태가 아닌 경우에만 상품을 생성하도록 구현할 수 있을 것이다. 

 

상품 등록 기능을 구현한 응용 서비스

public class RegisterProductService {
    public ProductId registerNewProduct(NewProductRequest req) {
        // 생성 가능 판단 
        Store account = accountRepository.findStoreById(req.getStoreId());
        checkNull(account);
        
        if (!account.isBlocked()){
			throw new StoreBlockedException();	
		}
        
        // product 생성 
        ProductId id = productRepository.nextId();
        Product product = new Product(id, account.getId(), ...생략);
        
        // save
        productRepository.save(product);
        
        return id;
    }
    ...
}

이 코드는 Product를 생성 가능한지 판단하는 코드와 Product를 생성하는 코드가 분리되어 있다. 

 

Store가 Product를 생성할 수 있는지를 판단하고 Product를 생성하는 것은 논리적으로 하나의 도메인 기능이다.

이 도메인 기능을 응용 서비스에서 구현하고 있음으로써, 도메인 로직 처리가 응용 서비스에 노출되었다.

 

이 도메인 기능을 넣기 위한 별도의 도메인 서비스나 팩토리 클래스를 만들 수도 있지만, 이 기능을 Store 애그리거트에 구현할 수도 있다.

 

Product를 생성하는 기능을 Store 애그리거트에 다음과 같이 옮겨보자.

public class Store {
    ...

    public Product createProduct(ProductId newProductId, ...생략) {
        if (isBlocked()) throw new StoreBlockedException();
        return new Product(newProductId, getId(), ...생략);
	}
}

Store 애그리거트의 createProduct()는 Product 애그리거트를 생성하는 팩토리 역할을 한다. 팩토리 역할을 하면서도 중요한 도메인 로직을 구현하고 있다. 팩토리 기능을 구현했으므로 이제 응용 서비스는 팩토리 기능을 이용해서 Product를 생성하면 된다.

public class RegisterProductService{
    public ProductId registerNewProduct(NewProductRequest req){
        Store account = accountRepository.findStoreById(req.getStoreId()));
        checkNull(account);
        
        ProductId id = productRepository.nextId();
        
        // domain 로직 
        Product product = account.createProduct(id, ...생략);
        
        productRepository.save(product);
        
        return id;
    }
}

이렇게 변경함으로써 더이상 응용 서비스에서 Store의 상태를 확인하지 않는다. Store가 Product를 생성할 수 있는지를 확인하는 도메인 로직은 Store에서 구현하고 있다. 이제 Product 생성 가능 여부를 확인하는 도메인 로직을 변경해도 도메인 영역의 Store만 변경하면 되고 응용 서비스는 영향을 받지 않는다.

도메인의 응집도가 높아졌다. 이것이 바로 애그리거트를 팩토리로 사용할때 얻을 수 있는 장점이다. 

 

애그리거트가 갖고있는 데이터를 이용해서 다른 애그리거트를 생성해야 한다면 애그리거트에 팩토리 메서드를 구현하는 것을 고려해보자.

 

Product의 경우

1) 제품을 생성한 Store의 식별자를 필요로 한다.

• 즉, Store의 데이터를 이용해서 Product를 생성한다.

2) Product를 생성할 수 있는 조건을 판단할 때 Store의 상태를 이용한다.

• 따라서 Store에 Product를 생성하는 팩토리 메서드를 추가하면 Product를 생성할때 필요한 데이터의 일부를 직접 제공하면서 동시에 중요한 도메인 로직을 함께 구현할 수 있게된다.

 

Store 애그리거트가 Product 애그리거트를 생성할때 많은 정보를 알아야 한다면 Store 애그리거트에서 Product 애그리거트를 직접 생성하지 않고 다른 팩토리에 위임하는 방법도 있다.

public class Store {
    ...

    public Product createProduct(ProductId newProductId, ProductInfo pi) {
        if (isBlocked()) throw new StoreBlockedException();
        
        // 위임
        return ProductFactory.create(newProductId, getId(), pi);
    }
}

 

다른 팩토리에 위임하더라도 차단 상태의 상점은 상품을 만들 수 없다는 도메인 로직은 한 곳에 계속 위치한다.