オニオンアーキテクチャでドメイン知識がSQLに入るのを防ぐ方法

2025年2月5日

オニオンアーキテクチャでコードを構成する際に、頭を悩ませていたのがSQLにドメイン知識が入ってしまうことでした。

データをフィルタしたい場合に、SQLで取得した後Array.filterでフィルタを掛けるのはメモリも食うしパフォーマンスも悪いので現実的ではありません。

そのため、いままではしかたなくSQLのWHERE句にフィルタ条件を書いていたのですが、WHERE句に書く条件を定数としてドメイン層に定義してみればどうか、と思いついたので以下にメモを残します。

例：過去1年分の購入額が100万円以上の人を得意客として抽出する

課題

SQLで SELECT * FROM customers JOIN order ON customers.id = orders.customer_id WHERE (SELECT SUM(total) FROM orders WHERE created_at > "2024-01-24" GROUP BY cutomer_id) > 1000000 と書きたいが、そうすると「1年間の購入額が100万円以上」というドメイン知識をインフラ層に置くことになってしまう。

対策

ドメイン知識の値を定数としてドメイン層に書き、それを受け取ってSQLを発行するリポジトリの型も同時に定義する。
アプリケーション層でインフラ層のコードを呼び出す際にドメイン層の定数を引数に渡す。

コードに起こすと以下のようになります。

1
type CustomerId = Branded('CustomerId', number);
2

3
type Customer = {
4
id: CutomerId;
5
}
6

7
const ValuedCustomerCriteria = {
8
  period: 'one_year',
9
    totalAmount: 1000000,
10
} as const;
11
type ValuedCustomerCriteriaType = typeof ValuedCustomerCriteria;
12

13
type CustomerRepository = {
14
  selectValuedCustomer: (x: ValuedCustomerCriteriaType) => Promise<Customer[]>
15
}

1
import { CustomerRepository, ValuedCustomerCriteria } from './domain.ts';
2

3
const campaignForValuedCustomers = async (repo: CustomerRepository) => {
4
  return repo.selectValuedCustomer(ValuedCustomerCriteria);
5
}

1
import { db } from './db';
2
import { CustomerRepository, ValuedCustomerCriteriaType } from './domain.ts';
3

4
export const repo: CustomerRepository  = {
5
  selectValuedCustomer: async (criteria: ValuedCustomerCriteriaType) => {
6
      const date = calcDate(criteria.period); // one_year, two_years などから日付を得る関数
7
      return db.sql("SELECT * FROM customers JOIN orders ON cutomers.id = orders.customer_id WHERE (SELECT SUM(total) FROM orders WHERE created_at > '?' GROUP BY cutomer_id) > ?", date, criteria.totalAmount).execute();
8
  }
9
}

「購入額の合計」という部分はSQLに残ってしまっていますが、selectValuedCustomer関数はValuedCustomerCriteria 無しでは機能しないので、ドメイン層に得意客についてのドメイン知識があるということはわかるのではないかと思います。

この問題について、他に良い解決方法があればぜひ教えて下さい。