Fix ArangoCursor#next when performing a dirty read

Author: mpv1989

ChangeLog.md

@@ -6,6 +6,10 @@ The format is based on [Keep a Changelog](http://keepachangelog.com/en/1.0.0/) a
 
 ## [Unreleased]
 
+### Fixed
+
+- fixed `ArangoCursor#next` when performing a dirty read
+
 ## [5.0.0] - 2018-09-18
 
 ### Added

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

@@ -195,7 +195,7 @@ public <T> ArangoCursor<T> query(
 		final Request request = queryRequest(query, bindVars, options);
 		final HostHandle hostHandle = new HostHandle();
 		final CursorEntity result = executor.execute(request, CursorEntity.class, hostHandle);
-		return createCursor(result, type, hostHandle);
+		return createCursor(result, type, options, hostHandle);
 	}
 
 	@Override
@@ -218,23 +218,24 @@ public <T> ArangoCursor<T> query(final String query, final Class<T> type) throws
 	@Override
 	public <T> ArangoCursor<T> cursor(final String cursorId, final Class<T> type) throws ArangoDBException {
 		final HostHandle hostHandle = new HostHandle();
-		final CursorEntity result = executor.execute(queryNextRequest(cursorId), CursorEntity.class, hostHandle);
-		return createCursor(result, type, hostHandle);
+		final CursorEntity result = executor.execute(queryNextRequest(cursorId, null), CursorEntity.class, hostHandle);
+		return createCursor(result, type, null, hostHandle);
 	}
 
 	private <T> ArangoCursor<T> createCursor(
 		final CursorEntity result,
 		final Class<T> type,
+		final AqlQueryOptions options,
 		final HostHandle hostHandle) {
 		final ArangoCursorExecute execute = new ArangoCursorExecute() {
 			@Override
 			public CursorEntity next(final String id) {
-				return executor.execute(queryNextRequest(id), CursorEntity.class, hostHandle);
+				return executor.execute(queryNextRequest(id, options), CursorEntity.class, hostHandle);
 			}
 
 			@Override
 			public void close(final String id) {
-				executor.execute(queryCloseRequest(id), Void.class, hostHandle);
+				executor.execute(queryCloseRequest(id, options), Void.class, hostHandle);
 			}
 		};
 		return cursorInitializer != null ? cursorInitializer.createInstance(this, execute, type, result)

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

@@ -203,12 +203,22 @@ protected Request queryRequest(
 		return request;
 	}
 
-	protected Request queryNextRequest(final String id) {
-		return request(name, RequestType.PUT, PATH_API_CURSOR, id);
+	protected Request queryNextRequest(final String id, final AqlQueryOptions options) {
+		final Request request = request(name, RequestType.PUT, PATH_API_CURSOR, id);
+		final AqlQueryOptions opt = options != null ? options : new AqlQueryOptions();
+		if (opt.getAllowDirtyRead() == Boolean.TRUE) {
+			RequestUtils.allowDirtyRead(request);
+		}
+		return request;
 	}
 
-	protected Request queryCloseRequest(final String id) {
-		return request(name, RequestType.DELETE, PATH_API_CURSOR, id);
+	protected Request queryCloseRequest(final String id, final AqlQueryOptions options) {
+		final Request request = request(name, RequestType.DELETE, PATH_API_CURSOR, id);
+		final AqlQueryOptions opt = options != null ? options : new AqlQueryOptions();
+		if (opt.getAllowDirtyRead() == Boolean.TRUE) {
+			RequestUtils.allowDirtyRead(request);
+		}
+		return request;
 	}
 
 	protected Request explainQueryRequest(