refactor(jdbc): decouple from databend-client.

 refactor(jdbc): decouple from databend-client.

Author: youngsofun

databend-jdbc/pom.xml

@@ -15,11 +15,6 @@
     <packaging>jar</packaging>
 
     <dependencies>
-        <dependency>
-            <groupId>com.databend</groupId>
-            <artifactId>databend-client</artifactId>
-            <version>0.4.6</version>
-        </dependency>
         <dependency>
             <groupId>com.squareup.okhttp3</groupId>
             <artifactId>okhttp</artifactId>
@@ -38,6 +33,10 @@
             <groupId>com.fasterxml.jackson.core</groupId>
             <artifactId>jackson-databind</artifactId>
         </dependency>
+        <dependency>
+            <groupId>com.fasterxml.jackson.datatype</groupId>
+            <artifactId>jackson-datatype-jdk8</artifactId>
+        </dependency>
         <dependency>
             <groupId>com.vdurmont</groupId>
             <artifactId>semver4j</artifactId>

databend-jdbc/src/main/java/com/databend/jdbc/AbstractDatabendResultSet.java

@@ -1,13 +1,13 @@
 package com.databend.jdbc;
 
-import com.databend.client.QueryResults;
-import com.databend.client.QueryRowField;
-import com.databend.client.data.DatabendDataType;
-import com.databend.client.data.DatabendRawType;
-import com.databend.client.data.DatabendTypes;
-import com.databend.client.errors.QueryErrors;
+import com.databend.jdbc.internal.data.DatabendDataType;
+import com.databend.jdbc.internal.data.DatabendRawType;
+import com.databend.jdbc.internal.data.DatabendTypes;
+import com.databend.jdbc.internal.data.IntervalCodec;
+import com.databend.jdbc.internal.error.QueryError;
+import com.databend.jdbc.internal.query.QueryResults;
+import com.databend.jdbc.internal.query.QueryRowField;
 import com.databend.jdbc.annotation.NotImplemented;
-import com.databend.jdbc.exception.DatabendUnsupportedOperationException;
 import com.databend.jdbc.exception.DatabendSQLException;
 import com.google.common.collect.ImmutableList;
 import com.google.common.collect.ImmutableMap;
@@ -150,7 +150,7 @@ private static BigDecimal parseBigDecimal(String value)
     }
 
     static SQLException resultsException(QueryResults results, String originalSQL) {
-        QueryErrors error = requireNonNull(results.getError());
+        QueryError error = requireNonNull(results.getError());
         String message = format("SQL: (%s) Query failed (query_id=%s): %s", originalSQL, results.getQueryId(), error.getMessage());
         return new SQLException(message, String.valueOf(error.getCode()));
     }
@@ -724,7 +724,7 @@ public Object getObject(int columnIndex)
             if (!(value instanceof String)) {
                 throw new SQLDataException("Interval value is not textual: " + value.getClass().getName());
             }
-            return Interval.decode((String) value);
+            return IntervalCodec.decode((String) value);
         }
         return value;
     }
@@ -1411,7 +1411,7 @@ public void updateRowId(String columnLabel, RowId x)
     @Override
     @NotImplemented
     public int getHoldability() throws SQLException {
-        throw new DatabendUnsupportedOperationException();
+        throw new SQLFeatureNotSupportedException("getHoldability");
     }
 
     @Override

databend-jdbc/src/main/java/com/databend/jdbc/ConnectionProperties.java

@@ -1,6 +1,6 @@
 package com.databend.jdbc;
 
-import com.databend.client.PaginationOptions;
+import com.databend.jdbc.internal.session.PaginationOptions;
 import com.google.common.collect.ImmutableMap;
 import com.google.common.collect.ImmutableSet;
 

databend-jdbc/src/main/java/com/databend/jdbc/DatabendColumnInfo.java

@@ -1,7 +1,7 @@
 package com.databend.jdbc;
 
-import com.databend.client.data.DatabendRawType;
-import com.databend.client.data.DatabendTypes;
+import com.databend.jdbc.internal.data.DatabendRawType;
+import com.databend.jdbc.internal.data.DatabendTypes;
 import com.google.common.base.Preconditions;
 import com.google.common.base.Strings;
 import com.google.common.collect.ImmutableList;