【JPA】結合されたテーブルに対して動的クエリで検索する方法

Question

はじめに

Spring Bootを使用してJavaの勉強をしているのですが、
JPAの挙動で悩んでいるので、少しでも思い当たることがあれば教えて下さい。

やりたいこと

以下のような検索処理を実装しています。

• 9個の検索項目の内、一つ以上の項目を入力して検索する
• 検索対象のテーブルは2つ（CLAIMテーブルとFRAUD_SCORE_HISTORYテーブル）
• CLAIMテーブルとFRAUD_SCORE_HISTORYテーブルは親子の関係

※FRAUD_SCORE_HISTORYにも子孫テーブルが存在する

• CLAIMテーブルとFRAUD_SCORE_HISTORYテーブルから取得した要素をプロパティに持つオブジェクトのリストを検索結果として表示する

環境（pom.xmlから抜粋）

言語：Java 11
フレームワーク：Spring Boot 2.3.2
DB：H2データベース
DB操作：JPA
テストツール：Junit5

問題

Claimテーブルに1レコード挿入し、
Claimテーブルの各子孫テーブルにもそれぞれレコードを挿入した状態で
検索処理のテストをしました。
すると検索後になぜか1レコード増えてしまっていました。

主キーを自動採番する設定にしているのですが、
増えてしまった1レコードは主キー以外が1レコード目と全く同じです。

どのタイミングで増えているかですが、まず検索時は増えていません。
テーブルに1レコード存在する状態で検索すると1レコード取得出来ます。

また、同一メソッド内で2回検索処理をすると、2回とも1レコードだけ取得出来ます。
さらに、1回目のメソッド終了後も増えません。
（1メソッド実行後にDBを直接見ると1レコードしかありませんでした）

ただ、2つのメソッドで検索処理をすると、
後に実行したメソッドは2件のレコードを取得してしまいます。
テスト終了後にDBを直接見ても、レコードが増えています。

また、Claimテーブルだけでなく、その子孫テーブル全てのレコードが2倍になっています。
全て、Claimテーブルと同じく主キー以外同じレコードが2件ずつあります。

単一テーブルに対して動的クエリで検索した場合は、
正しく検索出来たので、結合されたテーブルに対して処理したことが原因だと思っています。

以下、実装したコードです。

コード

量が多いので一部省略します。
なお、動的クエリは以下を参考に実装しました。
[JPA] DB検索時の条件を動的に設定する

エンティティクラス

@Entity
@Table(name = "CLAIM")
@Data
@NoArgsConstructor
@AllArgsConstructor
@ToString(exclude = "fraudScoreHistory")
public class Claim implements Serializable {
	private static final long serialVersionUID = 1L;

	@Id
	@GeneratedValue(strategy = GenerationType.IDENTITY)
	private Integer Id;

（中略）

	@OneToMany(cascade = CascadeType.ALL, fetch = FetchType.EAGER, mappedBy = "claim")
	private List<FraudScoreHistory> fraudScoreHistory;
}

@Entity
@Table(name = "FRAUD_SCORE_HISTORY")
@Data
@NoArgsConstructor
@AllArgsConstructor
@ToString(exclude = "fraudScoreDetails")
public class FraudScoreHistory implements Serializable{
	private static final long serialVersionUID = 1L;

	@Id
	@GeneratedValue(strategy = GenerationType.IDENTITY)
	private Integer Id;

（中略）

	@OneToMany(cascade = CascadeType.ALL, fetch = FetchType.EAGER, mappedBy = "fraudScoreHistory")
	private List<FraudScoreDetail> fraudScoreDetails;

	@ManyToOne(fetch = FetchType.EAGER)
	@JoinColumn(nullable = false, name = "CLAIM_ID")
	private Claim claim;
}

@Entity
@Table(name = "FRAUD_SCORE_DETAILS")
@Data
@NoArgsConstructor
@AllArgsConstructor
@ToString(exclude = "reasons")
public class FraudScoreDetail implements Serializable{
	private static final long serialVersionUID = 1L;

	@Id
	@GeneratedValue(strategy = GenerationType.IDENTITY)
	private Integer Id;

（中略）

	@OneToMany(cascade = CascadeType.ALL, fetch = FetchType.EAGER, mappedBy = "fraudScoreDetail")
	private List<Reason> reasons;

	@ManyToOne(fetch = FetchType.EAGER)
	@JoinColumn(nullable = false, name = "FRAUD_SCORE_HISTORY_ID")
	private FraudScoreHistory fraudScoreHistory;
}

@Entity
@Table(name = "REASONS")
@Data
@NoArgsConstructor
@AllArgsConstructor
public class Reason implements Serializable {
	private static final long serialVersionUID = 1L;

	@Id
	@GeneratedValue(strategy = GenerationType.IDENTITY)
	private Integer Id;

（中略）

	@ManyToOne(fetch = FetchType.EAGER)
	@JoinColumn(nullable = false, name = "FRAUD_SCORE_DETAIL_ID")
	private FraudScoreDetail fraudScoreDetail;
}

レポジトリクラス・検索条件の実装クラス

public interface ClaimRepository extends JpaRepository<Claim, Integer>, JpaSpecificationExecutor<Claim> {
}

@Component
public class ClaimSpecifications {

	/**
	 * @param claimNumber
	 * @return 指定文字を事案番号に含む事案
	 */
	public Specification<Claim> claimNumberContains(String claimNumber) {
		return StringUtils.isEmpty(claimNumber) ? null : new Specification<Claim>() {
			@Override
			public Predicate toPredicate(Root<Claim> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
				return criteriaBuilder.equal(root.get("claimNumber"), claimNumber);
			}
		};
	}

（中略：同様に各検索条件のためのメソッドを作成）

	/**
	 * @param claimCategory
	 * @return 指定文字を事案カテゴリに含む事案
	 */
	public Specification<Claim> claimCategoryContains(String claimCategory) {
		return StringUtils.isEmpty(claimCategory) ? null : new Specification<Claim>() {
			@Override
			public Predicate toPredicate(Root<Claim> root, CriteriaQuery<?> query, CriteriaBuilder criteriaBuilder) {
claimCategory);
				return criteriaBuilder.equal(
						root.join("fraudScoreHistory", JoinType.LEFT).get("claimCategory"), claimCategory);
			}
		};
	}

}

サービスクラス

@Service
@Transactional
public class ClaimService {

	@Autowired
	ClaimRepository claimRepository;

	@Autowired
	ClaimSpecifications claimSpecifications;

	/**
	 * @param claimNumber
	 * @param insuredName
	 * @param contractorName
	 * @param departmentInCharge
	 * @param baseInCharge
	 * @param insuranceType
	 * @param updateDate
	 * @param accidentDate
	 * @param claimCategory
	 * @return 指定した値で検索した事案一覧の結果
	 */
	public List<Claim> getClaimListByCriteria(
			String claimNumber, String insuredName, String contractorName,
			String departmentInCharge, String baseInCharge, String insuranceType,
			String updateDate, String accidentDate, String claimCategory) {
		return claimRepository.findAll(Specification
				.where(claimSpecifications.claimNumberContains(claimNumber))
				.and(claimSpecifications.insuredNameContains(insuredName))
				.and(claimSpecifications.contractorNameContains(contractorName))
				.and(claimSpecifications.departmentInChargeContains(departmentInCharge))
				.and(claimSpecifications.baseInChargeContains(baseInCharge))
				.and(claimSpecifications.insuranceTypeContains(insuranceType))
				.and(claimSpecifications.accidentDateContains(accidentDate))
				.and(claimSpecifications.updateDateContains(updateDate))
				.and(claimSpecifications.claimCategoryContains(claimCategory)));
	}
}

テストクラス

@Slf4j
@ExtendWith(SpringExtension.class)
//@SpringBootTest(properties =
//{ "spring.datasource.url:jdbc:h2:mem:testdb;DB_CLOSE_ON_EXIT=FALSE;" })
@SpringBootTest
@Sql(scripts = "classpath:/sql/data.sql", config = @SqlConfig(encoding = "utf-8"))
class ClaimServiceTest {

	@Autowired
	ClaimService claimSerive;

	@Test
	public void testGetClaimListByCriteria() {
		log.info("テストNo.1");
		List<Claim> claimList = claimSerive.getClaimListByCriteria(
				"12345678910", "", "", "", "", "", "", "", "");
		log.info("claimList:{}", claimList);
		log.info("claimList.size():{}", claimList.size());
	}

	@Test
	public void testGetClaimListByCriteria2() {
		log.info("テストNo.2");
		List<Claim> claimList = claimSerive.getClaimListByCriteria(
				"12345678910", "", "", "", "", "", "", "", "");
		log.info("claimList:{}", claimList);
		log.info("claimList.size():{}", claimList.size());
	}
}

テストデータ（scripts = "classpath:/sql/data.sql"）

INSERT INTO CLAIM
(CLAIM_NUMBER, INSURED_NAME, CONTRACTOR_NAME, DEPARTMENT_IN_CHARGE, BASE_IN_CHARGE, INSURANCE_TYPE, UPDATE_DATE, ACCIDENT_DATE)
VALUES
('12345678910', '鈴木一郎', '山田次郎', '第一部署', '東京本社', 'スポ協', '2020-07-25T12:00:00.000Z', '2020-07-25T12:00:00.000Z');
INSERT INTO FRAUD_SCORE_HISTORY
(SCORING_DATE, CLAIM_CATEGORY, CLAIM_ID)
VALUES
('2020-06-25T12:00:00.000Z', '低', 1),
('2020-07-25T12:00:00.000Z', '中', 1);

INSERT INTO FRAUD_SCORE_DETAILS
(MODEL_CATEGORY_NAME, RANK, SCORE, FRAUD_SCORE_HISTORY_ID)
VALUES
('特殊事案モデル', 'Low', 30, 1),
('NC/PDモデル', 'Low', 30, 1),
('特殊事案モデル', 'Middle', 50, 2),
('NC/PDモデル', 'Middle', 50, 2);

INSERT INTO REASONS
(RANK, SCORE, DESCRIPTION, FEATURE_DESCRIPTION, FRAUD_SCORE_DETAIL_ID)
VALUES
('High', 50, '特徴量1', '特徴量1の説明', 1),
('Middle', 10, '特徴量2', '特徴量2の説明', 1),
('Low', -30, '特徴量3', '特徴量3の説明', 1),
('High', 50, '特徴量1', '特徴量1の説明', 2),
('Middle', 10, '特徴量2', '特徴量2の説明', 2),
('Low', -30, '特徴量3', '特徴量3の説明', 2),
('High', 70, '特徴量1', '特徴量1の説明', 3),
('Middle', 10, '特徴量2', '特徴量2の説明', 3),
('Low', -30, '特徴量3', '特徴量3の説明', 3),
('High', 70, '特徴量1', '特徴量1の説明', 4),
('Middle', 10, '特徴量2', '特徴量2の説明', 4),
('Low', -30, '特徴量3', '特徴量3の説明', 4);

JPAで実行されたSQL

SQLはSELECT文しか実行されていません。
SQLの実行文字数は1回目よりも2回目の方が2倍以上多くなっています。
1回目のメソッド実行時は600文字程度。
2回目のメソッド実行時は1800文字程度。

全量はGitHubに上げました。
実行されたSQL

その他試したこと

動的クエリの作成方法が悪いのかと思い、以下を参考に他の方法でも試しました。
Spring Data JPAで動的にクエリを生成するQuery by Example機能

ただ、結果は同じでした。

@Service
@Transactional
public class ClaimService {

	@Autowired
	ClaimRepository claimRepository;

	@Autowired
	ClaimSpecifications claimSpecifications;

	/**
	 * @param claimNumber
	 * @param insuredName
	 * @param contractorName
	 * @param departmentInCharge
	 * @param baseInCharge
	 * @param insuranceType
	 * @param updateDate
	 * @param accidentDate
	 * @param claimCategory
	 * @return 指定した値で検索した事案一覧の結果
	 */
	public List<Claim> getClaimListByExample(
			String claimNumber, String insuredName, String contractorName,
			String departmentInCharge, String baseInCharge, String insuranceType,
			String updateDate, String accidentDate, String claimCategory) {

		Claim claim = new Claim();

		if (!StringUtils.isEmpty(claimNumber)) {
			claim.setClaimNumber(claimNumber);
		}

（中略：同様にif文で判定し、入力されていればset）

		if (!StringUtils.isEmpty(claimCategory)) {
			FraudScoreHistory fraudScoreHistory = new FraudScoreHistory();
			fraudScoreHistory.setClaimCategory(claimCategory);
			List<FraudScoreHistory> fraudScoreList = new ArrayList<>();
			fraudScoreList.add(fraudScoreHistory);
			claim.setFraudScoreHistory(fraudScoreList);
		}

		return claimRepository.findAll(Example.of(claim));
	}

また、関係ないと思いますが、
エンティティクラスでfetch = FetchType.LAZYとすると、
検索時にLazyInitializationExceptionが発生します。
本題とはずれますが、これについてもご存じの方がいれば教えて下さい。

Comments

[A-pZ]

テストクラスの @Sql(scripts = "classpath:/sql/data.sql", config = @SqlConfig(encoding = "utf-8")) で指定している SQL も追記したほうが良いでしょう。

[waito]

ありがとうございます。テストクラスの下に追記しました。

Answer 1

試していないのですが、@Sqlで定義しているINSERT文が@Testごとに実行されているように思えます。

@Transactionを併用するか、@BeforeAllで投入SQLを1度だけにするかなどで対応できるかもしれません。

Answer 2

大変恥ずかしいのですが、自己解決しました。

テストクラスに@Sql(scripts = "classpath:/sql/data.sql", config = @SqlConfig(encoding = "utf-8"))をつけていたのですが、これが原因でした。

クラスに@Sqlつけると一番最初に一度だけ、
指定したsqlが実行されると思っていたのですが、
各メソッド実行前に呼び出されるようです。

つまり、テストメソッドが2個あるので、
テストデータ作成用sqlが2回実行されてしまっていたということです。

見当違いな質問をしてしまい、申し訳ございませんでした。
恥ずかしいので、この質問は数日後に消すかもしれません。

また、ご存じの方がいれば教えて頂きたいのですが、
テストの最初に一度だけ、テストデータ作成用のsqlを実行する方法はありますでしょうか？
（@BeforeAllをつけたメソッドに@Sqlをつけるという方法ではsqlが実行されませんでした）

また、JPAが実行したsqlではなく、自分が作成したsqliptから実行したsqlもログに吐き出すようにする方法はありますでしょうか？

以上、宜しくお願い致します。

Comments

[sazi]

恥ずかしいから消すと言いつつ、追加の質問をここでするのですね。
解決したのなら、別質問にされた方が良いと思います。
一応回答に追記はしています。

[waito]

> 解決したのなら、別質問にされた方が良いと思います。
失礼しました。

>DB側でSQLトレースすれば良いかと思います。
調べてやってみようと思います。
ありがとうございました。

Answer 3

selectではデータ更新が行われることはありません。
追加用の処理が呼び出されているのではないでしょうか。

JPAが実行したsqlではなく、自分が作成したsqliptから実行したsqlもログに吐き出すようにする方法はありますでしょうか？

DB側でSQLトレースすれば良いかと思います。

Comments

[waito]

回答ありがとうございます。
どこかで追加用の処理が呼び出されてしまっているのだとは思います。
ただ、追加用の処理は実装しておらず、
JPAにあらかじめ備わっている追加用の処理も使用しようとはしていないので、
何が原因か分かっていない状態です。

テストデータのSQLを追記したので、何か解決のアドバイスがあれば、頂けるとありがたいです。