1、add dependency
<dependency>
<groupId>io.github.holmofy</groupId>
<artifactId>spring-data-criteria-r2dbc</artifactId>
<version>${latest-version}</version>
</dependency>Find the latest version here
2、add apt plugin. It is like hibernate-jpamodelgen, which will help you generate corresponding mapping fields according to the model of SpringData
<build>
<plugins>
<plugin>
<groupId>org.apache.maven.plugins</groupId>
<artifactId>maven-compiler-plugin</artifactId>
<version>${maven-compiler-plugin.version}</version>
<configuration>
<source>${maven.compiler.source}</source>
<target>${maven.compiler.target}</target>
<annotationProcessorPaths>
<path>
<groupId>io.github.holmofy</groupId>
<artifactId>spring-data-criteria-apt</artifactId>
<version>${latest-version}</version>
</path>
<!-- other apt plugin -->
<path>
<groupId>org.projectlombok</groupId>
<artifactId>lombok</artifactId>
<version>1.18.24</version>
</path>
</annotationProcessorPaths>
</configuration>
</plugin>
</plugins>
</build>3、config Spring Data R2DBC: @EnableR2dbcRepositories(repositoryBaseClass = EnhancedR2dbcRepository.class)
@SpringBootApplication
@EnableR2dbcRepositories(repositoryBaseClass = EnhancedR2dbcRepository.class)
public class MainApplication {
public static void main(String[] args) {
SpringApplication.run(MainApplication.class, args);
}
// Webflux does not support Pageable by default, so we need to manually register it.
@Bean
WebFluxConfigurer springDataArgumentResolversConfigurer() {
return new WebFluxConfigurer() {
@Override
public void configureArgumentResolvers(ArgumentResolverConfigurer configurer) {
configurer.addCustomResolver(new ReactiveSortHandlerMethodArgumentResolver(),
new ReactivePageableHandlerMethodArgumentResolver());
}
};
}
}NOTE: These two issues spring-data-commons/issues/1846 & spring-boot/issues/20701 can track the progress of WebFlux's support for Pageable
4、use dynamic sql
1)、define model
NOTE: spring-data-r2dbc currently does not support @Embedded to see spring-data-r2dbc/issues/288
@Data
@Table("t_user")
public class User {
@Id
private Long id;
@Column("nick")
private String name;
// NOTE: spring-data-r2dbc currently does not support @Embedded
@Embedded.Empty
private Address address;
@CreatedDate
@Column("create_date")
private LocalDateTime created;
@LastModifiedDate
@Column("last_modified_date")
private LocalDateTime modified;
@Data
public static class Address {
private String province;
private String city;
private String area;
}
}2)、Dao interface
public interface UserDao extends ListCrudRepository<User, Long>,
CriteriaExecutor<User>, JdbcSupport {
/**
* Criteria example
*/
default Page<User> searchByQuery(UserQuery query, Pageable pageable) {
return findAll(Criteria.from(MoreCriteria.eq(User_.province, query.province))
.and(MoreCriteria.eq(User_.city, query.city))
.and(MoreCriteria.like(User_.area, query.area))
.and(MoreCriteria.like(User_.name, query.nick))
.and(MoreCriteria.between(User_.created, query.createFrom, query.createTo))
, pageable);
}
@Data
class UserQuery {
String nick;
String province;
String city;
String area;
LocalDateTime createFrom;
LocalDateTime createTo;
}
}3)、use Dao
@RestController
@AllArgsConstructor(onConstructor_ = @Autowired)
public class UserController {
UserDao userDao;
@GetMapping("/search")
public Memo<Page<User>> search(UserDao.UserQuery query, Pageable pageable) {
return userDao.searchByQuery(query, pageable);
}
}The complete example is here.
If you think it's good, please give this project a star.