Replace TConnection with TClientImpl in JDBC

README.md

@@ -126,13 +126,22 @@ Feel free to override any method of `TarantoolClientImpl`. For example, to hook
 all the results, you could override this:
 
 ```java
-protected void complete(long code, CompletableFuture<?> q);
+protected void complete(TarantoolPacket packet, TarantoolOp<?> future);
 ```
 
 ## Spring NamedParameterJdbcTemplate usage example
 
-To configure sockets you should implements SQLSocketProvider and add socketProvider=abc.xyz.MySocketProvider to connect url.
-For example tarantool://localhost:3301?user=test&password=test&socketProvider=abc.xyz.MySocketProvider
+The JDBC driver uses `TarantoolClient` implementation to provide a communication with server.
+To configure socket channel provider you should implements SocketChannelProvider and add
+`socketChannelProvider=abc.xyz.MySocketChannelProvider` to connect url.
+
+For example:
+
+```
+tarantool://localhost:3301?user=test&password=test&socketProvider=abc.xyz.MySocketProvider
+```
+
+Here is an example how you can use the driver covered by Spring `DriverManagerDataSource`:
 
 ```java
 NamedParameterJdbcTemplate template = new NamedParameterJdbcTemplate(new DriverManagerDataSource("tarantool://localhost:3301?user=test&password=test"));

src/main/java/org/tarantool/SqlProtoUtils.java

@@ -9,10 +9,10 @@
 
 public abstract class SqlProtoUtils {
     public static List<Map<String, Object>> readSqlResult(TarantoolPacket pack) {
-        List<List<?>> data = (List<List<?>>) pack.getBody().get(Key.DATA.getId());
+        List<List<Object>> data = getSQLData(pack);
+        List<SQLMetaData> metaData = getSQLMetadata(pack);
 
         List<Map<String, Object>> values = new ArrayList<>(data.size());
-        List<SQLMetaData> metaData = getSQLMetadata(pack);
         for (List row : data) {
             LinkedHashMap<String, Object> value = new LinkedHashMap<>();
             for (int i = 0; i < row.size(); i++) {

src/main/java/org/tarantool/TarantoolBase.java

@@ -11,10 +11,6 @@
 
 public abstract class TarantoolBase<Result> extends AbstractTarantoolOps<Integer, List<?>, Object, Result> {
     protected String serverVersion;
-
-    /**
-     * Connection state.
-     */
     protected MsgPackLite msgPackLite = MsgPackLite.INSTANCE;
     protected AtomicLong syncId = new AtomicLong();
     protected int initialRequestSize = 4096;
@@ -25,7 +21,7 @@ public TarantoolBase() {
     public TarantoolBase(String username, String password, Socket socket) {
         super();
         try {
-            TarantoolGreeting greeting = ProtoUtils.connect(socket, username, password);
+            TarantoolGreeting greeting = ProtoUtils.connect(socket, username, password, msgPackLite);
             this.serverVersion = greeting.getServerVersion();
         } catch (IOException e) {
             throw new CommunicationException("Couldn't connect to tarantool", e);

src/main/java/org/tarantool/TarantoolClient.java

@@ -23,6 +23,8 @@ public interface TarantoolClient {
 
     boolean isAlive();
 
+    boolean isClosed();
+
     void waitAlive() throws InterruptedException;
 
     boolean waitAlive(long timeout, TimeUnit unit) throws InterruptedException;

src/main/java/org/tarantool/TarantoolClientConfig.java

@@ -2,6 +2,8 @@
 
 public class TarantoolClientConfig {
 
+    public static final int DEFAULT_OPERATION_EXPIRY_TIME_MILLIS = 1000;
+
     /**
      * Auth-related data.
      */
@@ -67,4 +69,9 @@ public class TarantoolClientConfig {
      */
     public int retryCount = 3;
 
+    /**
+     * Operation expiration period.
+     */
+    public int operationExpiryTimeMillis = DEFAULT_OPERATION_EXPIRY_TIME_MILLIS;
+
 }