diff --git a/spring-data-mongodb/pom.xml b/spring-data-mongodb/pom.xml
index 628b1ec63..0fcdb2f39 100644
--- a/spring-data-mongodb/pom.xml
+++ b/spring-data-mongodb/pom.xml
@@ -59,14 +59,14 @@
- com.mysema.querydsl
+ com.querydsl
querydsl-mongodb
${querydsl}
true
- com.mysema.querydsl
+ com.querydsl
querydsl-apt
${querydsl}
provided
@@ -183,7 +183,7 @@
${apt}
- com.mysema.querydsl
+ com.querydsl
querydsl-apt
${querydsl}
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/MongoAnnotationProcessor.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/MongoAnnotationProcessor.java
index 09006d8ff..aa036659b 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/MongoAnnotationProcessor.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/MongoAnnotationProcessor.java
@@ -1,5 +1,5 @@
/*
- * Copyright 2011-2013 the original author or authors.
+ * Copyright 2011-2015 the original author or authors.
*
* Licensed under the Apache License, Version 2.0 (the "License");
* you may not use this file except in compliance with the License.
@@ -25,14 +25,14 @@ import javax.tools.Diagnostic;
import org.springframework.data.mongodb.core.mapping.Document;
-import com.mysema.query.annotations.QueryEmbeddable;
-import com.mysema.query.annotations.QueryEmbedded;
-import com.mysema.query.annotations.QueryEntities;
-import com.mysema.query.annotations.QuerySupertype;
-import com.mysema.query.annotations.QueryTransient;
-import com.mysema.query.apt.AbstractQuerydslProcessor;
-import com.mysema.query.apt.Configuration;
-import com.mysema.query.apt.DefaultConfiguration;
+import com.querydsl.apt.AbstractQuerydslProcessor;
+import com.querydsl.apt.Configuration;
+import com.querydsl.apt.DefaultConfiguration;
+import com.querydsl.core.annotations.QueryEmbeddable;
+import com.querydsl.core.annotations.QueryEmbedded;
+import com.querydsl.core.annotations.QueryEntities;
+import com.querydsl.core.annotations.QuerySupertype;
+import com.querydsl.core.annotations.QueryTransient;
/**
* Annotation processor to create Querydsl query types for QueryDsl annotated classes.
diff --git a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/QueryDslMongoRepository.java b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/QueryDslMongoRepository.java
index 306db7c45..9f759617c 100644
--- a/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/QueryDslMongoRepository.java
+++ b/spring-data-mongodb/src/main/java/org/springframework/data/mongodb/repository/support/QueryDslMongoRepository.java
@@ -34,12 +34,12 @@ import org.springframework.data.repository.core.EntityInformation;
import org.springframework.data.repository.core.EntityMetadata;
import org.springframework.util.Assert;
-import com.mysema.query.mongodb.MongodbQuery;
-import com.mysema.query.types.EntityPath;
-import com.mysema.query.types.Expression;
-import com.mysema.query.types.OrderSpecifier;
-import com.mysema.query.types.Predicate;
-import com.mysema.query.types.path.PathBuilder;
+import com.querydsl.core.types.EntityPath;
+import com.querydsl.core.types.Expression;
+import com.querydsl.core.types.OrderSpecifier;
+import com.querydsl.core.types.Predicate;
+import com.querydsl.core.types.dsl.PathBuilder;
+import com.querydsl.mongodb.AbstractMongodbQuery;
/**
* Special QueryDsl based repository implementation that allows execution {@link Predicate}s in various forms.
@@ -47,8 +47,8 @@ import com.mysema.query.types.path.PathBuilder;
* @author Oliver Gierke
* @author Thomas Darimont
*/
-public class QueryDslMongoRepository extends SimpleMongoRepository implements
- QueryDslPredicateExecutor {
+public class QueryDslMongoRepository extends SimpleMongoRepository
+ implements QueryDslPredicateExecutor {
private final PathBuilder builder;
private final EntityInformation entityInformation;
@@ -92,7 +92,7 @@ public class QueryDslMongoRepository extends SimpleM
*/
@Override
public T findOne(Predicate predicate) {
- return createQueryFor(predicate).uniqueResult();
+ return createQueryFor(predicate).fetchOne();
}
/*
@@ -101,7 +101,7 @@ public class QueryDslMongoRepository extends SimpleM
*/
@Override
public List findAll(Predicate predicate) {
- return createQueryFor(predicate).list();
+ return createQueryFor(predicate).fetchResults().getResults();
}
/*
@@ -110,7 +110,7 @@ public class QueryDslMongoRepository extends SimpleM
*/
@Override
public List findAll(Predicate predicate, OrderSpecifier>... orders) {
- return createQueryFor(predicate).orderBy(orders).list();
+ return createQueryFor(predicate).orderBy(orders).fetchResults().getResults();
}
/*
@@ -119,7 +119,7 @@ public class QueryDslMongoRepository extends SimpleM
*/
@Override
public List findAll(Predicate predicate, Sort sort) {
- return applySorting(createQueryFor(predicate), sort).list();
+ return applySorting(createQueryFor(predicate), sort).fetchResults().getResults();
}
/*
@@ -128,7 +128,7 @@ public class QueryDslMongoRepository extends SimpleM
*/
@Override
public Iterable findAll(OrderSpecifier>... orders) {
- return createQuery().orderBy(orders).list();
+ return createQuery().orderBy(orders).fetchResults().getResults();
}
/*
@@ -138,10 +138,11 @@ public class QueryDslMongoRepository extends SimpleM
@Override
public Page findAll(Predicate predicate, Pageable pageable) {
- MongodbQuery countQuery = createQueryFor(predicate);
- MongodbQuery query = createQueryFor(predicate);
+ AbstractMongodbQuery> countQuery = createQueryFor(predicate);
+ AbstractMongodbQuery> query = createQueryFor(predicate);
- return new PageImpl(applyPagination(query, pageable).list(), pageable, countQuery.count());
+ return new PageImpl(applyPagination(query, pageable).fetchResults().getResults(), pageable,
+ countQuery.fetchCount());
}
/*
@@ -151,10 +152,11 @@ public class QueryDslMongoRepository extends SimpleM
@Override
public Page findAll(Pageable pageable) {
- MongodbQuery countQuery = createQuery();
- MongodbQuery query = createQuery();
+ AbstractMongodbQuery> countQuery = createQuery();
+ AbstractMongodbQuery> query = createQuery();
- return new PageImpl(applyPagination(query, pageable).list(), pageable, countQuery.count());
+ return new PageImpl(applyPagination(query, pageable).fetchResults().getResults(), pageable,
+ countQuery.fetchCount());
}
/*
@@ -163,7 +165,7 @@ public class QueryDslMongoRepository extends SimpleM
*/
@Override
public List findAll(Sort sort) {
- return applySorting(createQuery(), sort).list();
+ return applySorting(createQuery(), sort).fetchResults().getResults();
}
/*
@@ -172,7 +174,7 @@ public class QueryDslMongoRepository extends SimpleM
*/
@Override
public long count(Predicate predicate) {
- return createQueryFor(predicate).count();
+ return createQueryFor(predicate).fetchCount();
}
/*
@@ -181,7 +183,7 @@ public class QueryDslMongoRepository extends SimpleM
*/
@Override
public boolean exists(Predicate predicate) {
- return createQueryFor(predicate).exists();
+ return createQueryFor(predicate).fetchCount() > 0;
}
/**
@@ -190,7 +192,7 @@ public class QueryDslMongoRepository extends SimpleM
* @param predicate
* @return
*/
- private MongodbQuery createQueryFor(Predicate predicate) {
+ private AbstractMongodbQuery> createQueryFor(Predicate predicate) {
return createQuery().where(predicate);
}
@@ -199,7 +201,7 @@ public class QueryDslMongoRepository extends SimpleM
*
* @return
*/
- private MongodbQuery createQuery() {
+ private AbstractMongodbQuery> createQuery() {
return new SpringDataMongodbQuery(mongoOperations, entityInformation.getJavaType());
}
@@ -210,7 +212,8 @@ public class QueryDslMongoRepository extends SimpleM
* @param pageable
* @return
*/
- private MongodbQuery applyPagination(MongodbQuery query, Pageable pageable) {
+ private AbstractMongodbQuery> applyPagination(
+ AbstractMongodbQuery> query, Pageable pageable) {
if (pageable == null) {
return query;
@@ -227,7 +230,8 @@ public class QueryDslMongoRepository extends SimpleM
* @param sort
* @return
*/
- private MongodbQuery applySorting(MongodbQuery query, Sort sort) {
+ private AbstractMongodbQuery> applySorting(
+ AbstractMongodbQuery> query, Sort sort) {
if (sort == null) {
return query;
@@ -260,7 +264,7 @@ public class QueryDslMongoRepository extends SimpleM
Expression