getting started: couchbase server java sdk – couchbase live new york 2015

Getting Started with the Java SDK

Michael Nitschinger, SDK Engineer@daschl

Overview

©2015 Couchbase Inc. 3

Couchbase SDKs What does it mean to be a Couchbase SDK?

Cluster

Bucket

CRUD View Query

N1QL Query

FunctionalManage connections to the bucket within the cluster for different services.Provide a core layer where IO can be managed and optimized.Provide a way to manage buckets.

APIinsertDesignDocument()flush()listDesignDocuments()

FunctionalHold on to cluster information such as topology.

APIReference Cluster ManagementopenBucket()info()disconnect()

FunctionalGive the application developer a concurrent API for basic (k-v) or document management

APIget()insert()upsert()remove()

FunctionalAllow for querying, execution of other directives such as defining indexes and checking on index state.

APIabucket.NewN1QLQuery( “SELECT * FROM default LIMIT 5” ) .Consistency(gocouchbase.RequestPlus);

FunctionalAllow for view querying, building of queries and reasonable error handling from the cluster.

APIabucket.NewViewQuery().Limit().Stale()

©2014 Couchbase, Inc. — Proprietary and Confidential


Languages and Interfaces for Couchbase Official SDKs

– Java – Version 2.2– .NET – Version 2.1– Node.js – Version 2.1– Python – Version 2.0

For each of these we have– Full Document support– Interoperability– Common yet idiomatic Programming Model

Others: Erlang, Perl, TCL, Clojure, Scala

PHP – Version 2.0 C – Version 2.5 Go – Version 1.0 Ruby – Version 2.0

DP

JDBC and ODBC



Documents are integral to the SDKs. There are many implementations, depending on the

content type.

A Document contains:

The Document

5

Property DescriptionID The bucket-unique identifierContent The value that is storedExpiry An expiration timeCAS The Compare-And-Swap identifier


Facts Split into two projects

– core-io– java-client

Current Versions (java-client)– 2.2.0 (GA)

Documentation available through http://developer.couchbase.com/documentation/server/4.0/sdks/java-2.2/java-intro.html

6

http://developer.couchbase.com/documentation/server/4.0/sdks/java-2.2/java-intro.html

http://developer.couchbase.com/documentation/server/4.0/sdks/java-2.2/java-intro.html



Couchbase Core IO

7

Common infrastructure & feature set for all language bindings

Message oriented Asynchronous only Low overhead and performance focused Supports Java 6+ (including 8!)

Disruptor RingBuffer for implicit batching and backpressure Netty for high performance IO


Detour: Java Client Architecture

8


Detour: Smart Batching

Source: http://mechanical-sympathy.blogspot.co.at/2011/10/smart-batching.html 9


Detour: Smart Batching

Source: http://mechanical-sympathy.blogspot.co.at/2011/10/smart-batching.html 10



The Big Picture

11



Couchbase Java Client

12

Java Binding on top of core-io

Clusters/Buckets Documents Sync & Async API Bucket and Cluster Management Various Utilities and Helpers



Connecting

13



From Sync to Async

14


2.x API

RxJava 101A Gentle Introduction


Java implementation for Reactive Extensions https://github.com/ReactiveX

A library to compose asynchronous and event-driven programs through observable sequences.

RxJava: Introduction

single multiplesync T Iterable<T>async

Future<T>

Observable<T>

17

https://github.com/ReactiveX




Observables are the duals of Iterables They describe both Latency and Error side effects.

RxJava: Introduction

event Iterable<T> (pull) Observable<T> (push)data retrieval

T next() onNext(T)

error discovery

throws Exception onError(Exception)

completion returns onCompleted()

18


Consuming Observables

19

The Observer subscribes and receives events.

A cold Observablestarts when subscribed.

onNext can be called0..N times


RxJava: Creating Observables

just

20



21



22



23



24



25


RxJava: Transforming Observables

26



27



28



29



30



31



32



33


RxJava: Filtering Observables

34



35



36



37

Spring Data Couchbase


Spring IO


Spring Data Couchbase

• Integration with Spring Data Templates Repositories Exception Mapping also @Cacheable

• Maps POJO Entities to JSON (and back)• 2.0 M1 Released!


Spring Data Landscape

JDBC/JPA


Repositories – Do this


Repositories – Get this

43


Repositories – Backed by Views

findByFirstname()

findAll(), count()

44


JavaConfig

45


Putting it together

46


There is more! Entity mapping (Alias keys, TTLs, @Version for optimistic

concurrency,...)

JavaConfig and XML support CouchbaseTemplate for lower level access @View to customize Views and DesignDocuments @Cacheable suport for transparent caching

Spring Boot and Spring XD integration upcoming

47

Questions?

getting started: couchbase server java sdk – couchbase live new york 2015

Software