Build and Run

include::example$GetStartedWS/build.gradle.sample

    (1)
    // One-off initialization
    private void init() {
        CouchbaseLite.init();
    }

    (2)
    // Create a database
    public Database createDb(String dbName) throws CouchbaseLiteException {
        return new Database(dbName);
    }

    (3)
    // Create a new named collection (like a SQL table)
    // in the database's default scope.
    public Collection createCollection(Database database, String collName) throws CouchbaseLiteException {
        return database.createCollection(collName);
    }

    (4)
    // Create a new document (i.e. a record)
    // and save it in a collection in the database.
    public String createDoc(Collection collection) throws CouchbaseLiteException {
        MutableDocument mutableDocument = new MutableDocument()
            .setFloat("version", 2.0f)
            .setString("language", "Java");
        collection.save(mutableDocument);
        return mutableDocument.getId();
    }

    (5)
    // Retrieve immutable document and log the database generated
    // document ID and some document properties
    public Document retrieveDoc(Collection collection, String docId) throws CouchbaseLiteException {
        return collection.getDocument(docId);
    }

    (6)
    // Retrieve and update a document.
    public void updateDoc(Collection collection, String docId) throws CouchbaseLiteException {
        Document document = collection.getDocument(docId);
        if (document != null) {
            collection.save(
                document.toMutable().setString("language", "Kotlin"));
        }
    }

    (7)
    // Create a query to fetch documents with language == Kotlin.
    public List<Map<String, Object>> queryDocs(Collection collection) throws CouchbaseLiteException {
        Query query = QueryBuilder.select(SelectResult.all())
            .from(DataSource.collection(collection))
            .where(Expression.property("language").equalTo(Expression.string("Kotlin")));
        List<Map<String, Object>> results = new ArrayList<>();
        try (ResultSet rs = query.execute()) {
            for (Result result: rs) { results.add(result.toMap()); }
        }
        return results;
    }

    (8)
    // OPTIONAL -- if you have Sync Gateway Installed you can try replication too.
    // Create a replicator to push and pull changes to and from the cloud.
    // Be sure to hold a reference somewhere to prevent the Replicator from being GCed
    public Replication startReplicator(Collection collection, ReplicatorChangeListener listener)
        throws URISyntaxException {
        CollectionConfiguration collConfig = new CollectionConfiguration()
            .setPullFilter((doc, flags) -> "Java".equals(doc.getString("language")));

        ReplicatorConfiguration replConfig =
            new ReplicatorConfiguration(
                new URLEndpoint(new URI("ws://localhost:4984/getting-started-db")))
                .addCollection(collection, collConfig)
                .setType(ReplicatorType.PUSH_AND_PULL)
                .setAuthenticator(new BasicAuthenticator("sync-gateway", "password".toCharArray()));

        Replicator replicator = new Replicator(replConfig);

        // Listen to replicator change events.
        // Use `token.remove()` to stop the listener
        ListenerToken token = replicator.addChangeListener(listener);

        // Start replication.
        replicator.start();

        return new Replication(replicator, token);
    }


    public void stopReplicator(Replication replication) {
        if (replication == null) { return; }
        replication.token.remove();
        replication.replicator.stop();
    }
}

include::example$GetStartedWS/src/main/webapp/index.html

include::example$GetStartedWS/src/main/webapp/showDbItems.jsp