jdbc: metadata: support prepared statements

src/main/java/org/tarantool/Code.java

@@ -13,6 +13,8 @@ public enum Code  {
     UPSERT(9),
     CALL(10),
     EXECUTE(11),
+    PREPARE(13),
+    DEALLOCATE(13),
     PING(64),
     SUBSCRIBE(66);
 

src/main/java/org/tarantool/Key.java

@@ -29,10 +29,13 @@ public enum Key implements Callable<Integer> {
     SQL_FIELD_TYPE(0x1),
 
     SQL_METADATA(0x32),
+    SQL_BIND_METADATA(0x33),
+    SQL_BIND_COUNT(0x34),
     SQL_TEXT(0x40),
     SQL_BIND(0x41),
     SQL_OPTIONS(0x42),
     SQL_INFO(0x42),
+    SQL_STATEMENT_ID(0x43),
     SQL_ROW_COUNT(0x00),
     SQL_INFO_AUTOINCREMENT_IDS(0x01);
 

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

@@ -30,8 +30,17 @@ public static List<List<Object>> getSQLData(TarantoolPacket pack) {
         return (List<List<Object>>) pack.getBody().get(Key.DATA.getId());
     }
 
+    public static List<SQLMetaData> getSQLBindMetadata(TarantoolPacket pack) {
+        return getMetadata(pack, Key.SQL_BIND_METADATA);
+    }
+
     public static List<SQLMetaData> getSQLMetadata(TarantoolPacket pack) {
-        List<Map<Integer, Object>> meta = (List<Map<Integer, Object>>) pack.getBody().get(Key.SQL_METADATA.getId());
+        return getMetadata(pack, Key.SQL_METADATA);
+    }
+
+    private static List<SQLMetaData> getMetadata(TarantoolPacket pack, Key targetKey) {
+        List<Map<Integer, Object>> meta = (List<Map<Integer, Object>>) pack.getBody()
+            .getOrDefault(targetKey.getId(), Collections.emptyList());
         List<SQLMetaData> values = new ArrayList<>(meta.size());
         for (Map<Integer, Object> item : meta) {
             values.add(new SQLMetaData(
@@ -42,6 +51,10 @@ public static List<SQLMetaData> getSQLMetadata(TarantoolPacket pack) {
         return values;
     }
 
+    public static Long getStatementId(TarantoolPacket pack) {
+        return ((Number) pack.getBody().get(Key.SQL_STATEMENT_ID.getId())).longValue();
+    }
+
     public static Long getSQLRowCount(TarantoolPacket pack) {
         Map<Key, Object> info = (Map<Key, Object>) pack.getBody().get(Key.SQL_INFO.getId());
         Number rowCount;

src/main/java/org/tarantool/TarantoolClientImpl.java

@@ -554,7 +554,7 @@ protected void complete(TarantoolPacket packet, TarantoolOperation operation) {
                 } catch (TarantoolSchemaException cause) {
                     fail(target, cause);
                 }
-            } else if (operation.getCode() == Code.EXECUTE) {
+            } else if (operation.isSqlRelated()) {
                 completeSql(operation, packet);
             } else {
                 ((CompletableFuture) result).complete(packet.getData());
@@ -763,7 +763,7 @@ public TarantoolClientOps<Integer, List<?>, Object, TupleTwo<List<?>, Long>> uns
         return unsafeSchemaOps;
     }
 
-    protected TarantoolRequest makeSqlRequest(String sql, List<Object> bind) {
+    private TarantoolRequest makeSqlRequest(String sql, List<Object> bind) {
         return new TarantoolRequest(
             Code.EXECUTE,
             TarantoolRequestArgumentFactory.value(Key.SQL_TEXT),

src/main/java/org/tarantool/TarantoolOperation.java

@@ -113,6 +113,10 @@ public Code getCode() {
         return code;
     }
 
+    public boolean isSqlRelated() {
+        return code == Code.EXECUTE || code == Code.PREPARE;
+    }
+
     public TarantoolOperation getDependedOperation() {
         return dependedOperation;
     }