added example for issue 105

Author: lpandzic

infobip-spring-data-r2dbc-custom-fragment/pom.xml

@@ -0,0 +1,42 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+         xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+
+    <parent>
+        <groupId>com.infobip</groupId>
+        <artifactId>infobip-spring-data-querydsl</artifactId>
+        <version>9.0.8-SNAPSHOT</version>
+    </parent>
+
+    <artifactId>infobip-spring-data-r2dbc-custom-fragment</artifactId>
+
+    <dependencies>
+        <dependency>
+            <groupId>${project.groupId}</groupId>
+            <artifactId>infobip-spring-data-r2dbc-querydsl-boot-starter</artifactId>
+            <version>${project.version}</version>
+        </dependency>
+
+        <!--TEST-->
+        <dependency>
+            <groupId>io.r2dbc</groupId>
+            <artifactId>r2dbc-mssql</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+
+        <dependency>
+            <groupId>com.zaxxer</groupId>
+            <artifactId>HikariCP</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+</project>

infobip-spring-data-r2dbc-custom-fragment/src/test/java/com/infobip/test/Main.java

@@ -0,0 +1,14 @@
+package com.infobip.test;
+
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.boot.builder.SpringApplicationBuilder;
+
+@SpringBootApplication
+public class Main {
+
+	public static void main(String[] args) {
+
+		new SpringApplicationBuilder(Main.class).run(args);
+	}
+
+}

infobip-spring-data-r2dbc-custom-fragment/src/test/java/com/infobip/test/Person.java

@@ -0,0 +1,16 @@
+package com.infobip.test;
+
+import lombok.With;
+import org.springframework.data.annotation.Id;
+
+public record Person(
+    @With
+    @Id
+    Long id,
+
+    String firstName,
+    
+    String lastName
+) {
+
+}

infobip-spring-data-r2dbc-custom-fragment/src/test/java/com/infobip/test/PersonRepository.java

@@ -0,0 +1,6 @@
+package com.infobip.test;
+
+import com.infobip.spring.data.r2dbc.QuerydslR2dbcRepository;
+
+public interface PersonRepository extends QuerydslR2dbcRepository<Person, Long>, ReactivePagingRepository<Person> {
+}

infobip-spring-data-r2dbc-custom-fragment/src/test/java/com/infobip/test/QuerydslR2dbcRepositoryTest.java

@@ -0,0 +1,15 @@
+package com.infobip.test;
+
+import lombok.AllArgsConstructor;
+import org.junit.jupiter.api.Test;
+
+@AllArgsConstructor
+public class QuerydslR2dbcRepositoryTest extends TestBase {
+
+    private final PersonRepository repository;
+
+    @Test
+    void shouldSaveWithVarArgs() {
+        repository.simplePaging("");
+    }
+}

infobip-spring-data-r2dbc-custom-fragment/src/test/java/com/infobip/test/ReactivePagingRepository.java

@@ -0,0 +1,8 @@
+package com.infobip.test;
+
+import reactor.core.publisher.Mono;
+
+public interface ReactivePagingRepository<T> {
+
+    Mono<T> simplePaging(String string);
+}

infobip-spring-data-r2dbc-custom-fragment/src/test/java/com/infobip/test/ReactivePagingRepositoryImpl.java

@@ -0,0 +1,19 @@
+package com.infobip.test;
+
+import com.infobip.spring.data.r2dbc.QuerydslR2dbcFragment;
+import org.springframework.context.annotation.Lazy;
+import reactor.core.publisher.Mono;
+
+public class ReactivePagingRepositoryImpl<T> implements ReactivePagingRepository<T> {
+
+    private final QuerydslR2dbcFragment querydslR2dbcFragment;
+
+    public ReactivePagingRepositoryImpl(@Lazy QuerydslR2dbcFragment querydslR2dbcFragment) {
+        this.querydslR2dbcFragment = querydslR2dbcFragment;
+    }
+
+    @Override
+    public Mono<T> simplePaging(String string) {
+        throw new UnsupportedOperationException();
+    }
+}

infobip-spring-data-r2dbc-custom-fragment/src/test/java/com/infobip/test/TestBase.java

@@ -0,0 +1,48 @@
+package com.infobip.test;
+
+import org.junit.jupiter.api.AfterEach;
+import org.junit.jupiter.api.TestInstance;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.data.repository.reactive.ReactiveCrudRepository;
+import org.springframework.test.context.ActiveProfiles;
+import org.springframework.test.context.TestConstructor;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import java.time.Duration;
+import java.util.List;
+import java.util.stream.Collectors;
+import java.util.stream.Stream;
+
+import static org.junit.jupiter.api.TestInstance.Lifecycle.PER_CLASS;
+
+@ActiveProfiles("mssql")
+@TestConstructor(autowireMode = TestConstructor.AutowireMode.ALL)
+@TestInstance(PER_CLASS)
+@SpringBootTest(classes = Main.class)
+public abstract class TestBase {
+
+    @Autowired
+    private List<ReactiveCrudRepository<?, ?>> repositories;
+
+    @AfterEach
+    public void clearRepositories() {
+        block(Flux.concat(repositories.stream()
+                                      .map(ReactiveCrudRepository::deleteAll)
+                                      .collect(Collectors.toList()))
+                  .collectList());
+    }
+
+    private <T> T block(Mono<T> mono) {
+        return mono.block(Duration.ofSeconds(10));
+    }
+
+    <T> List<T> block(Flux<T> flux) {
+        return block(flux.collectList());
+    }
+
+    protected Mono<Void> given(Mono<?>... ts) {
+        return Flux.concat(Stream.of(ts).collect(Collectors.toList())).last().then();
+    }
+}

infobip-spring-data-r2dbc-custom-fragment/src/test/java/com/infobip/test/TestConfiguration.java

@@ -0,0 +1,26 @@
+package com.infobip.test;
+
+import lombok.AllArgsConstructor;
+import org.flywaydb.core.Flyway;
+import org.springframework.context.annotation.Bean;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.core.env.Environment;
+
+@AllArgsConstructor
+@Configuration
+public class TestConfiguration {
+
+    private final Environment env;
+
+    @Bean(initMethod = "migrate")
+    public Flyway flyway() {
+        return new Flyway(Flyway.configure()
+                                .baselineOnMigrate(true)
+                                  .locations(env.getRequiredProperty("spring.flyway.locations"))
+                                .dataSource(
+                                        env.getRequiredProperty("spring.flyway.url"),
+                                        env.getRequiredProperty("spring.flyway.username"),
+                                        env.getRequiredProperty("spring.flyway.password"))
+        );
+    }
+}

infobip-spring-data-r2dbc-custom-fragment/src/test/resources/application-mssql.yaml

@@ -0,0 +1,6 @@
+spring:
+  r2dbc:
+    url: r2dbc:pool:mssql://<host>:<port>/InfobipSpringDataJdbcQuerydslTest
+  flyway:
+    locations: "classpath:db/migration/mssql"
+    url: jdbc:sqlserver://<host>:<port>;database=InfobipSpringDataJdbcQuerydslTest;trustServerCertificate=true