From 00642d899955adad3269a7d24cc3f744973663ad Mon Sep 17 00:00:00 2001 From: Guy Korland Date: Mon, 27 Nov 2023 13:41:34 +0200 Subject: [PATCH] clean warns --- src/main/java/com/falkordb/impl/api/AbstractGraph.java | 6 ++++++ src/main/java/com/falkordb/impl/api/GraphPipeline.java | 5 ++++- src/main/java/com/falkordb/impl/api/GraphTransaction.java | 5 ++++- 3 files changed, 14 insertions(+), 2 deletions(-) diff --git a/src/main/java/com/falkordb/impl/api/AbstractGraph.java b/src/main/java/com/falkordb/impl/api/AbstractGraph.java index d2c2c80..e32eb41 100644 --- a/src/main/java/com/falkordb/impl/api/AbstractGraph.java +++ b/src/main/java/com/falkordb/impl/api/AbstractGraph.java @@ -59,6 +59,7 @@ public abstract class AbstractGraph implements Graph { * @param query Cypher query * @return a result set */ + @Override public ResultSet query(String graphId, String query) { return sendQuery(graphId, query); } @@ -69,6 +70,7 @@ public ResultSet query(String graphId, String query) { * @param query Cypher query * @return a result set */ + @Override public ResultSet readOnlyQuery(String graphId, String query) { return sendReadOnlyQuery(graphId, query); } @@ -130,6 +132,7 @@ public ResultSet query(String graphId, String query, Map params) * @param params parameters map. * @return a result set. */ + @Override public ResultSet readOnlyQuery(String graphId, String query, Map params) { String preparedQuery = Utils.prepareQuery(query, params); return sendReadOnlyQuery(graphId, preparedQuery); @@ -163,14 +166,17 @@ public ResultSet readOnlyQuery(String graphId, String query, Map return sendReadOnlyQuery(graphId, preparedQuery, timeout); } + @Override public ResultSet callProcedure(String graphId, String procedure){ return callProcedure(graphId, procedure, Utils.DUMMY_LIST, Utils.DUMMY_MAP); } + @Override public ResultSet callProcedure(String graphId, String procedure, List args){ return callProcedure(graphId, procedure, args, Utils.DUMMY_MAP); } + @Override public ResultSet callProcedure(String graphId, String procedure, List args , Map> kwargs){ String preparedProcedure = Utils.prepareProcedure(procedure, args, kwargs); diff --git a/src/main/java/com/falkordb/impl/api/GraphPipeline.java b/src/main/java/com/falkordb/impl/api/GraphPipeline.java index c52e84c..1aea841 100644 --- a/src/main/java/com/falkordb/impl/api/GraphPipeline.java +++ b/src/main/java/com/falkordb/impl/api/GraphPipeline.java @@ -205,6 +205,7 @@ public ResultSet build(Object o) { * @param procedure procedure name to invoke * @return response with result set with the procedure data */ + @Override public Response callProcedure(String graphId, String procedure){ return callProcedure(graphId, procedure, Utils.DUMMY_LIST, Utils.DUMMY_MAP); } @@ -216,11 +217,11 @@ public Response callProcedure(String graphId, String procedure){ * @param args procedure arguments * @return response with result set with the procedure data */ + @Override public Response callProcedure(String graphId, String procedure, List args ){ return callProcedure(graphId, procedure, args, Utils.DUMMY_MAP); } - /** * Invoke a stored procedure * @param graphId a graph to perform the query on @@ -229,6 +230,7 @@ public Response callProcedure(String graphId, String procedure, List< * @param kwargs - procedure output arguments * @return response with result set with the procedure data */ + @Override public Response callProcedure(String graphId, String procedure, List args, Map> kwargs) { String preparedProcedure = Utils.prepareProcedure(procedure, args, kwargs); @@ -241,6 +243,7 @@ public Response callProcedure(String graphId, String procedure, List< * @param graphId graph to delete * @return response with the deletion running time statistics */ + @Override public Response deleteGraph(String graphId){ client.sendCommand(GraphCommand.DELETE, graphId); diff --git a/src/main/java/com/falkordb/impl/api/GraphTransaction.java b/src/main/java/com/falkordb/impl/api/GraphTransaction.java index e73c89e..a1c25b3 100644 --- a/src/main/java/com/falkordb/impl/api/GraphTransaction.java +++ b/src/main/java/com/falkordb/impl/api/GraphTransaction.java @@ -227,6 +227,7 @@ public ResultSet build(Object o) { * @param procedure procedure name to invoke * @return response with result set with the procedure data */ + @Override public Response callProcedure(String graphId, String procedure) { return callProcedure(graphId, procedure, Utils.DUMMY_LIST, Utils.DUMMY_MAP); } @@ -238,6 +239,7 @@ public Response callProcedure(String graphId, String procedure) { * @param args procedure arguments * @return response with result set with the procedure data */ + @Override public Response callProcedure(String graphId, String procedure, List args) { return callProcedure(graphId, procedure, args, Utils.DUMMY_MAP); } @@ -250,6 +252,7 @@ public Response callProcedure(String graphId, String procedure, List< * @param kwargs - procedure output arguments * @return response with result set with the procedure data */ + @Override public Response callProcedure(String graphId, String procedure, List args, Map> kwargs) { String preparedProcedure = Utils.prepareProcedure(procedure, args, kwargs); @@ -261,6 +264,7 @@ public Response callProcedure(String graphId, String procedure, List< * @param graphId graph to delete * @return response with the deletion running time statistics */ + @Override public Response deleteGraph(String graphId) { client.sendCommand(GraphCommand.DELETE, graphId); Response response = getResponse(BuilderFactory.STRING); @@ -272,5 +276,4 @@ public Response deleteGraph(String graphId) { public void setGraphCaches(GraphCaches caches) { this.caches = caches; } - }