+
+### What is Couchmove?
+
+Couchmove is an open-source Java migration tool for [Couchbase](https://www.couchbase.com/), which is an NoSQL document-oriented database, well know for it's performance and scalability.
+
+Couchmove can help you *track*, *manage* and *apply changes* in your Couchbase buckets. The concept is very similar to other database migration tools such as [Liquibase](http://www.liquibase.org), [Flyway](http://flywaydb.org), [mongeez](https://github.com/secondmarket/mongeez), [mongobee](http://mongodb-tools.com/tool/mongobee/) ...
+
+### What's special?
+
+Couchmove is widely inspired from [Flyway](http://flywaydb.org) : it strongly favors simplicity and convention over configuration : There is *no XML configuration files*. Just **json documents**, **design documents** to import and **n1ql** files to execute.
+
+### How to use?
+
+Check out our [wiki](https://github.com/differentway/couchmove/wiki)
+
+---
+[](https://travis-ci.org/differentway/couchmove) [](https://sonarqube.com/dashboard/index/com.github.differentway:couchmove:develop) [](https://github.com/differentway/couchmove/blob/master/LICENSE)
diff --git a/pom.xml b/pom.xml
new file mode 100644
index 0000000..ebbe56b
--- /dev/null
+++ b/pom.xml
@@ -0,0 +1,219 @@
+
+
+
+ * CAS is for Check And Swap, which is an identifier that permit optimistic concurrency
+ */
+ @Nullable
+ @JsonIgnore
+ private Long cas;
+}
diff --git a/src/main/java/com/github/couchmove/pojo/Status.java b/src/main/java/com/github/couchmove/pojo/Status.java
new file mode 100644
index 0000000..9c71f43
--- /dev/null
+++ b/src/main/java/com/github/couchmove/pojo/Status.java
@@ -0,0 +1,25 @@
+package com.github.couchmove.pojo;
+
+/**
+ * Describes the current status of a {@link ChangeLog} execution
+ *
+ * @author ctayeb
+ * Created on 03/06/2017
+ */
+public enum Status {
+
+ /**
+ * The {@link ChangeLog} was successfully executed
+ */
+ EXECUTED,
+
+ /**
+ * The {@link ChangeLog} execution has failed
+ */
+ FAILED,
+
+ /**
+ * The {@link ChangeLog} execution was ignored
+ */
+ SKIPPED
+}
diff --git a/src/main/java/com/github/couchmove/pojo/Type.java b/src/main/java/com/github/couchmove/pojo/Type.java
new file mode 100644
index 0000000..0adeb6b
--- /dev/null
+++ b/src/main/java/com/github/couchmove/pojo/Type.java
@@ -0,0 +1,41 @@
+package com.github.couchmove.pojo;
+
+import com.couchbase.client.java.query.N1qlQuery;
+import com.couchbase.client.java.view.DesignDocument;
+import lombok.Getter;
+
+/**
+ * Describes the type of the {@link ChangeLog}
+ *
+ * @author ctayeb
+ * Created on 27/05/2017
+ */
+public enum Type {
+
+ /**
+ * json documents
+ */
+ DOCUMENTS(""),
+
+ /**
+ * json document representing a {@link DesignDocument}
+ */
+ DESIGN_DOC(Constants.JSON),
+
+ /**
+ * n1ql file containing a list of {@link N1qlQuery}
+ */
+ N1QL(Constants.N1QL);
+
+ @Getter
+ private final String extension;
+
+ Type(String extension) {
+ this.extension = extension;
+ }
+
+ public static class Constants {
+ public static final String JSON = "json";
+ public static final String N1QL = "n1ql";
+ }
+}
diff --git a/src/main/java/com/github/couchmove/repository/CouchbaseRepository.java b/src/main/java/com/github/couchmove/repository/CouchbaseRepository.java
new file mode 100644
index 0000000..a3f47ae
--- /dev/null
+++ b/src/main/java/com/github/couchmove/repository/CouchbaseRepository.java
@@ -0,0 +1,85 @@
+package com.github.couchmove.repository;
+
+import com.couchbase.client.java.Bucket;
+import com.couchbase.client.java.query.N1qlQuery;
+import com.couchbase.client.java.view.DesignDocument;
+import com.github.couchmove.pojo.CouchbaseEntity;
+
+/**
+ * A repository for encapsulating storage, retrieval, and removal of json documents to Couchbase {@link Bucket}
+ *
+ * @param
+ * Otherwise it {@link CouchbaseRepository#save(String, CouchbaseEntity)}
+ *
+ * @param id the per-bucket unique document id
+ * @param entity entity to convert and save
+ * @return saved entity with CAS
+ * @throws com.couchbase.client.java.error.CASMismatchException if the cas of entity is different from existing one
+ * @throws com.couchbase.client.java.error.DocumentAlreadyExistsException if the cas is not set and the document exists on couchbase
+ */
+ E checkAndSave(String id, E entity);
+
+ /**
+ * Removes a {@link CouchbaseEntity} from Couchbase Bucket identified by its id
+ *
+ * @param id the id of the document to remove
+ */
+ void delete(String id);
+
+ /**
+ * Retrieves a document from Couchbase {@link Bucket} by its ID.
+ *
+ * - If the document exists, convert it to {@link CouchbaseEntity} with CAS set (Check And Swap for optimistic concurrency)
+ *
+ * {@value PREFIX_ID} + {@link ChangeLog#version}
+ *
+ * @param changeLog The ChangeLog to save
+ * @return {@link ChangeLog} entity with CAS (Check And Swap, for optimistic concurrency) set
+ */
+ public ChangeLog save(ChangeLog changeLog) {
+ return repository.save(PREFIX_ID + changeLog.getVersion(), changeLog);
+ }
+
+ /**
+ * Inserts a {@link DesignDocument} into production
+ *
+ * @param name name of the {@link DesignDocument} to insert
+ * @param content the content of the {@link DesignDocument} to insert
+ */
+ public void importDesignDoc(String name, String content) {
+ logger.info("Inserting Design Document '{}'...", name);
+ repository.importDesignDoc(name, content);
+ }
+
+ /**
+ * Queries Couchbase {@link Bucket} with multiple {@link N1qlQuery}
+ *
+ * @param content containing multiple {@link N1qlQuery}
+ */
+ public void executeN1ql(String content) {
+ List
+ * Exemple : 188,100,312 {@link TimeUnit#MILLISECONDS} → 2d 4h 15m 15s 312ms
+ *
+ * @param duration duration to format
+ * @param timeUnit source timeUnit
+ * @return human readable duration format
+ */
+ public static String prettyFormatDuration(long duration, TimeUnit timeUnit) {
+ StringBuffer sb = new StringBuffer();
+ duration = appendUnit(sb, duration, timeUnit, DAYS/* */, "d", timeUnit::toDays);
+ duration = appendUnit(sb, duration, timeUnit, HOURS/* */, "h", timeUnit::toHours);
+ duration = appendUnit(sb, duration, timeUnit, MINUTES/* */, "min", timeUnit::toMinutes);
+ duration = appendUnit(sb, duration, timeUnit, SECONDS/* */, "s", timeUnit::toSeconds);
+ duration = appendUnit(sb, duration, timeUnit, MILLISECONDS, "ms", timeUnit::toMillis);
+ duration = appendUnit(sb, duration, timeUnit, MICROSECONDS, "μs", timeUnit::toMicros);
+ /* */
+ appendUnit(sb, duration, timeUnit, NANOSECONDS, "ns", timeUnit::toNanos);
+ return sb.toString();
+ }
+
+ private static long appendUnit(StringBuffer sb, long duration, TimeUnit source, TimeUnit destination, String unit, Function
+ * - Otherwise it return null
+ *
+ *
+ *
+ * @param changeLogs to load from database
+ * @return database version of changeLogs
+ * @throws CouchmoveException if checksum doesn't match
+ */
+ public List
+ *
+ *
+ *
+ *
+ * @param content content from where the requests are extracted
+ * @return multiple requests
+ */
+ static List