diff --git a/src/main/java/org/springframework/data/couchbase/repository/query/AbstractN1qlBasedQuery.java b/src/main/java/org/springframework/data/couchbase/repository/query/AbstractN1qlBasedQuery.java index d092c1a7..cf4c4022 100644 --- a/src/main/java/org/springframework/data/couchbase/repository/query/AbstractN1qlBasedQuery.java +++ b/src/main/java/org/springframework/data/couchbase/repository/query/AbstractN1qlBasedQuery.java @@ -21,6 +21,8 @@ import java.util.List; import com.couchbase.client.java.document.json.JsonArray; import com.couchbase.client.java.query.Query; import com.couchbase.client.java.query.Statement; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.data.couchbase.core.CouchbaseOperations; import org.springframework.data.repository.query.ParameterAccessor; @@ -35,6 +37,8 @@ import org.springframework.data.util.StreamUtils; */ public abstract class AbstractN1qlBasedQuery implements RepositoryQuery { + private static final Logger LOG = LoggerFactory.getLogger(AbstractN1qlBasedQuery.class); + protected final CouchbaseQueryMethod queryMethod; private final CouchbaseOperations couchbaseOperations; @@ -67,6 +71,10 @@ public abstract class AbstractN1qlBasedQuery implements RepositoryQuery { query = Query.simple(statement); } + if (LOG.isDebugEnabled()) { + LOG.debug("Executing N1QL query: " + query.n1ql()); + } + return query; } diff --git a/src/main/java/org/springframework/data/couchbase/repository/query/ViewBasedCouchbaseQuery.java b/src/main/java/org/springframework/data/couchbase/repository/query/ViewBasedCouchbaseQuery.java index 67d60de4..0dec6b59 100644 --- a/src/main/java/org/springframework/data/couchbase/repository/query/ViewBasedCouchbaseQuery.java +++ b/src/main/java/org/springframework/data/couchbase/repository/query/ViewBasedCouchbaseQuery.java @@ -22,6 +22,8 @@ import com.couchbase.client.java.document.json.JsonObject; import com.couchbase.client.java.view.ViewQuery; import com.couchbase.client.java.view.ViewResult; import com.couchbase.client.java.view.ViewRow; +import org.slf4j.Logger; +import org.slf4j.LoggerFactory; import org.springframework.data.couchbase.core.CouchbaseOperations; import org.springframework.data.couchbase.core.CouchbaseQueryExecutionException; @@ -40,6 +42,8 @@ import org.springframework.util.StringUtils; */ public class ViewBasedCouchbaseQuery implements RepositoryQuery { + private static final Logger LOG = LoggerFactory.getLogger(ViewBasedCouchbaseQuery.class); + private final CouchbaseQueryMethod method; private final CouchbaseOperations operations; @@ -99,10 +103,16 @@ public class ViewBasedCouchbaseQuery implements RepositoryQuery { } protected Object execute(ViewQuery query) { + if (LOG.isDebugEnabled()) { + LOG.debug("Executing view query: " + query.toString()); + } return operations.findByView(query, method.getEntityInformation().getJavaType()); } protected Object executeReduce(ViewQuery query, String designDoc, String viewName) { + if (LOG.isDebugEnabled()) { + LOG.debug("Executing view reduced query: " + query.toString()); + } ViewResult viewResult = operations.queryView(query); List allRows = viewResult.allRows(); JsonObject error = viewResult.error(); diff --git a/src/test/resources/logback.xml b/src/test/resources/logback.xml index 6b4d4d87..fcbb76c9 100644 --- a/src/test/resources/logback.xml +++ b/src/test/resources/logback.xml @@ -15,4 +15,6 @@ + + \ No newline at end of file