spring-projects#282 - Add support of 'CONTAINING' conditions

Author: rchigvintsev

Diff for: src/main/java/org/springframework/data/r2dbc/repository/query/ConditionFactory.java

@@ -95,6 +95,7 @@ public Condition createCondition(Part part) {
             }
             case STARTING_WITH:
             case ENDING_WITH:
+            case CONTAINING:
             case LIKE: {
                 Expression pathExpression = createPropertyPathExpression(part.getProperty());
                 BindMarker bindMarker = createBindMarker(parameterMetadataProvider.next(part));

Diff for: src/test/java/org/springframework/data/r2dbc/repository/query/PartTreeR2dbcQueryIntegrationTests.java

@@ -307,6 +307,30 @@ public void prependsLikeOperatorParameterWithPercentSymbolForStartingWithQuery()
         verify(bindSpecMock, times(1)).bind(0, "%hn");
     }
 
+    @Test
+    public void createsQueryToFindAllEntitiesByStringAttributeContaining() throws Exception {
+        R2dbcQueryMethod queryMethod = getQueryMethod("findAllByFirstNameContaining", String.class);
+        PartTreeR2dbcQuery r2dbcQuery = new PartTreeR2dbcQuery(queryMethod, databaseClient, r2dbcConverter,
+                dataAccessStrategy);
+        RelationalParametersParameterAccessor accessor = getAccessor(queryMethod, new Object[] {"oh"});
+        BindableQuery bindableQuery = r2dbcQuery.createQuery(accessor);
+        String expectedSql = "SELECT " + ALL_FIELDS + " FROM " + TABLE + " WHERE " + TABLE + ".first_name LIKE ?";
+        assertThat(bindableQuery.get()).isEqualTo(expectedSql);
+    }
+
+    @SuppressWarnings({"rawtypes", "unchecked"})
+    @Test
+    public void wrapsLikeOperatorParameterWithPercentSymbolsForContainingQuery() throws Exception {
+        R2dbcQueryMethod queryMethod = getQueryMethod("findAllByFirstNameContaining", String.class);
+        PartTreeR2dbcQuery r2dbcQuery = new PartTreeR2dbcQuery(queryMethod, databaseClient, r2dbcConverter,
+                dataAccessStrategy);
+        RelationalParametersParameterAccessor accessor = getAccessor(queryMethod, new Object[] {"hn"});
+        BindableQuery bindableQuery = r2dbcQuery.createQuery(accessor);
+        DatabaseClient.BindSpec bindSpecMock = mock(DatabaseClient.BindSpec.class);
+        bindableQuery.bind(bindSpecMock);
+        verify(bindSpecMock, times(1)).bind(0, "%hn%");
+    }
+
     private R2dbcQueryMethod getQueryMethod(String methodName, Class<?>... parameterTypes) throws Exception {
         Method method = UserRepository.class.getMethod(methodName, parameterTypes);
         return new R2dbcQueryMethod(method, new DefaultRepositoryMetadata(UserRepository.class),
@@ -351,6 +375,8 @@ private interface UserRepository extends Repository<User, Long> {
         Flux<User> findAllByFirstNameStartingWith(String starting);
 
         Flux<User> findAllByFirstNameEndingWith(String ending);
+
+        Flux<User> findAllByFirstNameContaining(String containing);
     }
 
     @Table("users")