Created a District domain
@Entity
@Table(name = "DISTRICT_T")
public class DistrictT implements Serializable {
@Id
@Column(name = "DISTRICT_ID")
private Long districtId;
@Column(name = "MSC_CODE")
private String mscCode;
@Column(name ="DISTRICT_NAME")
private String districtName;
@Column(name = "ACTIVE_IND")
private Boolean activeInd;
}
@Repository
public interface DistrictRepository extends PagingAndSortingRepository<DistrictT, Long> {
List<DistrictT> findByActiveIndIsTrue();
}
@Bean
public RepositoryItemReader<DistrictT> districtItemReader(DistrictRepository repository) {
return new RepositoryItemReaderBuilder<DistrictT>().name("districtItemReader")
.pageSize(2)
.repository(districtRepository)
.methodName("findByActiveIndIsTrue")
.sorts(Map.of("districtId", Sort.Direction.ASC))
.build();
}
When running job, Spring throws exception below:
org.springframework.batch.item.adapter.DynamicMethodInvocationException: java.lang.NoSuchMethodException: jdk.proxy2.$Proxy84.findByActiveIndIsTrue(org.springframework.data.domain.PageRequest)
at org.springframework.batch.item.data.RepositoryItemReader.doInvoke(RepositoryItemReader.java:275) ~[spring-batch-infrastructure-5.1.2.jar:5.1.2]
Any idea on how to fix error?
You need to update the DistrictRepository to support pagination by adding a Pageable argument to the findByActiveIndIsTrue() method.
@Repository
public interface DistrictRepository extends PagingAndSortingRepository<DistrictT, Long> {
Page<DistrictT> findByActiveIndIsTrue(Pageable pageable);
}
The exception or the error that you are getting means that your function findByActiveIndIsTrue() is getting invoked along with a parameter ‘org.springframework.data.domain.PageRequest‘, which the function does not expects as per the function definition in the DistrictRepository. To solve the issue, you would need to modify the function findByActiveIndIsTrue() to accept an argument of type Pageable, like below:
@Repository
public interface DistrictRepository extends PagingAndSortingRepository<DistrictT, Long> {
Page<DistrictT> findByActiveIndIsTrue(Pageable pageable);
}
Whenever we use a function that returns a List in Spring Data JPA, pagination is automatically handled by Spring. However, the function does not know by itself to accept Pageable as a function argument.
Additionally, if you want to pass specific PageRequest arguments to your repository function, you can use the .arguments() while calling your function findByActiveIndIsTrue() in the RepositoryItemReader configuration like:
@Bean
public RepositoryItemReader<DistrictT> districtItemReader(DistrictRepository repository) {
return new RepositoryItemReaderBuilder<DistrictT>().name("districtItemReader")
.pageSize(2)
.repository(districtRepository)
.methodName("findByActiveIndIsTrue")
.arguments(List.of(PageRequest.of(0, 5))) // in case you want to pass specific PageRequest parameters
.sorts(Map.of("districtId", Sort.Direction.ASC))
.build();
}
Ishita is a new contributor to this site. Take care in asking for clarification, commenting, and answering.
Check out our Code of Conduct.