Skip to content

Commit 5792322

Browse files
gkorlandgkorland
authored
Pipeline (#127)
* replace "compact" "timeout" with constant
1 parent a066ee6 commit 5792322

File tree

2 files changed

+18
-18
lines changed

2 files changed

+18
-18
lines changed

‎src/main/java/com/redislabs/redisgraph/impl/api/RedisGraphPipeline.java‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -36,7 +36,7 @@ public RedisGraphPipeline(Client client, RedisGraph redisGraph){
3636
*/
3737
@Override
3838
public Response<ResultSet> query(String graphId, String query) {
39-
client.sendCommand(RedisGraphCommand.QUERY, graphId, query, "--COMPACT");
39+
client.sendCommand(RedisGraphCommand.QUERY, graphId, query, Utils.COMPACT_STRING);
4040
return getResponse(new Builder<ResultSet>() {
4141
@Override
4242
public ResultSet build(Object o) {
@@ -53,7 +53,7 @@ public ResultSet build(Object o) {
5353
*/
5454
@Override
5555
public Response<ResultSet> readOnlyQuery(String graphId, String query) {
56-
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, query, "--COMPACT");
56+
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, query, Utils.COMPACT_STRING);
5757
return getResponse(new Builder<ResultSet>() {
5858
@Override
5959
public ResultSet build(Object o) {
@@ -73,7 +73,7 @@ public ResultSet build(Object o) {
7373
*/
7474
@Override
7575
public Response<ResultSet> query(String graphId, String query, long timeout) {
76-
client.sendCommand(RedisGraphCommand.QUERY, graphId, query, "--COMPACT", "TIMEOUT", Long.toString(timeout));
76+
client.sendCommand(RedisGraphCommand.QUERY, graphId, query, Utils.COMPACT_STRING, Utils.TIMEOUT_STRING, Long.toString(timeout));
7777
return getResponse(new Builder<ResultSet>() {
7878
@Override
7979
public ResultSet build(Object o) {
@@ -93,7 +93,7 @@ public ResultSet build(Object o) {
9393
*/
9494
@Override
9595
public Response<ResultSet> readOnlyQuery(String graphId, String query, long timeout) {
96-
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, query, "--COMPACT", "TIMEOUT", Long.toString(timeout));
96+
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, query, Utils.COMPACT_STRING, Utils.TIMEOUT_STRING, Long.toString(timeout));
9797
return getResponse(new Builder<ResultSet>() {
9898
@Override
9999
public ResultSet build(Object o) {
@@ -115,7 +115,7 @@ public ResultSet build(Object o) {
115115
@Override
116116
public Response<ResultSet> query(String graphId, String query, Object ...args){
117117
String preparedQuery = Utils.prepareQuery(query, args);
118-
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, "--COMPACT");
118+
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, Utils.COMPACT_STRING);
119119
return getResponse(new Builder<ResultSet>() {
120120
@Override
121121
public ResultSet build(Object o) {
@@ -134,7 +134,7 @@ public ResultSet build(Object o) {
134134
@Override
135135
public Response<ResultSet> query(String graphId, String query, Map<String, Object> params) {
136136
String preparedQuery = Utils.prepareQuery(query, params);
137-
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, "--COMPACT");
137+
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, Utils.COMPACT_STRING);
138138
return getResponse(new Builder<ResultSet>() {
139139
@Override
140140
public ResultSet build(Object o) {
@@ -153,7 +153,7 @@ public ResultSet build(Object o) {
153153
@Override
154154
public Response<ResultSet> readOnlyQuery(String graphId, String query, Map<String, Object> params) {
155155
String preparedQuery = Utils.prepareQuery(query, params);
156-
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, preparedQuery, "--COMPACT");
156+
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, preparedQuery, Utils.COMPACT_STRING);
157157
return getResponse(new Builder<ResultSet>() {
158158
@Override
159159
public ResultSet build(Object o) {
@@ -176,7 +176,7 @@ public ResultSet build(Object o) {
176176
@Override
177177
public Response<ResultSet> query(String graphId, String query, Map<String, Object> params, long timeout) {
178178
String preparedQuery = Utils.prepareQuery(query, params);
179-
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, "--COMPACT", "TIMEOUT", Long.toString(timeout));
179+
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, Utils.COMPACT_STRING, Utils.TIMEOUT_STRING, Long.toString(timeout));
180180
return getResponse(new Builder<ResultSet>() {
181181
@Override
182182
public ResultSet build(Object o) {
@@ -199,7 +199,7 @@ public ResultSet build(Object o) {
199199
@Override
200200
public Response<ResultSet> readOnlyQuery(String graphId, String query, Map<String, Object> params, long timeout) {
201201
String preparedQuery = Utils.prepareQuery(query, params);
202-
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, preparedQuery, "--COMPACT", "TIMEOUT", Long.toString(timeout));
202+
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, preparedQuery, Utils.COMPACT_STRING, Utils.TIMEOUT_STRING, Long.toString(timeout));
203203
return getResponse(new Builder<ResultSet>() {
204204
@Override
205205
public ResultSet build(Object o) {

‎src/main/java/com/redislabs/redisgraph/impl/api/RedisGraphTransaction.java‎

Lines changed: 9 additions & 9 deletions
Original file line numberDiff line numberDiff line change
@@ -38,7 +38,7 @@ public RedisGraphTransaction(Client client, RedisGraph redisGraph){
3838
*/
3939
@Override
4040
public Response<ResultSet> query(String graphId, String query) {
41-
client.sendCommand(RedisGraphCommand.QUERY, graphId, query, "--COMPACT");
41+
client.sendCommand(RedisGraphCommand.QUERY, graphId, query, Utils.COMPACT_STRING);
4242
return getResponse(new Builder<ResultSet>() {
4343
@Override
4444
public ResultSet build(Object o) {
@@ -55,7 +55,7 @@ public ResultSet build(Object o) {
5555
*/
5656
@Override
5757
public Response<ResultSet> readOnlyQuery(String graphId, String query) {
58-
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, query, "--COMPACT");
58+
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, query, Utils.COMPACT_STRING);
5959
return getResponse(new Builder<ResultSet>() {
6060
@Override
6161
public ResultSet build(Object o) {
@@ -75,7 +75,7 @@ public ResultSet build(Object o) {
7575
*/
7676
@Override
7777
public Response<ResultSet> query(String graphId, String query, long timeout) {
78-
client.sendCommand(RedisGraphCommand.QUERY, graphId, query, "--COMPACT", "TIMEOUT", Long.toString(timeout));
78+
client.sendCommand(RedisGraphCommand.QUERY, graphId, query, Utils.COMPACT_STRING, Utils.TIMEOUT_STRING, Long.toString(timeout));
7979
return getResponse(new Builder<ResultSet>() {
8080
@Override
8181
public ResultSet build(Object o) {
@@ -95,7 +95,7 @@ public ResultSet build(Object o) {
9595
*/
9696
@Override
9797
public Response<ResultSet> readOnlyQuery(String graphId, String query, long timeout) {
98-
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, query, "--COMPACT", "TIMEOUT", Long.toString(timeout));
98+
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, query, Utils.COMPACT_STRING, Utils.TIMEOUT_STRING, Long.toString(timeout));
9999
return getResponse(new Builder<ResultSet>() {
100100
@Override
101101
public ResultSet build(Object o) {
@@ -117,7 +117,7 @@ public ResultSet build(Object o) {
117117
@Override
118118
public Response<ResultSet> query(String graphId, String query, Object ...args){
119119
String preparedQuery = Utils.prepareQuery(query, args);
120-
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, "--COMPACT");
120+
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, Utils.COMPACT_STRING);
121121
return getResponse(new Builder<ResultSet>() {
122122
@Override
123123
public ResultSet build(Object o) {
@@ -136,7 +136,7 @@ public ResultSet build(Object o) {
136136
@Override
137137
public Response<ResultSet> query(String graphId, String query, Map<String, Object> params) {
138138
String preparedQuery = Utils.prepareQuery(query, params);
139-
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, "--COMPACT");
139+
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, Utils.COMPACT_STRING);
140140
return getResponse(new Builder<ResultSet>() {
141141
@Override
142142
public ResultSet build(Object o) {
@@ -155,7 +155,7 @@ public ResultSet build(Object o) {
155155
@Override
156156
public Response<ResultSet> readOnlyQuery(String graphId, String query, Map<String, Object> params) {
157157
String preparedQuery = Utils.prepareQuery(query, params);
158-
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, preparedQuery, "--COMPACT");
158+
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, preparedQuery, Utils.COMPACT_STRING);
159159
return getResponse(new Builder<ResultSet>() {
160160
@Override
161161
public ResultSet build(Object o) {
@@ -178,7 +178,7 @@ public ResultSet build(Object o) {
178178
@Override
179179
public Response<ResultSet> query(String graphId, String query, Map<String, Object> params, long timeout) {
180180
String preparedQuery = Utils.prepareQuery(query, params);
181-
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, "--COMPACT", "TIMEOUT", Long.toString(timeout));
181+
client.sendCommand(RedisGraphCommand.QUERY, graphId, preparedQuery, Utils.COMPACT_STRING, Utils.TIMEOUT_STRING, Long.toString(timeout));
182182
return getResponse(new Builder<ResultSet>() {
183183
@Override
184184
public ResultSet build(Object o) {
@@ -201,7 +201,7 @@ public ResultSet build(Object o) {
201201
@Override
202202
public Response<ResultSet> readOnlyQuery(String graphId, String query, Map<String, Object> params, long timeout) {
203203
String preparedQuery = Utils.prepareQuery(query, params);
204-
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, preparedQuery, "--COMPACT", "TIMEOUT", Long.toString(timeout));
204+
client.sendCommand(RedisGraphCommand.RO_QUERY, graphId, preparedQuery, Utils.COMPACT_STRING, Utils.TIMEOUT_STRING, Long.toString(timeout));
205205
return getResponse(new Builder<ResultSet>() {
206206
@Override
207207
public ResultSet build(Object o) {

0 commit comments

Comments
 (0)