¿Cómo pasar documentos de MongoDB a Couchbase?

Este pseudocódigo:

getMongoCollectionStream().fromMongoDocumentToCouchbaseDocuments().writeCBdocToCouchbase()

Se traduce en:

MongoClient client = MongoClients.create(connectionString);
 MongoDatabase db = client.getDatabase(dbName);
 Observable<org.bson.Document> mongoDocs = db.getCollection(collectionName).find();

db.getCollection(collectionName).find().toObservable()

.map(new Func1<org.bson.Document, Document>() {

public Document call(org.bson.Document mongoDoc) {

mongoDoc.put(typeField, type);

RawJsonDocument d = RawJsonDocument.create(mongoDoc

.getObjectId("_id").toHexString(), mongoDoc

.toJson());

return d;

};

}).map(asyncBucket.upsert(doc));;

Leer más

Responder

Introduce tus datos o haz clic en un icono para iniciar sesión:

Logo de WordPress.com

Estás comentando usando tu cuenta de WordPress.com. Cerrar sesión / Cambiar )

Imagen de Twitter

Estás comentando usando tu cuenta de Twitter. Cerrar sesión / Cambiar )

Foto de Facebook

Estás comentando usando tu cuenta de Facebook. Cerrar sesión / Cambiar )

Google+ photo

Estás comentando usando tu cuenta de Google+. Cerrar sesión / Cambiar )

Conectando a %s

A %d blogueros les gusta esto: