#265 - Add example for Spring Data Couchbase.

Original pull request: #275.

couchbase/example/src/main/java/example/springdata/couchbase/CouchbaseConfiguration.java

@@ -0,0 +1,35 @@
+package example.springdata.couchbase;
+
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+import org.springframework.context.annotation.Configuration;
+import org.springframework.data.couchbase.config.AbstractCouchbaseConfiguration;
+import org.springframework.data.couchbase.repository.config.EnableCouchbaseRepositories;
+
+import java.util.Collections;
+import java.util.List;
+
+/**
+ * Couchbase Configuration to connect to Couchbase data store
+ *
+ * @author Chandana Kithalagama
+ */
+@SpringBootApplication
+@Configuration
+@EnableCouchbaseRepositories
+public class CouchbaseConfiguration extends AbstractCouchbaseConfiguration {
+
+	@Override
+	protected List<String> getBootstrapHosts() {
+		return Collections.singletonList("192.168.99.100");
+	}
+
+	@Override
+	protected String getBucketName() {
+		return "travel-sample";
+	}
+
+	@Override
+	protected String getBucketPassword() {
+		return "";
+	}
+}

couchbase/example/src/main/java/example/springdata/couchbase/model/Airline.java

@@ -0,0 +1,40 @@
+package example.springdata.couchbase.model;
+
+import com.couchbase.client.java.repository.annotation.Field;
+import com.couchbase.client.java.repository.annotation.Id;
+import lombok.*;
+import org.springframework.data.couchbase.core.mapping.Document;
+
+/**
+ * A domain object representing an Airline
+ *
+ * @author Chandana Kithalagama
+ */
+@Data
+@AllArgsConstructor
+@NoArgsConstructor
+@Document
+public class Airline {
+
+	@Id
+	private int id;
+
+	@Field
+	private String type;
+
+	@Field
+	private String name;
+
+	@Field("iata")
+	private String iataCode;
+
+	@Field
+	private String icao;
+
+	@Field
+	private String callsign;
+
+	@Field
+	private String country;
+
+}

couchbase/example/src/main/java/example/springdata/couchbase/repository/AirlineRepository.java

@@ -0,0 +1,18 @@
+package example.springdata.couchbase.repository;
+
+import example.springdata.couchbase.model.Airline;
+import org.springframework.data.couchbase.core.query.Query;
+import org.springframework.data.repository.CrudRepository;
+
+import java.util.List;
+
+/**
+ * Repository interface to manage {@link Airline} instances.
+ *
+ * @author Chandana Kithalagama
+ */
+public interface AirlineRepository extends CrudRepository<Airline, Integer>{
+
+	@Query("#{#n1ql.selectEntity} WHERE #{#n1ql.filter} AND name = $1")
+	List<Airline> findAirlineByName(String name);
+}

couchbase/example/src/test/java/example/springdata/couchbase/repository/AirlineRepositoryIntegrationTest.java

@@ -0,0 +1,84 @@
+package example.springdata.couchbase.repository;
+
+import example.springdata.couchbase.CouchbaseConfiguration;
+import example.springdata.couchbase.model.Airline;
+import org.junit.After;
+import org.junit.Before;
+import org.junit.Test;
+import org.junit.runner.RunWith;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.boot.test.context.SpringBootTest;
+import org.springframework.test.context.junit4.SpringRunner;
+
+import java.util.Arrays;
+import java.util.List;
+
+import static org.assertj.core.api.Assertions.assertThat;
+
+/**
+ * Unit tests for basic CRUD operations
+ *
+ * @author Chandana Kithalagama
+ */
+@RunWith(SpringRunner.class)
+@SpringBootTest(classes = CouchbaseConfiguration.class)
+public class AirlineRepositoryIntegrationTest {
+
+	@Autowired
+	AirlineRepository airlineRepository;
+	Airline a, b, c;
+	List<Airline> airlineList;
+
+	@Before
+	public void setup() {
+		a = new Airline(20000,"airline", "CK 1", "LK", "CMB", "CLK","Sri Lanka");
+		b = new Airline(20001,"airline", "CK 2", "LK", "CMB", "CLK","Sri Lanka");
+		c = new Airline(20002,"airline", "CK 3", "LK", "CMB", "CLK","Sri Lanka");
+
+		airlineList = Arrays.asList(a, b, b);
+	}
+
+	@Test
+	public void testSaveAirline() {
+		Iterable<Airline> itr = airlineRepository.save(Arrays.asList(a));
+		assertThat(itr).isNotNull();
+		Airline airline = airlineRepository.findOne(a.getId());
+		assertThat(airline).isNotNull();
+		assertThat(airline).isEqualTo(a);
+		assertThat(airline).isNotEqualTo(b);
+		airlineRepository.delete(a.getId());
+	}
+
+	@Test
+	public void testGetAllAirlines() {
+		Iterable<Airline> itr = airlineRepository.save(airlineList);
+		assertThat(itr).isNotNull();
+		Iterable<Airline> itr2 = airlineRepository.findAll(Arrays.asList(a.getId(), b.getId(), c.getId()));
+		assertThat(itr2).isNotNull();
+		airlineRepository.delete(airlineList);
+	}
+
+	@Test
+	public void testDeleteAirlines() {
+		Iterable<Airline> itr = airlineRepository.save(Arrays.asList(a));
+		assertThat(itr).isNotNull();
+		airlineRepository.delete(a.getId());
+		Airline airline = airlineRepository.findOne(a.getId());
+		assertThat(airline).isNull();
+	}
+
+	@Test
+	public void testGetByName() {
+		Iterable<Airline> itr = airlineRepository.save(Arrays.asList(a));
+		assertThat(itr).isNotNull();
+		List<Airline> airlines = airlineRepository.findAirlineByName(a.getName());
+		assertThat(airlines.size()).isGreaterThanOrEqualTo(1);
+		assertThat(airlines.get(0)).isEqualTo(a);
+		airlineRepository.delete(a.getId());
+	}
+
+	@After
+	public void tearDown() {
+		airlineRepository.delete(airlineList);
+	}
+}