MemcachedClient c=new MemcachedClient(new BinaryConnectionFactory(), AddrUtil.getAddresses("192.168.56.102:11211 192.168.56.103:11211"));

package jdbcdemo6;
 
// MD5
import java.security.MessageDigest;
import java.security.NoSuchAlgorithmException;
 
//MySQL client
import com.mysql.jdbc.Driver;
import java.util.Properties;
import java.sql.ResultSet;
import java.sql.Connection;
import java.sql.SQLException;
import java.util.Random;
import java.util.concurrent.TimeUnit;
 
//Couchbase client
import com.couchbase.client.java.*;
import com.couchbase.client.java.document.JsonDocument;
import com.couchbase.client.java.document.json.JsonObject;
 
public class jdbcdemo6 {
 
	private static String MD5encode(String string1)
	{
		String md5=null;
 
		if (string1 == null) return null;
 
		try {
			MessageDigest digest1 = MessageDigest.getInstance("MD5");
			byte[] hash = digest1.digest(string1.getBytes());
			StringBuilder sb = new StringBuilder(2*hash.length);
 
			digest1.update(string1.getBytes());
			for(byte b : hash)
			{
				sb.append(String.format("%02x", b&0xff));
			}
			md5=sb.toString();
		}
		catch (NoSuchAlgorithmException e)
		{
			e.printStackTrace();
		}
		return md5;
	}
 
	public static void main(String[] args) throws Exception {
		Driver driver = new Driver();
		Properties props = new Properties();
		ResultSet rs;
		Connection conn = null;
		String JDBC_URL = "jdbc:mysql://192.168.56.101:3322", query1, query1_md5;
		Random generator = new Random();
		JsonDocument document1=null;
		JsonObject object1=null;
		int in_couchbase=0, not_in_couchbase=0, id;
 
		// Connect to a Couchbase cluster
		Cluster cluster = CouchbaseCluster.create("192.168.56.102", "192.168.56.103", "192.168.56.104");
		Bucket bucket=cluster.openBucket("default");
 
		long start_time = System.currentTimeMillis();
		props.put("user","yjaquier");
		props.put("password","secure_password");
 
		System.out.println("------------ MySQL Connector/J JDBC connection testing ------------\n");
		System.out.println("Trying connection...\n");
 
		// Get JDBC connection
		try {
			conn = driver.connect(JDBC_URL, props);
		  }
		catch (SQLException e) {
			e.printStackTrace();
			System.exit(1);
		}
 
		// Looping and executing queries and try to get first the result from Couchbase server
		for(int i=1; i <= 1000; i++) {
			id=generator.nextInt(30000) + 1;
			System.out.print("\nQuery "+i+" for id="+id+", ");
			query1="SELECT firstname,lastname FROM test.customers where id="+id;
			query1_md5=MD5encode(query1);
 
			try {
				document1=bucket.get(query1_md5, 5, TimeUnit.SECONDS);
			}
			catch (RuntimeException e) {
				System.out.println("Couchbase server timeout...");
			}
			if (document1==null) {
				System.out.print("Query result not in Couchbase, ");
				not_in_couchbase++;
				rs = conn.createStatement().executeQuery(query1);
				while (rs.next()) {
					System.out.print("customer : " + rs.getString("firstname")+", "+rs.getString("lastname"));
					object1=JsonObject.empty().put("firstname", rs.getString("firstname")).put("lastname", rs.getString("lastname"));
					bucket.upsert(JsonDocument.create(query1_md5, object1));
				}
				rs.close();
			}
			else  {
				System.out.print("Query result in Couchbase, ");
				in_couchbase++;
				System.out.print("customer : " + document1.content().getString("firstname")+", "+document1.content().getString("lastname"));
			}
		}
 
		System.out.println("\nExiting...");
		if (conn != null) {
			conn.close();
		}
 
		long end_time = System.currentTimeMillis();
 
		System.out.println("Executed in " + (end_time - start_time) + " milliseconds");
		System.out.println("Percentage in Couchbase "+Math.round(in_couchbase*100/(in_couchbase+not_in_couchbase))+"% ("+in_couchbase+"), not in Couchbase "+
							Math.round(not_in_couchbase*100/(in_couchbase+not_in_couchbase))+"% ("+not_in_couchbase+")");
	}
}