get/clear slow queries

Author: Mark

src/main/java/com/arangodb/ArangoDatabase.java

@@ -718,6 +718,65 @@ private Request getCurrentlyRunningQueriesRequest() {
 		return new Request(name, RequestType.GET, ArangoDBConstants.PATH_API_QUERY_CURRENT);
 	}
 
+	/**
+	 * Returns a list of slow running AQL queries
+	 * 
+	 * @see <a href=
+	 *      "https://docs.arangodb.com/current/HTTP/AqlQuery/index.html#returns-the-list-of-slow-aql-queries">API
+	 *      Documentation</a>
+	 * @return a list of slow running AQL queries
+	 * @throws ArangoDBException
+	 */
+	public Collection<QueryEntity> getSlowQueries() throws ArangoDBException {
+		return executeSync(getSlowQueriesRequest(), new Type<Collection<QueryEntity>>() {
+		}.getType());
+	}
+
+	/**
+	 * Returns a list of slow running AQL queries
+	 * 
+	 * @see <a href=
+	 *      "https://docs.arangodb.com/current/HTTP/AqlQuery/index.html#returns-the-list-of-slow-aql-queries">API
+	 *      Documentation</a>
+	 * @return a list of slow running AQL queries
+	 */
+	public CompletableFuture<Collection<QueryEntity>> getSlowQueriesAsync() {
+		return executeAsync(getSlowQueriesRequest(), new Type<Collection<QueryEntity>>() {
+		}.getType());
+	}
+
+	private Request getSlowQueriesRequest() {
+		return new Request(name, RequestType.GET, ArangoDBConstants.PATH_API_QUERY_SLOW);
+	}
+
+	/**
+	 * Clears the list of slow AQL queries
+	 * 
+	 * @see <a href=
+	 *      "https://docs.arangodb.com/current/HTTP/AqlQuery/index.html#clears-the-list-of-slow-aql-queries">API
+	 *      Documentation</a>
+	 * @throws ArangoDBException
+	 */
+	public void clearSlowQueries() throws ArangoDBException {
+		executeSync(clearSlowQueriesRequest(), Void.class);
+	}
+
+	/**
+	 * Clears the list of slow AQL queries
+	 * 
+	 * @see <a href=
+	 *      "https://docs.arangodb.com/current/HTTP/AqlQuery/index.html#clears-the-list-of-slow-aql-queries">API
+	 *      Documentation</a>
+	 * @return void
+	 */
+	public CompletableFuture<Void> clearSlowQueriesAsync() {
+		return executeAsync(clearSlowQueriesRequest(), Void.class);
+	}
+
+	private Request clearSlowQueriesRequest() {
+		return new Request(name, RequestType.DELETE, ArangoDBConstants.PATH_API_QUERY_SLOW);
+	}
+
 	/**
 	 * Create a new AQL user function
 	 * 

src/main/java/com/arangodb/internal/ArangoDBConstants.java

@@ -51,6 +51,7 @@ public class ArangoDBConstants {
 	public static final String PATH_API_QUERY_CACHE_PROPERTIES = "/_api/query-cache/properties";
 	public static final String PATH_API_QUERY_PROPERTIES = "/_api/query/properties";
 	public static final String PATH_API_QUERY_CURRENT = "/_api/query/current";
+	public static final String PATH_API_QUERY_SLOW = "/_api/query/slow";
 	public static final String PATH_API_TRAVERSAL = "/_api/traversal";
 
 	public static final String ENCRYPTION_PLAIN = "plain";

src/test/java/com/arangodb/ArangoDatabaseTest.java

@@ -587,6 +587,29 @@ public void getCurrentlyRunningQueries() throws InterruptedException, ExecutionE
 		}
 	}
 
+	@Test
+	public void getAndClearSlowQueries() throws InterruptedException, ExecutionException {
+		final QueryTrackingPropertiesEntity properties = db.getQueryTrackingProperties();
+		final Long slowQueryThreshold = properties.getSlowQueryThreshold();
+		try {
+			properties.setSlowQueryThreshold(1L);
+			db.setQueryTrackingProperties(properties);
+
+			db.query("return sleep(1.1)", null, null, Void.class);
+			final Collection<QueryEntity> slowQueries = db.getSlowQueries();
+			assertThat(slowQueries, is(notNullValue()));
+			assertThat(slowQueries.size(), is(1));
+			final QueryEntity queryEntity = slowQueries.stream().findFirst().get();
+			assertThat(queryEntity.getQuery(), is("return sleep(1.1)"));
+
+			db.clearSlowQueries();
+			assertThat(db.getSlowQueries().size(), is(0));
+		} finally {
+			properties.setSlowQueryThreshold(slowQueryThreshold);
+			db.setQueryTrackingProperties(properties);
+		}
+	}
+
 	@Test
 	public void createGetDeleteAqlFunction() {
 		final Collection<AqlFunctionEntity> aqlFunctionsInitial = db.getAqlFunctions(null);