|
34 | 34 | import java.util.concurrent.Future;
|
35 | 35 | import java.util.stream.Collectors;
|
36 | 36 |
|
| 37 | +import com.couchbase.client.java.query.QueryScanConsistency; |
37 | 38 | import org.junit.jupiter.api.BeforeEach;
|
38 | 39 | import org.junit.jupiter.api.Test;
|
39 | 40 | import org.springframework.beans.factory.annotation.Autowired;
|
|
42 | 43 | import org.springframework.data.couchbase.CouchbaseClientFactory;
|
43 | 44 | import org.springframework.data.couchbase.config.AbstractCouchbaseConfiguration;
|
44 | 45 | import org.springframework.data.couchbase.core.CouchbaseTemplate;
|
| 46 | +import org.springframework.data.couchbase.core.query.QueryCriteria; |
45 | 47 | import org.springframework.data.couchbase.domain.Address;
|
46 | 48 | import org.springframework.data.couchbase.domain.Airport;
|
47 | 49 | import org.springframework.data.couchbase.domain.AirportRepository;
|
@@ -317,12 +319,12 @@ void deleteAllById() {
|
317 | 319 | void couchbaseRepositoryQuery() throws Exception {
|
318 | 320 | User user = new User("1", "Dave", "Wilson");
|
319 | 321 | userRepository.save(user);
|
| 322 | + couchbaseTemplate.findByQuery(User.class).withConsistency(QueryScanConsistency.REQUEST_PLUS).matching(QueryCriteria.where("firstname").is("Dave").and("`1`").is("`1`")).all(); |
320 | 323 | String input = "findByFirstname";
|
321 | 324 | Method method = UserRepository.class.getMethod(input, String.class);
|
322 | 325 | CouchbaseQueryMethod queryMethod = new CouchbaseQueryMethod(method,
|
323 | 326 | new DefaultRepositoryMetadata(UserRepository.class), new SpelAwareProxyProjectionFactory(),
|
324 | 327 | couchbaseTemplate.getConverter().getMappingContext());
|
325 |
| - |
326 | 328 | CouchbaseRepositoryQuery query = new CouchbaseRepositoryQuery(couchbaseTemplate, queryMethod, null);
|
327 | 329 | List<User> users = (List<User>)query.execute(new String[] { "Dave" });
|
328 | 330 | assertEquals(user, users.get(0));
|
|
0 commit comments