Java: ArangoDB: Replace multiple documents

ArangoCollection interface 'replaceDocuments' method to replace multiple documents in one call.

 

Signature

<T> MultiDocumentEntity<DocumentUpdateEntity<T>> replaceDocuments(Collection<T> values) throws ArangoDBException;
<T> MultiDocumentEntity<DocumentUpdateEntity<T>> replaceDocuments(Collection<T> values, DocumentReplaceOptions options) throws ArangoDBException;

 Replaces multiple documents in the specified collection with the ones in the values, the replaced documents are specified by the _key attributes in the documents in values.

 

'values' defines the the List of documents.

'DocumentReplaceOptions' is used to specify additional options like waitForSync, returnNew, returnOld, silent etc.,

 

Example

 

DocumentReplaceOptions replaceOptions = new DocumentReplaceOptions();
replaceOptions.returnNew(true);
replaceOptions.returnOld(true);
replaceOptions.silent(false);

MultiDocumentEntity<DocumentUpdateEntity<BaseDocument>> updatedDocs = collection.replaceDocuments(docsToReplace, replaceOptions);

 

Find the below working application.

 

DocumentsBulkReplaceDemo.java

 

package com.sample.app;

import java.util.ArrayList;
import java.util.Arrays;
import java.util.Collection;
import java.util.List;

import com.arangodb.ArangoCollection;
import com.arangodb.ArangoCursor;
import com.arangodb.ArangoDB;
import com.arangodb.ArangoDatabase;
import com.arangodb.entity.BaseDocument;
import com.arangodb.entity.DocumentCreateEntity;
import com.arangodb.entity.DocumentUpdateEntity;
import com.arangodb.entity.MultiDocumentEntity;
import com.arangodb.mapping.ArangoJack;
import com.arangodb.model.DocumentCreateOptions;
import com.arangodb.model.DocumentReplaceOptions;

public class DocumentsBulkReplaceDemo {
	private static final String USER_NAME = "root";
	private static final String PASSWORD = "tiger";
	private static final String HOST = "127.0.0.1";
	private static final int PORT = 8529;

	public static void main(String args[]) {
		// Get an ArangoDB instance
		ArangoDB arangoDB = new ArangoDB.Builder().user(USER_NAME).password(PASSWORD).host(HOST, PORT)
				.serializer(new ArangoJack()).build();

		String databaseName = "testdb";
		arangoDB.createDatabase(databaseName);

		ArangoDatabase arangoDatabase = arangoDB.db(databaseName);

		String collectionName = "test1";

		arangoDatabase.createCollection(collectionName);

		ArangoCollection collection = arangoDatabase.collection(collectionName);

		BaseDocument empDocument1 = new BaseDocument();
		empDocument1.addAttribute("firstName", "Krishna");
		empDocument1.addAttribute("lastName", "Gurram");
		empDocument1.addAttribute("hobbies", Arrays.asList("trekking", "playing cricket"));

		BaseDocument empDocument2 = new BaseDocument();
		empDocument2.addAttribute("firstName", "Joel");
		empDocument2.addAttribute("lastName", "Chelli");
		empDocument2.addAttribute("hobbies", Arrays.asList("designing games"));

		DocumentCreateOptions docOptions = new DocumentCreateOptions();
		docOptions.returnNew(true);

		MultiDocumentEntity<DocumentCreateEntity<BaseDocument>> persistedDocs = collection
				.insertDocuments(Arrays.asList(empDocument1, empDocument2), docOptions);
		Collection<DocumentCreateEntity<BaseDocument>> docs = persistedDocs.getDocuments();

		System.out.println("Before replacing");
		for (DocumentCreateEntity<BaseDocument> doc : docs) {
			System.out.println(doc.getNew());
		}

		String query = "FOR c IN " + collectionName + " RETURN c";

		ArangoCursor<BaseDocument> cursor = arangoDatabase.query(query, null, null, BaseDocument.class);

		List<BaseDocument> docsToReplace = new ArrayList<>();

		while (cursor.hasNext()) {
			BaseDocument baseDoc = cursor.next();

			String firstName = (String) baseDoc.getProperties().get("firstName");
			String lastName = (String) baseDoc.getProperties().get("lastName");
			List<String> hobbies = (List<String>) baseDoc.getProperties().get("hobbies");

			BaseDocument tempDoc = new BaseDocument();
			tempDoc.addAttribute("name", "(" + firstName + "," + lastName + ")");
			tempDoc.addAttribute("hobbies", hobbies);

			// you must set the key of a document to replace
			tempDoc.setKey(baseDoc.getKey());

			docsToReplace.add(tempDoc);
		}

		DocumentReplaceOptions replaceOptions = new DocumentReplaceOptions();
		replaceOptions.returnNew(true);
		replaceOptions.returnOld(true);
		replaceOptions.silent(false);

		MultiDocumentEntity<DocumentUpdateEntity<BaseDocument>> updatedDocs = collection.replaceDocuments(docsToReplace,
				replaceOptions);

		Collection<DocumentUpdateEntity<BaseDocument>> updatedDocColl = updatedDocs.getDocuments();

		System.out.println("\nAfter replacing");
		for (DocumentUpdateEntity<BaseDocument> updatedDoc : updatedDocColl) {
			System.out.println(updatedDoc.getNew());
		}
		// Dropping the collection and database
		collection.drop();
		arangoDatabase.drop();
		System.exit(0);

	}
}

 

Output

Before replacing
BaseDocument [documentRevision=_cS6E7Ky---, documentHandle=test1/64855, documentKey=64855, properties={firstName=Krishna, lastName=Gurram, hobbies=[trekking, playing cricket]}]
BaseDocument [documentRevision=_cS6E7Ky--A, documentHandle=test1/64856, documentKey=64856, properties={firstName=Joel, lastName=Chelli, hobbies=[designing games]}]

After replacing
BaseDocument [documentRevision=_cS6E7Mi---, documentHandle=test1/64855, documentKey=64855, properties={name=(Krishna,Gurram), hobbies=[trekking, playing cricket]}]
BaseDocument [documentRevision=_cS6E7Mi--A, documentHandle=test1/64856, documentKey=64856, properties={name=(Joel,Chelli), hobbies=[designing games]}]

 

 

Previous                                                    Next                                                    Home