Todo el c\u00f3digo de este blog est\u00e1 disponible en el siguiente repositorio Git: mongodb-to-couchbase<\/a>.<\/p>\n Un cl\u00faster Couchbase que contenga el conjunto de datos seg\u00fan los detalles del art\u00edculo anterior<\/a>.<\/p>\n Antes de que un cliente (aplicaci\u00f3n) pueda conectarse al cluster del Servidor Couchbase es necesario definir un usuario de aplicaci\u00f3n que se utiliza para la autenticaci\u00f3n por parte del cliente. Couchbase Control de acceso basado en funciones<\/a> le permite definir usuarios y asignarles las funciones adecuadas. Utilice la consola web para crear un usuario de aplicaci\u00f3n denominado mflix_client<\/strong> como sigue.<\/p>\n Ir a la Seguridad<\/strong> en la consola web y haga clic en A\u00d1ADIR USUARIO<\/strong>:<\/p>\n Configure el mflix_client<\/strong> usuario de la siguiente manera y haga clic en A\u00f1adir usuario<\/strong>:<\/p>\n En el Seguridad<\/strong> ver\u00e1s el nuevo usuario mflix_client:<\/p>\n \u00cdndices secundarios<\/a> en Couchbase Server soportan la ejecuci\u00f3n eficiente de consultas (o b\u00fasquedas secundarias) al igual que los \u00edndices en MongoDB. Los ejemplos de c\u00f3digo en este art\u00edculo ejecutan Consultas N1QL<\/a> que utilizan dos \u00edndices que crear\u00e1s ejecutando consultas N1QL. Vaya a la p\u00e1gina Consulta<\/strong> en la consola web:<\/p>\n El primer \u00edndice est\u00e1 en el atributo name de todos los documentos de comentarios del bucket sample_mflix. Introduzca la siguiente sentencia N1QL en el archivo Editor de consultas:<\/strong><\/p>\n Haga clic en Ejecute<\/strong> y despu\u00e9s de unos momentos el creaci\u00f3n de \u00edndices<\/a> est\u00e1 completo:<\/p>\n El segundo \u00edndice se basa en los atributos year, imdb.rating y title de todos los documentos de pel\u00edculas del bucket sample_mflix. Introduzca la siguiente sentencia N1QL en el archivo Editor de consultas<\/strong>:<\/p>\n Haga clic en Ejecute<\/strong> y al cabo de unos instantes se habr\u00e1 completado la creaci\u00f3n del \u00edndice:<\/p>\n Ir a la \u00cdndices<\/strong> en la consola web para verificar que los \u00edndices idx1<\/strong> & idx2<\/strong> existe:<\/p>\n El c\u00f3digo de ejemplo de este art\u00edculo utiliza los SDK Java de Couchbase y MongoDB y se proporciona s\u00f3lo como ejemplo de c\u00f3mo utilizar algunas de las API del SDK. Consulta los siguientes enlaces para obtener la documentaci\u00f3n completa del SDK de Couchbase para tu idioma:<\/p>\n Para acceder a los recursos del cl\u00faster, los clientes deben autentifique<\/a> pasando las credenciales apropiadas a Couchbase Server. El c\u00f3digo de ejemplo utiliza las credenciales de usuario de la aplicaci\u00f3n mflix_client creadas anteriormente para autenticar.<\/p>\n El siguiente ejemplo de c\u00f3digo se conecta al cluster de Couchbase que se ejecuta en el nodo especificado, obtiene una referencia al bucket mflix_client, y una referencia a la colecci\u00f3n por defecto en ese bucket.<\/p>\n Couchbase<\/u><\/p>\n MongoDB<\/u><\/p>\n Utiliza el Colecci\u00f3n.get()<\/strong> para recuperar documentos completos<\/a> por ID. El siguiente ejemplo de c\u00f3digo recupera dos documentos de la colecci\u00f3n predeterminada del bucket sample_mflix.<\/p>\n Couchbase<\/u><\/p>\n MongoDB<\/u><\/p>\n Utiliza el Colecci\u00f3n.insertar()<\/strong> para crear un nuevo documento<\/a> con el ID y el contenido especificados si a\u00fan no existe. El siguiente ejemplo de c\u00f3digo inserta este documento en la colecci\u00f3n predeterminada del bucket sample_mflix:<\/p>\n Couchbase<\/u><\/p>\n MongoDB<\/u><\/p>\n Operaciones de dosificaci\u00f3n<\/a> le permite aprovechar mejor su red y acelerar su aplicaci\u00f3n aumentando el rendimiento de la red y reduciendo la latencia. Las operaciones por lotes funcionan mediante\u00a0pipelining<\/em>\u00a0a trav\u00e9s de la red. Cuando las solicitudes se canalizan, se env\u00edan en un gran grupo al cl\u00faster. El cl\u00faster, a su vez\u00a0tuber\u00edas<\/em>\u00a0al cliente.<\/p>\n El siguiente ejemplo de c\u00f3digo utiliza este enfoque para insertar dos nuevos documentos en el bucket sample_mflix.<\/p>\n Couchbase<\/u><\/p>\n MongoDB<\/u><\/p>\n Utiliza el Colecci\u00f3n.reemplazar()<\/strong> para actualizar un documento existente<\/a> con el ID especificado s\u00f3lo si ya existe. Couchbase admite operaciones con subdocumentos<\/a> que puede utilizarse para acceder eficazmente a\u00a0piezas<\/em>\u00a0de documentos. Las operaciones con subdocumentos pueden ser m\u00e1s r\u00e1pidas y eficientes en red que\u00a0documento completo\u00a0<\/em>porque s\u00f3lo transmiten por la red las secciones del documento a las que se ha accedido. Las operaciones con documentos completos y subdocumentos son at\u00f3micas, lo que permite realizar modificaciones seguras en los documentos con control de concurrencia incorporado.<\/p>\n El siguiente ejemplo de c\u00f3digo utiliza operaciones de subdocumento para actualizar el atributo de texto de un documento especificado.<\/p>\n Couchbase<\/u><\/p>\n MongoDB<\/u><\/p>\n Adem\u00e1s del acceso primario mediante API de clave\/valor, tambi\u00e9n puede ejecutar consultas N1QL<\/a> a trav\u00e9s de las API N1QL. N1QL<\/a> es un lenguaje declarativo para consultar, transformar y manipular datos JSON - piensa en SQL para JSON.<\/p>\n El siguiente ejemplo de c\u00f3digo ejecuta una consulta N1QL para actualizar los atributos de nombre y correo electr\u00f3nico de todos los documentos de comentarios cuyo nombre sea Anat Chase. Esta consulta utiliza el atributo idx1<\/strong> creado anteriormente.<\/p>\n Couchbase<\/u><\/p>\n MongoDB<\/u><\/p>\n Utiliza el Colecci\u00f3n.upsert()<\/strong> para insertar el documento si no existe, o sustituirlo si existe<\/a>. Si no existe un documento con el ID especificado, upsert() crear\u00e1 un nuevo documento. Si existe un documento con el ID especificado, upsert() actualizar\u00e1 el documento existente. El siguiente ejemplo de c\u00f3digo actualiza un documento existente en el bucket sample_mflix.<\/p>\n Couchbase<\/u><\/p>\n MongoDB<\/u><\/p>\n Utiliza el Colecci\u00f3n.eliminar()<\/strong> para eliminar un documento completo<\/a> con el ID especificado. El siguiente ejemplo de c\u00f3digo elimina un documento existente del bucket sample_mflix.<\/p>\n Couchbase<\/u><\/p>\n MongoDB<\/u><\/p>\n Tambi\u00e9n puede utilizar consultas N1QL para eliminar documentos. El siguiente ejemplo de c\u00f3digo ejecuta una consulta N1QL para eliminar varios documentos del bucket sample_mflix. Se eliminar\u00e1n todos los documentos de comentarios cuyo nombre sea Anita Chase. Esta consulta utiliza el m\u00e9todo idx1<\/strong> creado anteriormente.<\/p>\n Couchbase<\/u><\/p>\n MongoDB<\/u><\/p>\n N1QL tambi\u00e9n puede utilizarse para realizar b\u00fasquedas secundarias de datos m\u00e1s complicadas. El siguiente ejemplo de c\u00f3digo ejecuta una consulta N1QL de bloqueo para seleccionar el t\u00edtulo, el a\u00f1o y la calificaci\u00f3n imdb de todos los documentos de pel\u00edculas cuyo a\u00f1o est\u00e9 comprendido entre 1970 y 1979, ordenados por la calificaci\u00f3n imdb. La consulta utiliza el m\u00e9todo idx2<\/strong> creado anteriormente.<\/p>\n Similar a operaciones reactivas clave\/valor por lotes<\/a>, consultas reactivas y as\u00edncronas<\/a> para un mejor rendimiento.<\/p>\n Couchbase<\/u><\/p>\n MongoDB<\/u><\/p>\n Explore las otras capacidades del SDK de Couchbase incluyendo Anal\u00edtica<\/a> y B\u00fasqueda de texto completo<\/a>. Aproveche nuestra formaci\u00f3n gratuita en l\u00ednea disponible en https:\/\/learn.couchbase.com<\/a> para obtener m\u00e1s informaci\u00f3n sobre Couchbase.<\/p>\n Para obtener informaci\u00f3n detallada sobre las ventajas arquitect\u00f3nicas de la plataforma de datos Couchbase sobre MongoDB, consulte este documento: Couchbase: Mejor que MongoDB en todos los sentidos<\/a>.<\/p>\n Descubra por qu\u00e9 otras empresas eligen Couchbase en lugar de MongoDB:<\/p>\n <\/p>","protected":false},"excerpt":{"rendered":" Prolog The previous article provided details on how to migrate a MongoDB data set to Couchbase Server. This article shows you how to use the Couchbase SDK to access the data via a Java console application. Code snippets show how […]<\/p>","protected":false},"author":1352,"featured_media":7289,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"inline_featured_image":false,"footnotes":""},"categories":[1815,1816,1818,1812,2201],"tags":[2378,1393,1505,1309],"ppma_author":[9091],"class_list":["post-7770","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-best-practices-and-tutorials","category-couchbase-server","category-java","category-n1ql-query","category-tools-sdks","tag-6-5","tag-api","tag-index","tag-mongodb"],"acf":[],"yoast_head":"\nRequisitos previos<\/h2>\n
Crear un usuario de aplicaci\u00f3n<\/h2>\n
![\"\"](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2019\/10\/01.-Security-no-users.png\")
<\/p>\n\n
![\"\"](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2019\/10\/02.-mflix_client-user.png\")
<\/p>\n![\"\"](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2019\/10\/03.-Security-1-user.png\")
<\/p>\nCreaci\u00f3n de \u00edndices para consultas N1QL<\/h2>\n
![\"\"](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2019\/10\/04.-Query-workbench.png\")
<\/p>\nCREATE INDEX idx1 on muestra_mflix(nombre) WHERE type=\"comentario\"<\/pre>\n
![\"\"](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2019\/10\/05.-Create-index-idx1-statement.png\")
<\/p>\n![\"\"](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2019\/10\/06.-Create-index-idx1-complete.png\")
<\/p>\nCREATE INDEX idx2 on sample_mflix(a\u00f1o, imdb.rating, t\u00edtulo) WHERE type=\"pel\u00edcula\"<\/pre>\n
![\"\"](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2019\/10\/07.-Create-index-idx2-statement.png\")
<\/p>\n![\"\"](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2019\/10\/08.-Create-index-idx2-complete.png\")
<\/p>\n![\"\"](\"https:\/\/www.couchbase.com\/blog\/wp-content\/uploads\/2019\/10\/09.-Index-list-2-indexes.png\")
<\/p>\nConvertir llamadas API de MongoDB en llamadas API de Couchbase<\/h2>\n
\n
Conectarse a Couchbase Server<\/h3>\n
Cluster cluster = Cluster.connect(\"127.0.0.1\", \"mflix_client\", \"password\");\r\nBucket bucket = cluster.bucket(\"sample_mflix\");\r\nColecci\u00f3n colecci\u00f3n = bucket.defaultCollection();<\/pre>\n
MongoClient mongoClient = MongoClients.create(\"mongodb+srv:\/\/:@\/ \");\r\nMongoDatabase mongoDatabase = mongoClient.getDatabase(\"sample_mflix\");\r\nMongoCollection comments = mongoDatabase.getCollection(\"comments\");\r\nMongoCollection movies = mongoDatabase.getCollection(\"movies\");<\/pre>\n
Recuperar un documento por ID<\/h3>\n
\/\/ get() lanzar\u00e1 una excepci\u00f3n si no existe un documento con el ID especificado\r\nGetResult comment = collection.get(\"comment:5a9427648b0beebeb69579cc\");\r\nSystem.out.println(comment.contentAsObject());\r\n\r\nGetResult movie = collection.get(\"movie:573a1390f29313caabcd4135\");\r\nSystem.out.println(movie.contentAsObject());<\/pre>\n
comments.find(Filters.eq(\"_id\", new ObjectId(\"5a9427648b0beebeb69579cc\"));\r\nmovies.find(Filters.eq(\"_id\", new ObjectId(\"573a1390f29313caabcd4135\")));<\/pre>\n
Insertar un nuevo documento<\/h3>\n
{\r\n \"nombre\": \"Anat Chase\",\r\n \"email\": \"anat_chase@fakegmail.com\",\r\n \"movie_id\":\"movie:573a1390f29313caabcd4135\",\r\n \"text\": \"Esta es la cr\u00edtica de Anat\",\r\n \"type\": \"comment\"\r\n}<\/pre>\nJsonObject doc = JsonObject.create()\r\n .put(\"nombre\", \"Anat Chase\")\r\n .put(\"email\", \"anat_chase@fakegmail.com\")\r\n .put(\"movie_id\", \"movie:573a1390f29313caabcd4135\")\r\n .put(\"text\", \"Esta es la rese\u00f1a de Anat\")\r\n .put(\"type\", \"comment\");\r\n\r\n\/\/ insert() lanzar\u00e1 una excepci\u00f3n si ya existe un documento con el ID especificado\r\ncollection.insert(\"comment:5a9427648b0beebeb69579c0\", doc);<\/pre>\n
Document doc = new Document(\"_id\", new ObjectId(\"5a9427648b0beebeb69579c0\"))\r\n .append(\"nombre\", \"Anat Chase\")\r\n .append(\"email\", \"anat_chase@fakegmail.com\")\r\n .append(\"movie_id\", new ObjectId(\"573a1390f29313caabcd4135\"))\r\n .append(\"text\", \"Esta es la rese\u00f1a de Anat\");\r\n\r\ncomments.insertOne(doc);<\/pre>\n
Insertar varios documentos nuevos<\/h3>\n
\/\/ Crear dos documentos JSON\r\nList<Tuple2> documents = new ArrayList<Tuple2>();\r\ndoc = JsonObject.create()\r\n .put(\"nombre\", \"Anat Chase\")\r\n .put(\"email\", \"anat_chase@fakegmail.com\")\r\n .put(\"movie_id\", \"movie:573a1390f29313caabcd42e8\")\r\n .put(\"text\", \"Esta es la rese\u00f1a de Anat\")\r\n .put(\"tipo\", \"comentario\");\r\ndocuments.add(Tuples.of(\"comentario:5a9427648b0beebeb69579c1\", doc));\r\n\r\nJsonObject doc2 = JsonObject.create()\r\n .put(\"nombre\", \"Anat Chase\")\r\n .put(\"email\", \"anat_chase@fakegmail.com\")\r\n .put(\"movie_id\", \"movie:573a1390f29313caabcd4323\")\r\n .put(\"text\", \"Esta es la rese\u00f1a de Anat\")\r\n .put(\"tipo\", \"comentario\");\r\ndocuments.add(Tuples.of(\"comentario:5a9427648b0beebeb69579c2\", doc2));\r\n\r\n\/\/ Inserta los 2 documentos en un lote, esperando hasta que el \u00faltimo haya terminado.\r\n\/\/ insert() lanzar\u00e1 una excepci\u00f3n si ya existe un documento con el ID especificado\r\nFlujo\r\n .fromIterable(documentos)\r\n .parallel().runOn(Schedulers.elastic())\r\n .concatMap(doc3 -> reactiveCollection.insert(doc3.getT1(), doc3.getT2())\r\n .onErrorResume(e -> Mono.error(new Exception(doc3.getT1(), e))))\r\n .secuencial().collectList().block();<\/pre>\n
List documents = new ArrayList();\r\nDocument doc1 = new Document(\"_id\", new ObjectId(\"5a9427648b0beebeb69579c1\"))\r\n .append(\"nombre\", \"Anat Chase\")\r\n .append(\"email\", \"anat_chase@fakegmail.com\")\r\n .append(\"movie_id\", new ObjectId(\"573a1390f29313caabcd42e8\"))\r\n .append(\"text\", \"Esta es la rese\u00f1a de Anat\");\r\ndocuments.add(doc1);\r\n\r\nDocument doc2 = new Document(\"_id\", new ObjectId(\"5a9427648b0beebeb69579c2\"))\r\n .append(\"nombre\", \"Anat Chase\")\r\n .append(\"email\", \"anat_chase@fakegmail.com\")\r\n .append(\"movie_id\", new ObjectId(\"573a1390f29313caabcd4323\"))\r\n .append(\"text\", \"Esta es la rese\u00f1a de Anat\");\r\ndocuments.add(doc2);\r\n\r\ncomments.insertMany(documentos);<\/pre>\n
Actualizar un documento existente<\/h3>\n
\/\/ Actualizar un documento utilizando la API de subdocumentos para modificar los atributos espec\u00edficos\r\n\/\/ replace() lanzar\u00e1 una excepci\u00f3n si no existe un documento con el ID especificado\r\ncollection.mutateIn(\r\n \"comment:5a9427648b0beebeb69579c0\",\r\n Arrays.asList(replace(\"texto\", \"Esta no es la rese\u00f1a de Anat\"));<\/pre>\n
comments.updateOne(\r\n Filters.eq(\"_id\", new ObjectId(\"5a9427648b0beebeb69579c0\")),\r\n Updates.combine(Updates.set(\"text\", \"\")));<\/pre>\n
Actualizar varios documentos<\/h3>\n
\/\/ ejecutar una consulta N1QL UPDATE a trav\u00e9s de la API de consulta\r\nString statement =\r\n \"UPDATE sample_mflix \" +\r\n \"SET name='Anita Chase', email='anita_chase@fakegmail.com' \" +\r\n \"WHERE type='comment' AND name='Anat Chase'\";\r\nQueryResult updateResult = cluster.query(statement);\r\n<\/pre>\n
comentarios.updateMany(\r\n Filters.eq(\"nombre\", \"Anat Chase\"),\r\n Updates.combine(\r\n Updates.set(\"nombre\", \"Anita Chase\"),\r\n Updates.set(\"email\", \"anita_chase@fakegmail.com\")));<\/pre>\n
Actualizar o insertar un documento<\/h3>\n
doc = JsonObject.create()\r\n .put(\"nombre\", \"Mia Hannas\")\r\n .put(\"email\", \"mia_hannas@fakegmail.com\")\r\n .put(\"movie_id\", \"movie:573a1390f29313caabcd4135\")\r\n .put(\"text\", \"Esta es la rese\u00f1a de Mia\")\r\n .put(\"type\", \"comment\");\r\n\r\n\/\/ upsert() actualizar\u00e1 el documento si existe o insertar\u00e1 el documento si no existe\r\ncollection.upsert(\"comment:5a9427648b0beebeb69579c0\", doc);<\/pre>\n
collection.replaceOne(\r\n Filters.eq(\"_id\", new ObjectId(\"5a9427648b0beebeb69579c0\")),\r\n new Document(\"nombre\", \"Mia Hannas\")\r\n .append(\"email\", \"mia_hannas@fakegmail.com\")\r\n .append(\"movie_id\", new ObjectId(\"573a1390f29313caabcd4135\"))\r\n .append(\"text\", \"Esta es la cr\u00edtica de Mia\"),\r\n new UpdateOptions().upsert(true));<\/pre>\n
Borrar un documento<\/h3>\n
\/\/ remove() lanzar\u00e1 una excepci\u00f3n si el documento no existe\r\ncollection.remove(\"comment:5a9427648b0beebeb69579c0\");<\/pre>\n
collection.deleteOne(Filters.eq(\"_id\", new ObjectId(\"5a9427648b0beebeb69579c0\"));<\/pre>\n
Borrar varios documentos<\/h3>\n
\/\/ ejecuta una consulta DELETE N1QL a trav\u00e9s de la API de consultas\r\nString statement = \"DELETE FROM muestra_mflix \" +\r\n \"WHERE type='comment' AND name='Anita Chase'\";\r\n\r\nQueryResult deleteResult = cluster.query(statement);<\/pre>\n
comments.deleteMany(Filters.eq(\"nombre\", \"Anita Chase\"));<\/pre>\n
Acceso a datos con N1QL<\/h3>\n
\/\/ ejecutar una consulta SELECT N1QL (bloqueo) a trav\u00e9s de la API de consulta\r\nString selectStatement = \"SELECT title, year, imdb.rating FROM sample_mflix \" +\r\n \"WHERE type='movie' AND year BETWEEN 1970 AND 1979 ORDER BY imdb.rating DESC\";\r\n\r\nfinal QueryResult selectResult = cluster.query(selectStatement);\r\nfor (JsonObject row : selectResult.rowsAsObject()) {\r\n System.out.println(row.toString());\r\n}\r\n<\/pre>\nmovies.find(Filtros.and(Filtros.gte(\"a\u00f1o\", 1970), Filtros.lte(\"a\u00f1o\", 1979)))\r\n .sort(Sorts.descending(\"imdb.rating\"))\r\n .projection(Projections.fields(\r\n Projections.include(\"t\u00edtulo\", \"a\u00f1o\", \"imdb.rating\"),\r\n Projections.excludeId());<\/pre>\n
El futuro<\/strong><\/h2>\n
\n