JAVA-26393 Move couchbase to persistence-modules (#15059)

2023-10-27 14:34:45 +03:00
parent 1028ab97c4
commit 520b679733
55 changed files with 3 additions and 4 deletions
@@ -0,0 +1,6 @@
+# Created by .ignore support plugin (hsz.mobi)
+
+# IntelliJ project files
+.idea
+*.iml
+/target/
@@ -0,0 +1,54 @@
+## Couchbase
+
+This module contains articles about Couchbase
+
+### Relevant Articles:
+- [Introduction to Couchbase SDK for Java](https://www.baeldung.com/java-couchbase-sdk)
+- [Using Couchbase in a Spring Application](https://www.baeldung.com/couchbase-sdk-spring)
+- [Asynchronous Batch Operations in Couchbase](https://www.baeldung.com/async-batch-operations-in-couchbase)
+- [Querying Couchbase with MapReduce Views](https://www.baeldung.com/couchbase-query-mapreduce-view)
+- [Querying Couchbase with N1QL](https://www.baeldung.com/n1ql-couchbase)
+
+### Overview
+This Maven project contains the Java code for the Couchbase entities and Spring services
+as described in the tutorials, as well as a unit/integration test
+for each service implementation.
+
+### Working with the Code
+The project was developed and tested using Java 7 and 8 in the Eclipse-based
+Spring Source Toolkit (STS) and therefore should run fine in any
+recent version of Eclipse or another IDE of your choice
+that supports Java 7 or later.
+
+### Building the Project
+You can also build the project using Maven outside of any IDE:
+```
+mvn clean install
+```
+
+### Package Organization
+Java classes for the intro tutorial are in the
+org.baeldung.couchbase.intro package.
+
+Java classes for the Spring service tutorial are in the
+org.baeldung.couchbase.spring package hierarchy.
+
+Java classes for the Asynchronous Couchbase tutorial are in the
+org.baeldung.couchbase.async package hierarchy.
+
+
+### Running the tests
+The test classes for the Spring service tutorial are:
+- org.baeldung.couchbase.spring.service.ClusterServiceTest
+- org.baeldung.couchbase.spring.person.PersonCrudServiceTest
+
+The test classes for the Asynchronous Couchbase tutorial are in the
+org.baeldung.couchbase.async package hierarchy:
+- org.baeldung.couchbase.async.service.ClusterServiceTest
+- org.baeldung.couchbase.async.person.PersonCrudServiceTest
+
+The test classes may be run as JUnit tests from your IDE
+or using the Maven command line:
+```
+mvn test
+```
@@ -0,0 +1,233 @@
+#!/bin/sh
+# ----------------------------------------------------------------------------
+# Licensed to the Apache Software Foundation (ASF) under one
+# or more contributor license agreements.  See the NOTICE file
+# distributed with this work for additional information
+# regarding copyright ownership.  The ASF licenses this file
+# to you under the Apache License, Version 2.0 (the
+# "License"); you may not use this file except in compliance
+# with the License.  You may obtain a copy of the License at
+#
+#    http://www.apache.org/licenses/LICENSE-2.0
+#
+# Unless required by applicable law or agreed to in writing,
+# software distributed under the License is distributed on an
+# "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+# KIND, either express or implied.  See the License for the
+# specific language governing permissions and limitations
+# under the License.
+# ----------------------------------------------------------------------------
+
+# ----------------------------------------------------------------------------
+# Maven2 Start Up Batch script
+#
+# Required ENV vars:
+# ------------------
+#   JAVA_HOME - location of a JDK home dir
+#
+# Optional ENV vars
+# -----------------
+#   M2_HOME - location of maven2's installed home dir
+#   MAVEN_OPTS - parameters passed to the Java VM when running Maven
+#     e.g. to debug Maven itself, use
+#       set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
+#   MAVEN_SKIP_RC - flag to disable loading of mavenrc files
+# ----------------------------------------------------------------------------
+
+if [ -z "$MAVEN_SKIP_RC" ] ; then
+
+  if [ -f /etc/mavenrc ] ; then
+    . /etc/mavenrc
+  fi
+
+  if [ -f "$HOME/.mavenrc" ] ; then
+    . "$HOME/.mavenrc"
+  fi
+
+fi
+
+# OS specific support.  $var _must_ be set to either true or false.
+cygwin=false;
+darwin=false;
+mingw=false
+case "`uname`" in
+  CYGWIN*) cygwin=true ;;
+  MINGW*) mingw=true;;
+  Darwin*) darwin=true
+           #
+           # Look for the Apple JDKs first to preserve the existing behaviour, and then look
+           # for the new JDKs provided by Oracle.
+           #
+           if [ -z "$JAVA_HOME" ] && [ -L /System/Library/Frameworks/JavaVM.framework/Versions/CurrentJDK ] ; then
+             #
+             # Apple JDKs
+             #
+             export JAVA_HOME=/System/Library/Frameworks/JavaVM.framework/Versions/CurrentJDK/Home
+           fi
+
+           if [ -z "$JAVA_HOME" ] && [ -L /System/Library/Java/JavaVirtualMachines/CurrentJDK ] ; then
+             #
+             # Apple JDKs
+             #
+             export JAVA_HOME=/System/Library/Java/JavaVirtualMachines/CurrentJDK/Contents/Home
+           fi
+
+           if [ -z "$JAVA_HOME" ] && [ -L "/Library/Java/JavaVirtualMachines/CurrentJDK" ] ; then
+             #
+             # Oracle JDKs
+             #
+             export JAVA_HOME=/Library/Java/JavaVirtualMachines/CurrentJDK/Contents/Home
+           fi
+
+           if [ -z "$JAVA_HOME" ] && [ -x "/usr/libexec/java_home" ]; then
+             #
+             # Apple JDKs
+             #
+             export JAVA_HOME=`/usr/libexec/java_home`
+           fi
+           ;;
+esac
+
+if [ -z "$JAVA_HOME" ] ; then
+  if [ -r /etc/gentoo-release ] ; then
+    JAVA_HOME=`java-config --jre-home`
+  fi
+fi
+
+if [ -z "$M2_HOME" ] ; then
+  ## resolve links - $0 may be a link to maven's home
+  PRG="$0"
+
+  # need this for relative symlinks
+  while [ -h "$PRG" ] ; do
+    ls=`ls -ld "$PRG"`
+    link=`expr "$ls" : '.*-> \(.*\)$'`
+    if expr "$link" : '/.*' > /dev/null; then
+      PRG="$link"
+    else
+      PRG="`dirname "$PRG"`/$link"
+    fi
+  done
+
+  saveddir=`pwd`
+
+  M2_HOME=`dirname "$PRG"`/..
+
+  # make it fully qualified
+  M2_HOME=`cd "$M2_HOME" && pwd`
+
+  cd "$saveddir"
+  # echo Using m2 at $M2_HOME
+fi
+
+# For Cygwin, ensure paths are in UNIX format before anything is touched
+if $cygwin ; then
+  [ -n "$M2_HOME" ] &&
+    M2_HOME=`cygpath --unix "$M2_HOME"`
+  [ -n "$JAVA_HOME" ] &&
+    JAVA_HOME=`cygpath --unix "$JAVA_HOME"`
+  [ -n "$CLASSPATH" ] &&
+    CLASSPATH=`cygpath --path --unix "$CLASSPATH"`
+fi
+
+# For Migwn, ensure paths are in UNIX format before anything is touched
+if $mingw ; then
+  [ -n "$M2_HOME" ] &&
+    M2_HOME="`(cd "$M2_HOME"; pwd)`"
+  [ -n "$JAVA_HOME" ] &&
+    JAVA_HOME="`(cd "$JAVA_HOME"; pwd)`"
+  # TODO classpath?
+fi
+
+if [ -z "$JAVA_HOME" ]; then
+  javaExecutable="`which javac`"
+  if [ -n "$javaExecutable" ] && ! [ "`expr \"$javaExecutable\" : '\([^ ]*\)'`" = "no" ]; then
+    # readlink(1) is not available as standard on Solaris 10.
+    readLink=`which readlink`
+    if [ ! `expr "$readLink" : '\([^ ]*\)'` = "no" ]; then
+      if $darwin ; then
+        javaHome="`dirname \"$javaExecutable\"`"
+        javaExecutable="`cd \"$javaHome\" && pwd -P`/javac"
+      else
+        javaExecutable="`readlink -f \"$javaExecutable\"`"
+      fi
+      javaHome="`dirname \"$javaExecutable\"`"
+      javaHome=`expr "$javaHome" : '\(.*\)/bin'`
+      JAVA_HOME="$javaHome"
+      export JAVA_HOME
+    fi
+  fi
+fi
+
+if [ -z "$JAVACMD" ] ; then
+  if [ -n "$JAVA_HOME"  ] ; then
+    if [ -x "$JAVA_HOME/jre/sh/java" ] ; then
+      # IBM's JDK on AIX uses strange locations for the executables
+      JAVACMD="$JAVA_HOME/jre/sh/java"
+    else
+      JAVACMD="$JAVA_HOME/bin/java"
+    fi
+  else
+    JAVACMD="`which java`"
+  fi
+fi
+
+if [ ! -x "$JAVACMD" ] ; then
+  echo "Error: JAVA_HOME is not defined correctly." >&2
+  echo "  We cannot execute $JAVACMD" >&2
+  exit 1
+fi
+
+if [ -z "$JAVA_HOME" ] ; then
+  echo "Warning: JAVA_HOME environment variable is not set."
+fi
+
+CLASSWORLDS_LAUNCHER=org.codehaus.plexus.classworlds.launcher.Launcher
+
+# For Cygwin, switch paths to Windows format before running java
+if $cygwin; then
+  [ -n "$M2_HOME" ] &&
+    M2_HOME=`cygpath --path --windows "$M2_HOME"`
+  [ -n "$JAVA_HOME" ] &&
+    JAVA_HOME=`cygpath --path --windows "$JAVA_HOME"`
+  [ -n "$CLASSPATH" ] &&
+    CLASSPATH=`cygpath --path --windows "$CLASSPATH"`
+fi
+
+# traverses directory structure from process work directory to filesystem root
+# first directory with .mvn subdirectory is considered project base directory
+find_maven_basedir() {
+  local basedir=$(pwd)
+  local wdir=$(pwd)
+  while [ "$wdir" != '/' ] ; do
+    if [ -d "$wdir"/.mvn ] ; then
+      basedir=$wdir
+      break
+    fi
+    wdir=$(cd "$wdir/.."; pwd)
+  done
+  echo "${basedir}"
+}
+
+# concatenates all lines of a file
+concat_lines() {
+  if [ -f "$1" ]; then
+    echo "$(tr -s '\n' ' ' < "$1")"
+  fi
+}
+
+export MAVEN_PROJECTBASEDIR=${MAVEN_BASEDIR:-$(find_maven_basedir)}
+MAVEN_OPTS="$(concat_lines "$MAVEN_PROJECTBASEDIR/.mvn/jvm.config") $MAVEN_OPTS"
+
+# Provide a "standardized" way to retrieve the CLI args that will
+# work with both Windows and non-Windows executions.
+MAVEN_CMD_LINE_ARGS="$MAVEN_CONFIG $@"
+export MAVEN_CMD_LINE_ARGS
+
+WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
+
+exec "$JAVACMD" \
+  $MAVEN_OPTS \
+  -classpath "$MAVEN_PROJECTBASEDIR/.mvn/wrapper/maven-wrapper.jar" \
+  "-Dmaven.home=${M2_HOME}" "-Dmaven.multiModuleProjectDirectory=${MAVEN_PROJECTBASEDIR}" \
+  ${WRAPPER_LAUNCHER} "$@"
@@ -0,0 +1,145 @@
+@REM ----------------------------------------------------------------------------
+@REM Licensed to the Apache Software Foundation (ASF) under one
+@REM or more contributor license agreements.  See the NOTICE file
+@REM distributed with this work for additional information
+@REM regarding copyright ownership.  The ASF licenses this file
+@REM to you under the Apache License, Version 2.0 (the
+@REM "License"); you may not use this file except in compliance
+@REM with the License.  You may obtain a copy of the License at
+@REM
+@REM    http://www.apache.org/licenses/LICENSE-2.0
+@REM
+@REM Unless required by applicable law or agreed to in writing,
+@REM software distributed under the License is distributed on an
+@REM "AS IS" BASIS, WITHOUT WARRANTIES OR CONDITIONS OF ANY
+@REM KIND, either express or implied.  See the License for the
+@REM specific language governing permissions and limitations
+@REM under the License.
+@REM ----------------------------------------------------------------------------
+
+@REM ----------------------------------------------------------------------------
+@REM Maven2 Start Up Batch script
+@REM
+@REM Required ENV vars:
+@REM JAVA_HOME - location of a JDK home dir
+@REM
+@REM Optional ENV vars
+@REM M2_HOME - location of maven2's installed home dir
+@REM MAVEN_BATCH_ECHO - set to 'on' to enable the echoing of the batch commands
+@REM MAVEN_BATCH_PAUSE - set to 'on' to wait for a key stroke before ending
+@REM MAVEN_OPTS - parameters passed to the Java VM when running Maven
+@REM     e.g. to debug Maven itself, use
+@REM set MAVEN_OPTS=-Xdebug -Xrunjdwp:transport=dt_socket,server=y,suspend=y,address=8000
+@REM MAVEN_SKIP_RC - flag to disable loading of mavenrc files
+@REM ----------------------------------------------------------------------------
+
+@REM Begin all REM lines with '@' in case MAVEN_BATCH_ECHO is 'on'
+@echo off
+@REM enable echoing my setting MAVEN_BATCH_ECHO to 'on'
+@if "%MAVEN_BATCH_ECHO%" == "on"  echo %MAVEN_BATCH_ECHO%
+
+@REM set %HOME% to equivalent of $HOME
+if "%HOME%" == "" (set "HOME=%HOMEDRIVE%%HOMEPATH%")
+
+@REM Execute a user defined script before this one
+if not "%MAVEN_SKIP_RC%" == "" goto skipRcPre
+@REM check for pre script, once with legacy .bat ending and once with .cmd ending
+if exist "%HOME%\mavenrc_pre.bat" call "%HOME%\mavenrc_pre.bat"
+if exist "%HOME%\mavenrc_pre.cmd" call "%HOME%\mavenrc_pre.cmd"
+:skipRcPre
+
+@setlocal
+
+set ERROR_CODE=0
+
+@REM To isolate internal variables from possible post scripts, we use another setlocal
+@setlocal
+
+@REM ==== START VALIDATION ====
+if not "%JAVA_HOME%" == "" goto OkJHome
+
+echo.
+echo Error: JAVA_HOME not found in your environment. >&2
+echo Please set the JAVA_HOME variable in your environment to match the >&2
+echo location of your Java installation. >&2
+echo.
+goto error
+
+:OkJHome
+if exist "%JAVA_HOME%\bin\java.exe" goto init
+
+echo.
+echo Error: JAVA_HOME is set to an invalid directory. >&2
+echo JAVA_HOME = "%JAVA_HOME%" >&2
+echo Please set the JAVA_HOME variable in your environment to match the >&2
+echo location of your Java installation. >&2
+echo.
+goto error
+
+@REM ==== END VALIDATION ====
+
+:init
+
+set MAVEN_CMD_LINE_ARGS=%*
+
+@REM Find the project base dir, i.e. the directory that contains the folder ".mvn".
+@REM Fallback to current working directory if not found.
+
+set MAVEN_PROJECTBASEDIR=%MAVEN_BASEDIR%
+IF NOT "%MAVEN_PROJECTBASEDIR%"=="" goto endDetectBaseDir
+
+set EXEC_DIR=%CD%
+set WDIR=%EXEC_DIR%
+:findBaseDir
+IF EXIST "%WDIR%"\.mvn goto baseDirFound
+cd ..
+IF "%WDIR%"=="%CD%" goto baseDirNotFound
+set WDIR=%CD%
+goto findBaseDir
+
+:baseDirFound
+set MAVEN_PROJECTBASEDIR=%WDIR%
+cd "%EXEC_DIR%"
+goto endDetectBaseDir
+
+:baseDirNotFound
+set MAVEN_PROJECTBASEDIR=%EXEC_DIR%
+cd "%EXEC_DIR%"
+
+:endDetectBaseDir
+
+IF NOT EXIST "%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config" goto endReadAdditionalConfig
+
+@setlocal EnableExtensions EnableDelayedExpansion
+for /F "usebackq delims=" %%a in ("%MAVEN_PROJECTBASEDIR%\.mvn\jvm.config") do set JVM_CONFIG_MAVEN_PROPS=!JVM_CONFIG_MAVEN_PROPS! %%a
+@endlocal & set JVM_CONFIG_MAVEN_PROPS=%JVM_CONFIG_MAVEN_PROPS%
+
+:endReadAdditionalConfig
+
+SET MAVEN_JAVA_EXE="%JAVA_HOME%\bin\java.exe"
+
+set WRAPPER_JAR="".\.mvn\wrapper\maven-wrapper.jar""
+set WRAPPER_LAUNCHER=org.apache.maven.wrapper.MavenWrapperMain
+
+%MAVEN_JAVA_EXE% %JVM_CONFIG_MAVEN_PROPS% %MAVEN_OPTS% %MAVEN_DEBUG_OPTS% -classpath %WRAPPER_JAR% "-Dmaven.multiModuleProjectDirectory=%MAVEN_PROJECTBASEDIR%" %WRAPPER_LAUNCHER% %MAVEN_CMD_LINE_ARGS%
+if ERRORLEVEL 1 goto error
+goto end
+
+:error
+set ERROR_CODE=1
+
+:end
+@endlocal & set ERROR_CODE=%ERROR_CODE%
+
+if not "%MAVEN_SKIP_RC%" == "" goto skipRcPost
+@REM check for post script, once with legacy .bat ending and once with .cmd ending
+if exist "%HOME%\mavenrc_post.bat" call "%HOME%\mavenrc_post.bat"
+if exist "%HOME%\mavenrc_post.cmd" call "%HOME%\mavenrc_post.cmd"
+:skipRcPost
+
+@REM pause the script if MAVEN_BATCH_PAUSE is set to 'on'
+if "%MAVEN_BATCH_PAUSE%" == "on" pause
+
+if "%MAVEN_TERMINATE_CMD%" == "on" exit %ERROR_CODE%
+
+exit /B %ERROR_CODE%
@@ -0,0 +1,78 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0"
+    xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+    xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <artifactId>couchbase</artifactId>
+    <name>couchbase</name>
+    <packaging>jar</packaging>
+    <description>Couchbase Tutorials</description>
+
+    <parent>
+        <groupId>com.baeldung</groupId>
+        <artifactId>persistence-modules</artifactId>
+        <version>1.0.0-SNAPSHOT</version>
+    </parent>
+
+    <dependencies>
+        <!-- Couchbase SDK -->
+        <dependency>
+            <groupId>com.couchbase.client</groupId>
+            <artifactId>java-client</artifactId>
+            <version>${couchbase.client.version}</version>
+        </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.core</groupId>
+            <artifactId>jackson-databind</artifactId>
+            <version>${jackson.version}</version>
+        </dependency>
+        <!-- Spring Context for Dependency Injection -->
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context</artifactId>
+            <version>${spring-framework.version}</version>
+            <exclusions>
+                <exclusion>
+                    <artifactId>commons-logging</artifactId>
+                    <groupId>commons-logging</groupId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-context-support</artifactId>
+            <version>${spring-framework.version}</version>
+            <exclusions>
+                <exclusion>
+                    <artifactId>commons-logging</artifactId>
+                    <groupId>commons-logging</groupId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <!-- Test-Scoped Dependencies -->
+        <dependency>
+            <groupId>org.springframework</groupId>
+            <artifactId>spring-test</artifactId>
+            <version>${spring-framework.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <!-- https://mvnrepository.com/artifact/org.apache.commons/commons-lang3 -->
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>${commons-lang3.version}</version>
+            <scope>test</scope>
+        </dependency>
+        <dependency>
+            <groupId>javax.annotation</groupId>
+            <artifactId>javax.annotation-api</artifactId>
+            <version>1.3.2</version>
+        </dependency>
+    </dependencies>
+
+    <properties>
+        <couchbase.client.version>2.7.2</couchbase.client.version>
+        <spring-framework.version>5.3.25</spring-framework.version>
+    </properties>
+
+</project>
@@ -0,0 +1,9 @@
+package com.baeldung.couchbase.async;
+
+public interface CouchbaseEntity {
+
+    String getId();
+
+    void setId(String id);
+
+}
@@ -0,0 +1,90 @@
+package com.baeldung.couchbase.async.person;
+
+import com.baeldung.couchbase.async.CouchbaseEntity;
+
+public class Person implements CouchbaseEntity {
+
+    private String id;
+    private String type;
+    private String name;
+    private String homeTown;
+
+    Person() {
+    }
+
+    public Person(Builder b) {
+        this.id = b.id;
+        this.type = b.type;
+        this.name = b.name;
+        this.homeTown = b.homeTown;
+    }
+
+    @Override
+    public String getId() {
+        return id;
+    }
+
+    @Override
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getHomeTown() {
+        return homeTown;
+    }
+
+    public void setHomeTown(String homeTown) {
+        this.homeTown = homeTown;
+    }
+
+    public static class Builder {
+        private String id;
+        private String type;
+        private String name;
+        private String homeTown;
+
+        public static Builder newInstance() {
+            return new Builder();
+        }
+
+        public Person build() {
+            return new Person(this);
+        }
+
+        public Builder id(String id) {
+            this.id = id;
+            return this;
+        }
+
+        public Builder type(String type) {
+            this.type = type;
+            return this;
+        }
+
+        public Builder name(String name) {
+            this.name = name;
+            return this;
+        }
+
+        public Builder homeTown(String homeTown) {
+            this.homeTown = homeTown;
+            return this;
+        }
+    }
+}
@@ -0,0 +1,24 @@
+package com.baeldung.couchbase.async.person;
+
+import javax.annotation.PostConstruct;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.stereotype.Service;
+
+import com.baeldung.couchbase.async.service.AbstractCrudService;
+import com.baeldung.couchbase.async.service.BucketService;
+
+@Service
+public class PersonCrudService extends AbstractCrudService<Person> {
+
+    @Autowired
+    public PersonCrudService(@Qualifier("TutorialBucketService") BucketService bucketService, PersonDocumentConverter converter) {
+        super(bucketService, converter);
+    }
+
+    @PostConstruct
+    private void init() {
+        loadBucket();
+    }
+}
@@ -0,0 +1,28 @@
+package com.baeldung.couchbase.async.person;
+
+import org.springframework.stereotype.Service;
+
+import com.baeldung.couchbase.async.service.JsonDocumentConverter;
+import com.couchbase.client.java.document.JsonDocument;
+import com.couchbase.client.java.document.json.JsonObject;
+
+@Service
+public class PersonDocumentConverter implements JsonDocumentConverter<Person> {
+
+    @Override
+    public JsonDocument toDocument(Person p) {
+        JsonObject content = JsonObject.empty().put("type", "Person").put("name", p.getName()).put("homeTown", p.getHomeTown());
+        return JsonDocument.create(p.getId(), content);
+    }
+
+    @Override
+    public Person fromDocument(JsonDocument doc) {
+        JsonObject content = doc.content();
+        Person p = new Person();
+        p.setId(doc.id());
+        p.setType("Person");
+        p.setName(content.getString("name"));
+        p.setHomeTown(content.getString("homeTown"));
+        return p;
+    }
+}
@@ -0,0 +1,28 @@
+package com.baeldung.couchbase.async.person;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.couchbase.client.core.CouchbaseException;
+
+@Service
+public class RegistrationService {
+
+    @Autowired
+    private PersonCrudService crud;
+
+    public void registerNewPerson(String name, String homeTown) {
+        Person person = new Person();
+        person.setName(name);
+        person.setHomeTown(homeTown);
+        crud.create(person);
+    }
+
+    public Person findRegistrant(String id) {
+        try {
+            return crud.read(id);
+        } catch (CouchbaseException e) {
+            return crud.readFromReplica(id);
+        }
+    }
+}
@@ -0,0 +1,27 @@
+package com.baeldung.couchbase.async.service;
+
+import com.couchbase.client.java.Bucket;
+
+public abstract class AbstractBucketService implements BucketService {
+
+    private ClusterService clusterService;
+
+    private Bucket bucket;
+
+    protected void openBucket() {
+        bucket = clusterService.openBucket(getBucketName(), getBucketPassword());
+    }
+
+    protected abstract String getBucketName();
+
+    protected abstract String getBucketPassword();
+
+    public AbstractBucketService(ClusterService clusterService) {
+        this.clusterService = clusterService;
+    }
+
+    @Override
+    public Bucket getBucket() {
+        return bucket;
+    }
+}
@@ -0,0 +1,142 @@
+package com.baeldung.couchbase.async.service;
+
+import java.util.ArrayList;
+import java.util.List;
+import java.util.UUID;
+import java.util.concurrent.TimeUnit;
+
+import org.slf4j.Logger;
+import org.slf4j.LoggerFactory;
+
+import com.baeldung.couchbase.async.CouchbaseEntity;
+import com.couchbase.client.core.BackpressureException;
+import com.couchbase.client.core.time.Delay;
+import com.couchbase.client.java.AsyncBucket;
+import com.couchbase.client.java.Bucket;
+import com.couchbase.client.java.ReplicaMode;
+import com.couchbase.client.java.document.JsonDocument;
+import com.couchbase.client.java.util.retry.RetryBuilder;
+
+import rx.Observable;
+import rx.functions.Action1;
+import rx.functions.Func1;
+
+public abstract class AbstractCrudService<T extends CouchbaseEntity> implements CrudService<T> {
+
+    private static final Logger logger = LoggerFactory.getLogger(AbstractCrudService.class);
+
+    private BucketService bucketService;
+    private Bucket bucket;
+    private JsonDocumentConverter<T> converter;
+
+    public AbstractCrudService(BucketService bucketService, JsonDocumentConverter<T> converter) {
+        this.bucketService = bucketService;
+        this.converter = converter;
+    }
+
+    protected void loadBucket() {
+        bucket = bucketService.getBucket();
+    }
+
+    @Override
+    public void create(T t) {
+        if (t.getId() == null) {
+            t.setId(UUID.randomUUID().toString());
+        }
+        JsonDocument doc = converter.toDocument(t);
+        bucket.insert(doc);
+    }
+
+    @Override
+    public T read(String id) {
+        JsonDocument doc = bucket.get(id);
+        return (doc == null ? null : converter.fromDocument(doc));
+    }
+
+    @Override
+    public T readFromReplica(String id) {
+        List<JsonDocument> docs = bucket.getFromReplica(id, ReplicaMode.FIRST);
+        return (docs.isEmpty() ? null : converter.fromDocument(docs.get(0)));
+    }
+
+    @Override
+    public void update(T t) {
+        JsonDocument doc = converter.toDocument(t);
+        bucket.upsert(doc);
+    }
+
+    @Override
+    public void delete(String id) {
+        bucket.remove(id);
+    }
+
+    @Override
+    public List<T> readBulk(Iterable<String> ids) {
+        final AsyncBucket asyncBucket = bucket.async();
+        Observable<JsonDocument> asyncOperation = Observable.from(ids).flatMap(new Func1<String, Observable<JsonDocument>>() {
+            public Observable<JsonDocument> call(String key) {
+                return asyncBucket.get(key);
+            }
+        });
+
+        final List<T> items = new ArrayList<T>();
+        try {
+            asyncOperation.toBlocking().forEach(new Action1<JsonDocument>() {
+                public void call(JsonDocument doc) {
+                    T item = converter.fromDocument(doc);
+                    items.add(item);
+                }
+            });
+        } catch (Exception e) {
+            logger.error("Error during bulk get", e);
+        }
+
+        return items;
+    }
+
+    @Override
+    public void createBulk(Iterable<T> items) {
+        final AsyncBucket asyncBucket = bucket.async();
+        Observable.from(items).flatMap(new Func1<T, Observable<JsonDocument>>() {
+            @SuppressWarnings("unchecked")
+            @Override
+            public Observable<JsonDocument> call(final T t) {
+                if (t.getId() == null) {
+                    t.setId(UUID.randomUUID().toString());
+                }
+                JsonDocument doc = converter.toDocument(t);
+                return asyncBucket.insert(doc).retryWhen(RetryBuilder.anyOf(BackpressureException.class).delay(Delay.exponential(TimeUnit.MILLISECONDS, 100)).max(10).build());
+            }
+        }).last().toBlocking().single();
+    }
+
+    @Override
+    public void updateBulk(Iterable<T> items) {
+        final AsyncBucket asyncBucket = bucket.async();
+        Observable.from(items).flatMap(new Func1<T, Observable<JsonDocument>>() {
+            @SuppressWarnings("unchecked")
+            @Override
+            public Observable<JsonDocument> call(final T t) {
+                JsonDocument doc = converter.toDocument(t);
+                return asyncBucket.upsert(doc).retryWhen(RetryBuilder.anyOf(BackpressureException.class).delay(Delay.exponential(TimeUnit.MILLISECONDS, 100)).max(10).build());
+            }
+        }).last().toBlocking().single();
+    }
+
+    @Override
+    public void deleteBulk(Iterable<String> ids) {
+        final AsyncBucket asyncBucket = bucket.async();
+        Observable.from(ids).flatMap(new Func1<String, Observable<JsonDocument>>() {
+            @SuppressWarnings("unchecked")
+            @Override
+            public Observable<JsonDocument> call(String key) {
+                return asyncBucket.remove(key).retryWhen(RetryBuilder.anyOf(BackpressureException.class).delay(Delay.exponential(TimeUnit.MILLISECONDS, 100)).max(10).build());
+            }
+        }).last().toBlocking().single();
+    }
+
+    @Override
+    public boolean exists(String id) {
+        return bucket.exists(id);
+    }
+}
@@ -0,0 +1,8 @@
+package com.baeldung.couchbase.async.service;
+
+import com.couchbase.client.java.Bucket;
+
+public interface BucketService {
+
+    Bucket getBucket();
+}
@@ -0,0 +1,8 @@
+package com.baeldung.couchbase.async.service;
+
+import com.couchbase.client.java.Bucket;
+
+public interface ClusterService {
+
+    Bucket openBucket(String name, String password);
+}
@@ -0,0 +1,42 @@
+package com.baeldung.couchbase.async.service;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+import javax.annotation.PostConstruct;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.couchbase.client.java.Bucket;
+import com.couchbase.client.java.Cluster;
+import com.couchbase.client.java.CouchbaseCluster;
+import com.couchbase.client.java.env.CouchbaseEnvironment;
+import com.couchbase.client.java.env.DefaultCouchbaseEnvironment;
+
+@Service
+public class ClusterServiceImpl implements ClusterService {
+
+    private Cluster cluster;
+    private Map<String, Bucket> buckets = new ConcurrentHashMap<>();
+    
+    @Autowired
+    public ClusterServiceImpl(Cluster cluster) {
+        this.cluster = cluster;
+    }
+
+    @PostConstruct
+    private void init() {
+        CouchbaseEnvironment env = DefaultCouchbaseEnvironment.create();
+        cluster = CouchbaseCluster.create(env, "localhost");
+    }
+
+    @Override
+    synchronized public Bucket openBucket(String name, String password) {
+        if (!buckets.containsKey(name)) {
+            Bucket bucket = cluster.openBucket(name, password);
+            buckets.put(name, bucket);
+        }
+        return buckets.get(name);
+    }
+}
@@ -0,0 +1,26 @@
+package com.baeldung.couchbase.async.service;
+
+import java.util.List;
+
+public interface CrudService<T> {
+
+    void create(T t);
+
+    T read(String id);
+
+    T readFromReplica(String id);
+
+    void update(T t);
+
+    void delete(String id);
+
+    List<T> readBulk(Iterable<String> ids);
+
+    void createBulk(Iterable<T> items);
+
+    void updateBulk(Iterable<T> items);
+
+    void deleteBulk(Iterable<String> ids);
+
+    boolean exists(String id);
+}
@@ -0,0 +1,10 @@
+package com.baeldung.couchbase.async.service;
+
+import com.couchbase.client.java.document.JsonDocument;
+
+public interface JsonDocumentConverter<T> {
+
+    JsonDocument toDocument(T t);
+
+    T fromDocument(JsonDocument doc);
+}
@@ -0,0 +1,33 @@
+package com.baeldung.couchbase.async.service;
+
+import javax.annotation.PostConstruct;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.beans.factory.annotation.Qualifier;
+import org.springframework.stereotype.Service;
+
+@Service
+@Qualifier("TutorialBucketService")
+public class TutorialBucketService extends AbstractBucketService {
+
+    @PostConstruct
+    void init() {
+        openBucket();
+    }
+
+    @Autowired
+    public TutorialBucketService(ClusterService clusterService) {
+        super(clusterService);
+        openBucket();
+    }
+
+    @Override
+    protected String getBucketName() {
+        return "baeldung-tutorial";
+    }
+
+    @Override
+    protected String getBucketPassword() {
+        return "";
+    }
+}
@@ -0,0 +1,87 @@
+package com.baeldung.couchbase.intro;
+
+import java.util.List;
+import java.util.UUID;
+
+import com.couchbase.client.core.CouchbaseException;
+import com.couchbase.client.java.Bucket;
+import com.couchbase.client.java.Cluster;
+import com.couchbase.client.java.CouchbaseCluster;
+import com.couchbase.client.java.ReplicaMode;
+import com.couchbase.client.java.document.JsonDocument;
+import com.couchbase.client.java.document.json.JsonObject;
+import com.couchbase.client.java.env.CouchbaseEnvironment;
+import com.couchbase.client.java.env.DefaultCouchbaseEnvironment;
+
+public class CodeSnippets {
+
+    static Cluster loadClusterWithDefaultEnvironment() {
+        return CouchbaseCluster.create("localhost");
+    }
+
+    static Cluster loadClusterWithCustomEnvironment() {
+        CouchbaseEnvironment env = DefaultCouchbaseEnvironment.builder().connectTimeout(10000).kvTimeout(3000).build();
+        return CouchbaseCluster.create(env, "localhost");
+    }
+
+    static Bucket loadDefaultBucketWithBlankPassword(Cluster cluster) {
+        return cluster.openBucket();
+    }
+
+    static Bucket loadBaeldungBucket(Cluster cluster) {
+        return cluster.openBucket("baeldung", "");
+    }
+
+    static JsonDocument insertExample(Bucket bucket) {
+        JsonObject content = JsonObject.empty().put("name", "John Doe").put("type", "Person").put("email", "[email protected]").put("homeTown", "Chicago");
+        String id = UUID.randomUUID().toString();
+        JsonDocument document = JsonDocument.create(id, content);
+        JsonDocument inserted = bucket.insert(document);
+        return inserted;
+    }
+
+    static JsonDocument retrieveAndUpsertExample(Bucket bucket, String id) {
+        JsonDocument document = bucket.get(id);
+        JsonObject content = document.content();
+        content.put("homeTown", "Kansas City");
+        JsonDocument upserted = bucket.upsert(document);
+        return upserted;
+    }
+
+    static JsonDocument replaceExample(Bucket bucket, String id) {
+        JsonDocument document = bucket.get(id);
+        JsonObject content = document.content();
+        content.put("homeTown", "Milwaukee");
+        JsonDocument replaced = bucket.replace(document);
+        return replaced;
+    }
+
+    static JsonDocument removeExample(Bucket bucket, String id) {
+        JsonDocument removed = bucket.remove(id);
+        return removed;
+    }
+
+    static JsonDocument getFirstFromReplicaExample(Bucket bucket, String id) {
+        try {
+            return bucket.get(id);
+        } catch (CouchbaseException e) {
+            List<JsonDocument> list = bucket.getFromReplica(id, ReplicaMode.FIRST);
+            if (!list.isEmpty()) {
+                return list.get(0);
+            }
+        }
+        return null;
+    }
+
+    static JsonDocument getLatestReplicaVersion(Bucket bucket, String id) {
+        long maxCasValue = -1;
+        JsonDocument latest = null;
+        for (JsonDocument replica : bucket.getFromReplica(id, ReplicaMode.ALL)) {
+            if (replica.cas() > maxCasValue) {
+                latest = replica;
+                maxCasValue = replica.cas();
+            }
+        }
+        return latest;
+    }
+}
@@ -0,0 +1,6 @@
+package com.baeldung.couchbase.mapreduce;
+
+public interface CouchbaseKeyGenerator<T> {
+
+    String generateKey(T t);
+}
@@ -0,0 +1,10 @@
+package com.baeldung.couchbase.mapreduce;
+
+@SuppressWarnings("serial")
+public class DuplicateKeyException extends Exception {
+
+    public DuplicateKeyException(String s) {
+        super(s);
+    }
+
+}
@@ -0,0 +1,11 @@
+package com.baeldung.couchbase.mapreduce;
+
+import java.util.UUID;
+
+public class RandomUUIDGenerator<T> implements CouchbaseKeyGenerator<T> {
+
+    @Override
+    public String generateKey(T t) {
+        return UUID.randomUUID().toString();
+    }
+}
@@ -0,0 +1,50 @@
+package com.baeldung.couchbase.mapreduce;
+
+public class StudentGrade {
+
+    private String name;
+    private String course;
+    private Integer grade;
+    private Integer hours;
+    
+    public StudentGrade() { }
+    
+    public StudentGrade(String name, String course, Integer grade, Integer hours) {
+        this.name = name;
+        this.course = course;
+        this.grade = grade;
+        this.hours = hours;
+    }
+    
+    public String getName() {
+        return name;
+    }
+    
+    public void setName(String name) {
+        this.name = name;
+    }
+    
+    public String getCourse() {
+        return course;
+    }
+    
+    public void setCourse(String course) {
+        this.course = course;
+    }
+    
+    public Integer getGrade() {
+        return grade;
+    }
+    
+    public void setGrade(Integer grade) {
+        this.grade = grade;
+    }
+
+    public Integer getHours() {
+        return hours;
+    }
+
+    public void setHours(Integer hours) {
+        this.hours = hours;
+    }
+}
@@ -0,0 +1,9 @@
+package com.baeldung.couchbase.mapreduce;
+
+public class StudentGradeKeyGenerator implements CouchbaseKeyGenerator<StudentGrade> {
+
+    @Override
+    public String generateKey(StudentGrade g) {
+        return g.getName() + ":" + g.getCourse();
+    }
+}
@@ -0,0 +1,70 @@
+package com.baeldung.couchbase.mapreduce;
+
+import com.couchbase.client.deps.com.fasterxml.jackson.databind.ObjectMapper;
+import com.couchbase.client.java.document.json.JsonArray;
+import com.couchbase.client.java.view.ViewQuery;
+
+public class StudentGradeQueryBuilder {
+
+    final ObjectMapper om = new ObjectMapper();
+    
+    public ViewQuery findAll() {
+        return ViewQuery.from("studentGrades", "findByCourse");
+    }
+    
+    public ViewQuery findByCourse(String course) {
+        return ViewQuery.from("studentGrades", "findByCourse")
+                .key(course);
+    }
+    
+    public ViewQuery findByCourses(String... courses) {
+        return ViewQuery.from("studentGrades", "findByCourse")
+                .keys(JsonArray.from(courses));
+    }
+    
+    public ViewQuery findByGradeInRange(int lower, int upper, boolean inclusiveEnd) {
+        return ViewQuery.from("studentGrades", "findByGrade")
+                .startKey(lower)
+                .endKey(upper)
+                .inclusiveEnd(inclusiveEnd);
+    }
+    
+    public ViewQuery findByGradeLessThan(int upper) {
+        return ViewQuery.from("studentGrades", "findByGrade")
+                .endKey(upper)
+                .inclusiveEnd(false);
+    }
+    
+    public ViewQuery findByGradeGreaterThan(int lower) {
+        return ViewQuery.from("studentGrades", "findByGrade")
+                .startKey(lower);
+    }
+        
+    public ViewQuery findByCourseAndGradeInRange(String course, int minGrade, int maxGrade, boolean inclusiveEnd) {
+        return ViewQuery.from("studentGrades", "findByCourseAndGrade")
+                .startKey(JsonArray.from(course, minGrade))
+                .endKey(JsonArray.from(course, maxGrade))
+                .inclusiveEnd(inclusiveEnd);
+    }
+    
+    public ViewQuery findTopGradesByCourse(String course, int limit) {
+        return ViewQuery.from("studentGrades", "findByCourseAndGrade")
+                .startKey(JsonArray.from(course, 100))
+                .endKey(JsonArray.from(course, 0))
+                .inclusiveEnd(true)
+                .descending()
+                .limit(limit);
+    }
+    
+    public ViewQuery countStudentsByCourse() {
+        return ViewQuery.from("studentGrades", "countStudentsByCourse")
+                .reduce()
+                .groupLevel(1);
+    }
+    
+    public ViewQuery sumCreditsByStudent() {
+        return ViewQuery.from("studentGrades", "sumCreditsByStudent")
+                .reduce()
+                .groupLevel(1);
+    }
+}
@@ -0,0 +1,169 @@
+package com.baeldung.couchbase.mapreduce;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+import java.util.Map.Entry;
+
+import com.couchbase.client.deps.com.fasterxml.jackson.databind.ObjectMapper;
+import com.couchbase.client.java.Bucket;
+import com.couchbase.client.java.CouchbaseCluster;
+import com.couchbase.client.java.document.JsonDocument;
+import com.couchbase.client.java.document.json.JsonArray;
+import com.couchbase.client.java.document.json.JsonObject;
+import com.couchbase.client.java.view.ViewQuery;
+import com.couchbase.client.java.view.ViewResult;
+import com.couchbase.client.java.view.ViewRow;
+
+public class StudentGradeService {
+
+    final CouchbaseKeyGenerator<StudentGrade> keyGenerator;
+    final CouchbaseCluster cluster;
+    final Bucket bucket;
+    final ObjectMapper om = new ObjectMapper();
+    final StudentGradeQueryBuilder queryBuilder;
+    
+    public StudentGradeService(CouchbaseKeyGenerator<StudentGrade> keyGenerator) {
+        this.keyGenerator = keyGenerator;
+        this.queryBuilder = new StudentGradeQueryBuilder();
+        cluster = CouchbaseCluster.create("127.0.0.1");
+        bucket = cluster.openBucket("baeldung-tutorial");
+    }
+    
+    public String insert(StudentGrade studentGrade) throws DuplicateKeyException {
+        String id = keyGenerator.generateKey(studentGrade);
+        if(bucket.exists(id)) {
+            throw new DuplicateKeyException("document already exists with key " + id);
+        }
+        JsonObject content = JsonObject.empty()
+                .put("type", "StudentGrade")
+                .put("name", studentGrade.getName())
+                .put("course", studentGrade.getCourse())
+                .put("grade", studentGrade.getGrade())
+                .put("hours", studentGrade.getHours());
+        JsonDocument doc = JsonDocument.create(id, content);
+        bucket.insert(doc);
+        return id;
+    }
+    
+    public List<JsonDocument> findAll() {
+        ViewQuery query = queryBuilder.findAll();
+        ViewResult result = bucket.query(query);
+        return extractDocuments(result);
+    }
+    
+    private List<JsonDocument> extractDocuments(ViewResult result) {
+        List<JsonDocument> docs = new ArrayList<>();
+        for(ViewRow row : result.allRows()) {
+            JsonDocument doc = row.document();
+            docs.add(doc);
+        }
+        return docs;
+    }
+    
+    public List<JsonDocument> findByCourse(String course) {
+        ViewQuery query = queryBuilder.findByCourse(course);
+        ViewResult result = bucket.query(query);
+        return extractDocuments(result);
+    }
+    
+    public List<JsonDocument> findByCourses(String... courses) {
+        ViewQuery query = queryBuilder.findByCourses(courses);
+        ViewResult result = bucket.query(query);
+        return extractDocuments(result);
+    }
+    
+    public List<JsonDocument> findByGradeInRange(int lower, int upper, boolean inclusiveEnd) {
+        ViewQuery query = queryBuilder.findByGradeInRange(lower, upper, inclusiveEnd);
+        ViewResult result = bucket.query(query);
+        return extractDocuments(result);
+    }
+    
+    public List<JsonDocument> findByGradeLessThan(int upper) {
+        ViewQuery query = queryBuilder.findByGradeLessThan(upper);
+        ViewResult result = bucket.query(query);
+        return extractDocuments(result);
+    }
+    
+    public List<JsonDocument> findByGradeGreaterThan(int lower) {
+        ViewQuery query = queryBuilder.findByGradeGreaterThan(lower);
+        ViewResult result = bucket.query(query);
+        return extractDocuments(result);
+    }
+        
+    public List<JsonDocument> findByCourseAndGradeInRange(String course, int minGrade, int maxGrade, boolean inclusiveEnd) {
+        ViewQuery query = queryBuilder.findByCourseAndGradeInRange(course, minGrade, maxGrade, inclusiveEnd);
+        ViewResult result = bucket.query(query);
+        return extractDocuments(result);
+    }
+    
+    public List<JsonDocument> findTopGradesByCourse(String course, int limit) {
+        ViewQuery query = queryBuilder.findTopGradesByCourse(course, limit);
+        ViewResult result = bucket.query(query);
+        return extractDocuments(result);
+    }
+    
+    public Map<String, Long> countStudentsByCourse() {
+        ViewQuery query = ViewQuery.from("studentGrades", "countStudentsByCourse")
+                .reduce()
+                .groupLevel(1);
+        ViewResult result = bucket.query(query);
+        
+        Map<String, Long> numStudentsByCourse = new HashMap<>();
+        for(ViewRow row : result.allRows()) {
+            JsonArray keyArray = (JsonArray) row.key();
+            String course = keyArray.getString(0);
+            long count = Long.valueOf(row.value().toString());
+            numStudentsByCourse.put(course, count);
+        }
+        
+        return numStudentsByCourse;
+    }
+    
+    public Map<String, Long> sumCreditHoursByStudent() {
+        ViewQuery query = ViewQuery.from("studentGrades", "sumHoursByStudent")
+                .reduce()
+                .groupLevel(1);
+        ViewResult result = bucket.query(query);
+        
+        Map<String, Long> creditHoursByStudent = new HashMap<>();
+        for(ViewRow row : result.allRows()) {
+            String course = (String) row.key();
+            long sum = Long.valueOf(row.value().toString());
+            creditHoursByStudent.put(course, sum);
+        }
+        
+        return creditHoursByStudent;
+    }
+    
+    public Map<String, Long> sumGradePointsByStudent() {
+        ViewQuery query = ViewQuery.from("studentGrades", "sumGradePointsByStudent")
+                .reduce()
+                .groupLevel(1);
+        ViewResult result = bucket.query(query);
+        
+        Map<String, Long> gradePointsByStudent = new HashMap<>();
+        for(ViewRow row : result.allRows()) {
+            String course = (String) row.key();
+            long sum = Long.valueOf(row.value().toString());
+            gradePointsByStudent.put(course, sum);
+        }
+        
+        return gradePointsByStudent;
+    }
+    
+    public Map<String, Float> calculateGpaByStudent() {
+        Map<String, Long> creditHoursByStudent = sumCreditHoursByStudent();
+        Map<String, Long> gradePointsByStudent = sumGradePointsByStudent();
+        
+        Map<String, Float> result = new HashMap<>();
+        for(Entry<String, Long> creditHoursEntry : creditHoursByStudent.entrySet()) {
+            String name = creditHoursEntry.getKey();
+            long totalHours = creditHoursEntry.getValue();
+            long totalGradePoints = gradePointsByStudent.get(name);
+            result.put(name, ((float) totalGradePoints / totalHours));
+        }
+        return result;
+    }
+}
@@ -0,0 +1,26 @@
+package com.baeldung.couchbase.n1ql;
+
+import com.couchbase.client.java.Bucket;
+import com.couchbase.client.java.Cluster;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+@Service
+public class BucketFactory {
+
+    @Autowired
+    private Cluster cluster;
+
+    private Bucket travelSampleBucket;
+    private Bucket testBucket;
+
+    public Bucket getTravelSampleBucket() {
+        return (travelSampleBucket != null) ?
+                travelSampleBucket : cluster.openBucket("travel-sample");
+    }
+
+    public Bucket getTestBucket() {
+        return (testBucket != null) ?
+                testBucket : cluster.openBucket("test");
+    }
+}
@@ -0,0 +1,34 @@
+package com.baeldung.couchbase.n1ql;
+
+import com.couchbase.client.java.query.N1qlQueryResult;
+import com.fasterxml.jackson.databind.JsonNode;
+import com.fasterxml.jackson.databind.ObjectMapper;
+
+import java.io.IOException;
+import java.util.List;
+import java.util.Objects;
+import java.util.logging.Level;
+import java.util.logging.Logger;
+import java.util.stream.Collectors;
+
+public class CodeSnippets {
+
+    private static ObjectMapper objectMapper = new ObjectMapper();
+
+    private static final Logger logger = Logger.getLogger(CodeSnippets.class.getName());
+
+    public static List<JsonNode> extractJsonResult(N1qlQueryResult result) {
+      return result.allRows().stream()
+        .map(row -> {
+            try {
+              return objectMapper.readTree(row.value().toString());
+            }catch (IOException e) {
+               logger.log(Level.WARNING, e.getLocalizedMessage());
+               return null;
+            }
+        })
+        .filter(Objects::nonNull)
+        .collect(Collectors.toList());
+    }
+
+}
@@ -0,0 +1,86 @@
+package com.baeldung.couchbase.spring.person;
+
+public class Person {
+
+    private String id;
+    private String type;
+    private String name;
+    private String homeTown;
+
+    Person() {
+    }
+
+    public Person(Builder b) {
+        this.id = b.id;
+        this.type = b.type;
+        this.name = b.name;
+        this.homeTown = b.homeTown;
+    }
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getType() {
+        return type;
+    }
+
+    public void setType(String type) {
+        this.type = type;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public String getHomeTown() {
+        return homeTown;
+    }
+
+    public void setHomeTown(String homeTown) {
+        this.homeTown = homeTown;
+    }
+
+    public static class Builder {
+        private String id;
+        private String type;
+        private String name;
+        private String homeTown;
+
+        public static Builder newInstance() {
+            return new Builder();
+        }
+
+        public Person build() {
+            return new Person(this);
+        }
+
+        public Builder id(String id) {
+            this.id = id;
+            return this;
+        }
+
+        public Builder type(String type) {
+            this.type = type;
+            return this;
+        }
+
+        public Builder name(String name) {
+            this.name = name;
+            return this;
+        }
+
+        public Builder homeTown(String homeTown) {
+            this.homeTown = homeTown;
+            return this;
+        }
+    }
+}
@@ -0,0 +1,69 @@
+package com.baeldung.couchbase.spring.person;
+
+import java.util.List;
+import java.util.UUID;
+
+import javax.annotation.PostConstruct;
+
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Service;
+
+import com.baeldung.couchbase.spring.service.CrudService;
+import com.baeldung.couchbase.spring.service.TutorialBucketService;
+import com.couchbase.client.java.Bucket;
+import com.couchbase.client.java.ReplicaMode;
+import com.couchbase.client.java.document.JsonDocument;
+
+@Service
+public class PersonCrudService implements CrudService<Person> {
+
+    @Autowired
+    private TutorialBucketService bucketService;
+
+    @Autowired
+    private PersonDocumentConverter converter;
+
+    private Bucket bucket;
+
+    @PostConstruct
+    private void init() {
+        bucket = bucketService.getBucket();
+    }
+
+    @Override
+    public void create(Person person) {
+        if (person.getId() == null) {
+            person.setId(UUID.randomUUID().toString());
+        }
+        JsonDocument document = converter.toDocument(person);
+        bucket.insert(document);
+    }
+
+    @Override
+    public Person read(String id) {
+        JsonDocument doc = bucket.get(id);
+        return (doc != null ? converter.fromDocument(doc) : null);
+    }
+
+    @Override
+    public Person readFromReplica(String id) {
+        List<JsonDocument> docs = bucket.getFromReplica(id, ReplicaMode.FIRST);
+        return (docs.isEmpty() ? null : converter.fromDocument(docs.get(0)));
+    }
+
+    @Override
+    public void update(Person person) {
+        JsonDocument document = converter.toDocument(person);
+        bucket.upsert(document);
+    }
+
+    @Override
+    public void delete(String id) {
+        bucket.remove(id);
+    }
+
+    @Override
+    public boolean exists(String id) {
+        return bucket.exists(id);
+    }
+}
--- a/Show More
+++ b/Show More