Rework the driver to behave as a very basic wrapper of Couchbase Java client

* The only one column ("result") in a result set, containing resulting JSON converted to Java's Map<String, Object>
* No Database meta information for now except database version

Author: dxahtepb

build.gradle

@@ -2,7 +2,7 @@ plugins {
     id 'java'
 }
 
-version '1.3.5'
+version '0.1.0'
 
 sourceCompatibility = 1.8
 
@@ -27,7 +27,7 @@ sourceSets {
 }
 
 dependencies {
-    compile group: 'com.datastax.cassandra', name: 'cassandra-driver-core', version: '3.6.0'
+    compile 'com.couchbase.client:java-client:3.0.5'
     testCompile group: 'junit', name: 'junit', version: '4.12'
 }
 

driver/src/main/java/com/dbschema/CassandraJdbcDriver.java

@@ -1,22 +1,25 @@
 package com.dbschema;
 
-import com.datastax.driver.core.BatchStatement;
-import com.datastax.driver.core.Session;
-import com.datastax.driver.core.exceptions.SyntaxError;
+import com.couchbase.client.java.Cluster;
+import com.couchbase.client.java.query.QueryResult;
 
-import java.sql.*;
+import java.sql.Connection;
+import java.sql.ResultSet;
+import java.sql.SQLException;
+import java.sql.SQLFeatureNotSupportedException;
+import java.sql.SQLWarning;
+import java.sql.Statement;
 
 /**
  * @author Liudmila Kornilova
  **/
-public abstract class CassandraBaseStatement implements Statement {
-    final com.datastax.driver.core.Session session;
-    BatchStatement batchStatement = null;
+public abstract class CouchbaseBaseStatement implements Statement {
+    final Cluster cluster;
     private boolean isClosed = false;
-    CassandraResultSet result;
+    CouchbaseResultSet result;
 
-    CassandraBaseStatement(Session session) {
-        this.session = session;
+    CouchbaseBaseStatement(Cluster cluster) {
+        this.cluster = cluster;
     }
 
     @Override
@@ -35,16 +38,10 @@ public boolean isClosed() {
         return isClosed;
     }
 
-    boolean executeInner(com.datastax.driver.core.ResultSet resultSet, boolean returnNullStrings) throws SQLException {
+    boolean executeInner(QueryResult resultSet, boolean returnNullStrings) throws SQLException {
         try {
-            result = new CassandraResultSet(this, resultSet, returnNullStrings);
-            if (!result.isQuery()) {
-                result = null;
-                return false;
-            }
+            result = new CouchbaseResultSet(this, resultSet, returnNullStrings);
             return true;
-        } catch (SyntaxError ex) {
-            throw new SQLSyntaxErrorException(ex.getMessage(), ex);
         } catch (Throwable t) {
             throw new SQLException(t.getMessage(), t);
         }
@@ -64,20 +61,7 @@ public int getUpdateCount() throws SQLException {
 
     @Override
     public int[] executeBatch() throws SQLException {
-        if (batchStatement == null) throw new SQLException("No batch statements were submitted");
-        int statementsCount = batchStatement.size();
-        try {
-            session.execute(batchStatement);
-        } catch (Throwable t) {
-            throw new SQLException(t.getMessage(), t);
-        } finally {
-            batchStatement = null;
-        }
-        int[] res = new int[statementsCount];
-        for (int i = 0; i < statementsCount; i++) {
-            res[i] = SUCCESS_NO_INFO;
-        }
-        return res;
+        throw new SQLFeatureNotSupportedException();
     }
 
     @Override
@@ -152,7 +136,7 @@ public void setQueryTimeout(int seconds) throws SQLException {
 
     @Override
     public void cancel() throws SQLException {
-        throw new SQLFeatureNotSupportedException("Cassandra provides no support for interrupting an operation.");
+        throw new SQLFeatureNotSupportedException("Couchbase provides no support for interrupting an operation.");
     }
 
     @Override