Spring/spring-data-couchbase
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

DATACOUCH-143 - Log executed queries in DEBUG.

Browse Source
This commit is contained in:
Simon Baslé
2015-07-16 16:48:45 +02:00
parent 4b453d4246
commit 4f0ba9d215
3 changed files with 20 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
src/main/java/org/springframework/data/couchbase/repository/query/AbstractN1qlBasedQuery.java
View File

@@ -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;
}

10
src/main/java/org/springframework/data/couchbase/repository/query/ViewBasedCouchbaseQuery.java
View File

@@ -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<ViewRow> allRows = viewResult.allRows();
JsonObject error = viewResult.error();