Estou muito feliz em informar que o Couchbase agora tem um SDK Scala compat\u00edvel, permitindo que voc\u00ea obtenha e busque documentos, execute consultas N1QL, fa\u00e7a an\u00e1lises e pesquisas de texto completo - tudo com Scala nativo.<\/p>\n
Neste blog, abordarei os principais recursos e princ\u00edpios de design do Scala SDK. Ou, se voc\u00ea quiser come\u00e7ar imediatamente, d\u00ea uma olhada no guia de introdu\u00e7\u00e3o aqui<\/a>. O Scala SDK est\u00e1 dispon\u00edvel para download agora mesmo, em uma vers\u00e3o alfa de pr\u00e9-lan\u00e7amento.<\/p>\n O Scala SDK usa o mesmo n\u00facleo interno est\u00e1vel e de alto desempenho do novo Java SDK 3.x, portanto, embora seja novo, voc\u00ea pode ter certeza de que estar\u00e1 pronto para a produ\u00e7\u00e3o no GA.<\/p>\n O SDK do Scala apresenta uma interface funcional, com a maioria das opera\u00e7\u00f5es retornando um Scala Try. Ele pode ser um Success e conter o valor esperado, ou um Failure contendo um Throwable. Embora a princ\u00edpio isso pare\u00e7a um pouco prolixo e exija alguma disciplina de programa\u00e7\u00e3o para sempre tratar os erros, essa forma de tratamento de erros rapidamente se torna uma segunda natureza e permite que voc\u00ea desenvolva com seguran\u00e7a, sabendo que uma exce\u00e7\u00e3o aleat\u00f3ria n\u00e3o ser\u00e1 lan\u00e7ada pelo SDK.<\/p>\n Aqui est\u00e1 uma demonstra\u00e7\u00e3o simples de como inserir um documento:<\/p>\n E, em seguida, a correspond\u00eancia de padr\u00f5es no resultado do Try:<\/p>\n (\u00c9 claro que um aplicativo de produ\u00e7\u00e3o trataria os erros adequadamente, em vez de usar apenas println!)<\/p>\n Se voc\u00ea preferir algo semelhante ao Java SDK, que lan\u00e7a exce\u00e7\u00f5es, isso \u00e9 f\u00e1cil de simular, bastando chamar .get() em qualquer Try, que ser\u00e1 lan\u00e7ado se for uma falha:<\/p>\n \u00c9 f\u00e1cil combinar v\u00e1rios Trys por meio do flatMap. Aqui, inserimos um documento, depois o obtemos, recuperamos seu conte\u00fado convertido na biblioteca JSON integrada JsonObjectSafe (falaremos mais sobre isso posteriormente) e, por fim, obtemos um campo chamado \"status\" a partir dele. Tudo isso em um estilo totalmente funcional, de modo que, por exemplo, a opera\u00e7\u00e3o get s\u00f3 ser\u00e1 tentada se o upsert for bem-sucedido.<\/p>\n (Para fins de concis\u00e3o, a maioria dos exemplos abaixo deixar\u00e1 de lado a verifica\u00e7\u00e3o do resultado. Mas os aplicativos de produ\u00e7\u00e3o devem, \u00e9 claro, ABC - sempre estar verificando).<\/p>\n Imediatamente, o SDK \u00e9 compat\u00edvel com a nova durabilidade mais forte que estar\u00e1 dispon\u00edvel no Couchbase Server 6.5:<\/p>\n E oferece suporte a cole\u00e7\u00f5es, um novo m\u00e9todo de organiza\u00e7\u00e3o de documentos dentro de compartimentos que ser\u00e1 um recurso fundamental de uma vers\u00e3o futura do Couchbase Server (com uma visualiza\u00e7\u00e3o em breve). Em breve, o usu\u00e1rio poder\u00e1 criar algumas cole\u00e7\u00f5es de brinquedo para brincar, mas, por enquanto, ser\u00e1 suficiente abrir a cole\u00e7\u00e3o padr\u00e3o:<\/p>\n Essa l\u00f3gica funcionar\u00e1 em todas as vers\u00f5es compat\u00edveis do Couchbase Server (5.x e superior).<\/p>\n Al\u00e9m disso, est\u00e1 inclu\u00eddo o suporte ao OpenTracing (agora OpenTelemetry), a plataforma que est\u00e1 se tornando o padr\u00e3o de fato para o rastreamento de sistemas distribu\u00eddos complexos:<\/p>\n O SDK utiliza par\u00e2metros nomeados e padr\u00e3o em vez de sobrecargas, de modo que seu c\u00f3digo pode ser t\u00e3o simples quanto:<\/p>\n ou conforme personalizado:<\/p>\n como voc\u00ea precisa que seja.<\/p>\n Assim como o Java SDK, s\u00e3o apresentadas tr\u00eas APIs, o que lhe d\u00e1 flexibilidade para estruturar seu aplicativo da maneira que precisar.<\/p>\n A primeira \u00e9 a API s\u00edncrona de bloqueio simples que voc\u00ea viu nos exemplos acima. Essa pode ser uma boa op\u00e7\u00e3o padr\u00e3o, mas \u00e9 claro que exige que voc\u00ea gerencie explicitamente seu pr\u00f3prio threading, se necess\u00e1rio.<\/p>\n A segunda \u00e9 aquela criada com base na programa\u00e7\u00e3o reativa, usando tipos reativos padr\u00e3o (Mono e Flux) do Project Reactor.<\/p>\n Um exemplo de upserting de forma reativa:<\/p>\n Com a programa\u00e7\u00e3o reativa, nada acontecer\u00e1 at\u00e9 que assinemos o Mono. A maneira mais simples de fazer isso para fins de teste \u00e9 usar block(), embora essa seja uma pr\u00e1tica ruim para um aplicativo real:<\/p>\n A programa\u00e7\u00e3o reativa \u00e9 um assunto complexo e profundo que n\u00e3o posso abordar muito aqui, mas, quando dominada, \u00e9 uma ferramenta poderosa, especialmente para lidar com as complexidades dos sistemas distribu\u00eddos do mundo real. Em particular, a API reativa oferece contrapress\u00e3o em consultas N1QL, FTS e anal\u00edticas; portanto, se o aplicativo estiver com dificuldades para acompanhar os dados, ele reduzir\u00e1 automaticamente o consumo de linhas e evitar\u00e1 erros de falta de mem\u00f3ria. Incentivo os curiosos a dar uma olhada na Documenta\u00e7\u00e3o do Project Reactor<\/a> para saber mais.<\/p>\n Por fim, h\u00e1 a API ass\u00edncrona criada com base no Scala Futures, que fornece um pouco do gerenciamento de threads e da capacidade de composi\u00e7\u00e3o da programa\u00e7\u00e3o reativa, mas em uma forma mais familiar para muitos desenvolvedores do Scala. Um exemplo simples de upsert tem a seguinte apar\u00eancia:<\/p>\n Um dos principais objetivos era n\u00e3o prender voc\u00ea a nenhuma implementa\u00e7\u00e3o JSON espec\u00edfica e, pronto para uso, o Scala SDK funcionar\u00e1 bem com v\u00e1rias bibliotecas Scala JSON populares, incluindo Circe, \u00b5Pickle \/ \u00b5Json, Json4s e Jawn. Voc\u00ea pode ver trechos de como usar cada uma delas em os documentos JSON<\/a>Mas, para abrir seu apetite, aqui est\u00e1 um pouco do Circe em a\u00e7\u00e3o - observe como os tipos do Circe s\u00e3o enviados e retornados diretamente do SDK:<\/p>\n Adotando uma abordagem de \"baterias inclu\u00eddas\", h\u00e1 tamb\u00e9m uma biblioteca JSON simples inclu\u00edda no SDK, a JsonObject. Seus principais objetivos s\u00e3o:<\/p>\n Voc\u00ea pode se aprofundar no Documentos sobre JsonObject aqui<\/a>. \u00c9 claro que, se voc\u00ea preferir uma biblioteca JSON mais \"tipicamente Scala\" com dados imut\u00e1veis, tipos de dados alg\u00e9bricos, lentes, cursores e outros recursos funcionais, ent\u00e3o uma das outras bibliotecas suportadas pode ser uma escolha melhor - a escolha \u00e9 sua, e voc\u00ea pode facilmente misturar e combinar v\u00e1rias bibliotecas JSON no mesmo aplicativo.<\/p>\n Embora o SDK do Scala tenha um \u00f3timo suporte para JSON, \u00e0s vezes \u00e9 mais f\u00e1cil e prefer\u00edvel trabalhar diretamente com as classes de caso do Scala.<\/p>\n Basta adicionar essa pequena parte do boilerplate \u00e0 sua classe de caso para que o SDK possa gerar automaticamente a l\u00f3gica de serializa\u00e7\u00e3o:<\/p>\n E ent\u00e3o voc\u00ea pode facilmente enviar essa classe de caso diretamente para o SDK e receb\u00ea-la de volta:<\/p>\n Por tr\u00e1s disso, isso \u00e9 convertido e armazenado no Couchbase Server como o JSON que voc\u00ea espera:<\/p>\n Trata-se de um JSON simples e comum, sem metadados extras de serializa\u00e7\u00e3o ou similares, de modo que pode ser escrito livremente como uma classe de caso e lido em uma biblioteca JSON ou por outro SDK, ou vice-versa.<\/p>\n Confira o documenta\u00e7\u00e3o sobre o uso de classes de casos<\/a> para saber mais.<\/p>\n Facilitamos ao m\u00e1ximo o uso do Couchbase Analytics, N1QL e Full Text Search. Aqui est\u00e1 um exemplo de uma consulta N1QL em que as linhas s\u00e3o convertidas em JsonObject.<\/p>\n E, \u00e9 claro, \u00e9 poss\u00edvel obter esses resultados como qualquer um dos tipos de JSON suportados acima ou diretamente como classes de caso do Scala.<\/p>\n E, conforme mencionado acima, o uso da API reativa significa que voc\u00ea obt\u00e9m a contrapress\u00e3o autom\u00e1tica gratuitamente, garantindo que seu aplicativo consuma linhas em uma taxa gerenci\u00e1vel e n\u00e3o tenha problemas de falta de mem\u00f3ria em consultas muito grandes.<\/p>\n <\/p>\n Se voc\u00ea est\u00e1 animado para come\u00e7ar a usar o SDK do Couchbase Scala, confira o guia de in\u00edcio r\u00e1pido<\/a>. Ele est\u00e1 dispon\u00edvel agora mesmo, embora em uma forma alfa inicial. Pode haver algumas mudan\u00e7as significativas antes de ir para o GA, mas, por outro lado, este \u00e9 o momento perfeito para experiment\u00e1-lo e nos dar seu feedback, deixando um coment\u00e1rio abaixo ou enviando-o para Nossos f\u00f3runs<\/a>, Twitter<\/a> ou gitter<\/a>. Nada \u00e9 definitivo e agradecemos a chance de fazer algumas altera\u00e7\u00f5es e tornar este SDK o melhor poss\u00edvel.<\/p>","protected":false},"excerpt":{"rendered":" I\u2019m very happy to report that Couchbase now has a supported Scala SDK, allowing you to get and fetch documents, run N1QL queries, perform analytics and full text search lookups – all with native Scala. In this blog I\u2019m going […]<\/p>","protected":false},"author":40102,"featured_media":7088,"comment_status":"open","ping_status":"open","sticky":false,"template":"","format":"standard","meta":{"_acf_changed":false,"inline_featured_image":false,"footnotes":""},"categories":[2201],"tags":[],"ppma_author":[9084],"class_list":["post-7085","post","type-post","status-publish","format-standard","has-post-thumbnail","hentry","category-tools-sdks"],"acf":[],"yoast_head":"\nTratamento funcional de erros - sem exce\u00e7\u00f5es!<\/b><\/h3>\n
val json = JsonObject(\"status\" -> \"awesome!\")\r\n\r\nval result: Try[MutationResult] = collection.insert(\"document-key\", json)<\/pre>\n
result match {\r\n \u00a0\u00a0\u00a0 case Success(mr) => println(\"Upsert was successful\")\r\n \u00a0\u00a0\u00a0 case Failure(err: KeyAlreadyExistsException) => println(\"document-key already exists\") \r\n \u00a0\u00a0\u00a0 case Failure(err) => println(\"Error: \" + err)\r\n}<\/pre>\nval result: MutationResult = collection.insert(\"document-key\", json).get()<\/pre>\n
val result: Try[String] = collection.upsert(\"document-key\", json)\r\n .flatMap(_ => collection.get(\"document-key\"))\r\n .flatMap(_.contentAs[JsonObjectSafe])\r\n .flatMap(_.str(\"status\"))\r\n\r\nresult match {\r\n case Success(status) => println(s\"Couchbase is $status\")\r\n case Failure(err) =>\u00a0\u00a0\u00a0 println(\"Error: \" + err)\r\n}<\/pre>\nVis\u00e3o de futuro<\/b><\/h3>\n
val result = collection.upsert(\u201cdocId\u201d, json, durability = Durability.Majority)<\/pre>\n
val cluster = Cluster.connect(\"cluster-ip\", \"username\", \"password\")\r\nval collection = cluster.bucket(\"bucket-name\").defaultCollection<\/pre>\n
val result = collection.upsert(\u201cdocId\u201d, json, parentSpan = Some(mySpan))<\/pre>\n
API simples<\/b><\/h3>\n
val result = collection.upsert(\u201cdocId\u201d, json)<\/pre>\n
val result = collection.upsert(\u201cdocId\u201d, json, durability = Durability.Majority, expiration = 60.minutes, parentSpan = Some(mySpan))<\/pre>\n
Ass\u00edncrono<\/b><\/h3>\n
val mono: Mono[MutationResult] = collection.reactive.upsert(\"document-key\", json)\r\n .doOnError(err => println(s\"Error during upsert: ${err}\"))\r\n .doOnNext(mutationResult => println(\"Success\"))<\/pre>\nval result: MutationResult = mono.block()<\/pre>\n
val result: Future[MutationResult] = collection.async.upsert(\"document-key\", json)\r\n\r\nresult onComplete {\r\n case Success(_) \u00a0\u00a0\u00a0\u00a0\u00a0\u00a0\u00a0 => println(\"Successfully upserted\")\r\n case Failure(exception) => println(\"Error: \" + exception)\r\n}<\/pre>\nFlexibilidade do JSON<\/b><\/h3>\n
import io.circe.generic.auto._\r\nimport io.circe.syntax._\r\n\r\nval user = User(\u201cJohn Smith\u201d, 29)\r\nval json: io.circe.Json = user.asJson\r\n\r\nval result: Try[io.circe.Json] = collection.insert(\"id\", json)\r\n .flatMap(_ => collection.get(\"id\"))\r\n .flatMap(doc => doc.contentAs[io.circe.Json])\r\n\r\nresult match {\r\n case Success(content: io.circe.Json) =>\r\n \/\/ Handle Circe Json here\r\n case Failure(err) =>\u00a0\u00a0\u00a0 println(\"Error: \" + err)\r\n}<\/pre>\nJSON incorporado<\/h4>\n
\n
Suporte direto \u00e0 classe de casos<\/b><\/h4>\n
case class User(name: String, age: Int)\r\n\r\nobject User {\r\n implicit val codec: Codec[User] = Codecs.codec[User]\r\n}<\/pre>\nval r: Try[User] = collection.insert(\u201cdocId\u201d, User(\u201cJohn Smith\u201d, 29))\r\n .flatMap(_ => collection.get(\u201cdocId\u201d)\r\n .flatMap(doc => doc.contentAs[User])<\/pre>\n
{\"name\":\"John Smith\",\"age\":29}<\/pre>\nConsultas f\u00e1ceis<\/b><\/h3>\n
cluster.query(\"\"\"select * from `travel-sample` limit 10;\"\"\")\r\n .flatMap(_.allRowsAs[JsonObject]) match {\r\n\r\n case Success(rows: Seq[JsonObject]) =>\r\n rows.foreach(row => println(row))\r\n case Failure(err) =>\r\n println(s\"Error: $err\")\r\n}<\/pre>\n