package dao;

import com.couchbase.client.java.Bucket;
import com.couchbase.client.java.Cluster;
import com.couchbase.client.java.CouchbaseCluster;
import com.couchbase.client.java.error.FlushDisabledException;
import util.Configuration;

/**
 * Created by jeremy on 09/04/15.
 */
public class DAOManager {

    /**
     * Current Connection
     */
    protected static Cluster currentCluster = CouchbaseCluster.create(Configuration.COUCHBASE_HOSTNAME);

    /**
     * Instance of the DAOManager
     */
    private static DAOManager instance = new DAOManager();

    /**
     * Current Bucket
     */
    protected static Bucket currentBucket;

    public static void connect(){
        if (currentCluster != null && currentBucket==null) {
            // Open a bucket
            currentBucket = currentCluster.openBucket(Configuration.BUCKET_NAME);
        }
    }

    public static void connectTest(){
        if (currentCluster != null && currentBucket==null) {
            // Open a bucket
            currentBucket = currentCluster.openBucket(Configuration.BUCKET_NAME_TEST);
        }
    }

    public static void disconnect() {
        if(currentCluster != null)
        {
            if (currentBucket.close()){
                currentBucket = null;
            }
        }
    }


    /**
     * flush our bucket
     * @return
     */
    public static boolean flush()
    {
        if(currentBucket!=null && currentCluster!=null)
        {
            try
            {
                return currentBucket.bucketManager().flush();
            }
            catch (FlushDisabledException e)
            {
                e.printStackTrace();
                return false;
            }
        }
        return false;
    }

    public static Bucket getCurrentBucket() {
        return currentBucket;
    }
}

package dao;

import com.couchbase.client.java.Bucket;
import com.couchbase.client.java.Cluster;
import com.couchbase.client.java.CouchbaseCluster;
import com.couchbase.client.java.error.FlushDisabledException;
import util.Configuration;

/**
 * Created by jeremy on 09/04/15.
 */
public class DAOManager {

    /**
     * Current Connection
     */
    protected static Cluster currentCluster = CouchbaseCluster.create(Configuration.COUCHBASE_HOSTNAME);

    /**
     * Instance of the DAOManager
     */
    private static DAOManager instance = new DAOManager();

    /**
     * Current Bucket
     */
    protected static Bucket currentBucket;

    public static void connect(){
        if (currentCluster != null && currentBucket==null) {
            // Open a bucket
            currentBucket = currentCluster.openBucket(Configuration.BUCKET_NAME);
        }
    }

    public static void connectTest(){
        if (currentCluster != null && currentBucket==null) {
            // Open a bucket
            currentBucket = currentCluster.openBucket(Configuration.BUCKET_NAME_TEST);
        }
    }

    public static void disconnect() {
        if(currentCluster != null)
        {
            if (currentBucket != null && currentBucket.close()){
                currentBucket = null;
            }
        }
    }


    /**
     * flush our bucket
     * @return
     */
    public static boolean flush()
    {
        if(currentBucket!=null && currentCluster!=null)
        {
            try
            {
                return currentBucket.bucketManager().flush();
            }
            catch (FlushDisabledException e)
            {
                e.printStackTrace();
                return false;
            }
        }
        return false;
    }

    public static Bucket getCurrentBucket() {
        return currentBucket;
    }
}

patch on DAO