Merge pull request vitessio#1113 from yaoshengzhe/add_execute_batch_i…

…n_java Add executeBatchKeyspaceIds for vtgate-client
riseofthetigers · Sep 18, 2015 · def9738 · def9738
2 parents 68c37a3 + 58275fa
commit def9738
Show file tree

Hide file tree

Showing 2 changed files with 11 additions and 0 deletions.
diff --git a/java/vtgate-client/src/main/java/com/youtube/vitess/vtgate/rpcclient/RpcClient.java b/java/vtgate-client/src/main/java/com/youtube/vitess/vtgate/rpcclient/RpcClient.java
@@ -1,5 +1,6 @@
 package com.youtube.vitess.vtgate.rpcclient;
 
+import com.youtube.vitess.proto.Vtgate.Session;
 import com.youtube.vitess.vtgate.Exceptions.ConnectionException;
 import com.youtube.vitess.vtgate.Field;
 import com.youtube.vitess.vtgate.Query;
@@ -20,6 +21,9 @@ public interface RpcClient {
 
   public QueryResponse execute(Query query) throws ConnectionException;
 
+  public List<QueryResponse> executeBatchKeyspaceIds(
+          List<Query> queries, String tabletType, Session session, boolean asTransaction);
+
   public QueryResult streamNext(List<Field> fields) throws ConnectionException;
 
   public SplitQueryResponse splitQuery(SplitQueryRequest request) throws ConnectionException;

diff --git a/java/vtgate-client/src/main/java/com/youtube/vitess/vtgate/rpcclient/gorpc/GoRpcClient.java b/java/vtgate-client/src/main/java/com/youtube/vitess/vtgate/rpcclient/gorpc/GoRpcClient.java
@@ -4,6 +4,7 @@
 import com.youtube.vitess.gorpc.Exceptions.ApplicationException;
 import com.youtube.vitess.gorpc.Exceptions.GoRpcException;
 import com.youtube.vitess.gorpc.Response;
+import com.youtube.vitess.proto.Vtgate.Session;
 import com.youtube.vitess.vtgate.Exceptions.ConnectionException;
 import com.youtube.vitess.vtgate.Field;
 import com.youtube.vitess.vtgate.Query;
@@ -57,6 +58,12 @@ public QueryResponse execute(Query query) throws ConnectionException {
     return Bsonify.bsonToQueryResponse((BSONObject) response.getReply());
   }
 
+  @Override
+  public List<QueryResponse> executeBatchKeyspaceIds(
+          List<Query> queries, String tabletType, Session session, boolean asTransaction) {
+    throw new UnsupportedOperationException();
+  }
+
   @Override
   public QueryResult streamNext(List<Field> fields) throws ConnectionException {
     Response response;