-
Notifications
You must be signed in to change notification settings - Fork 478
/
Query.java
118 lines (105 loc) · 2.74 KB
/
Query.java
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
package org.influxdb.dto;
import java.io.UnsupportedEncodingException;
import java.net.URLEncoder;
import java.nio.charset.StandardCharsets;
/**
* Represents a Query against Influxdb.
*
* @author stefan.majer [at] gmail.com
*
*/
public class Query {
private final String command;
private final String database;
private final boolean requiresPost;
/**
* @param command the query command
*/
public Query(final String command) {
this(command, null);
}
/**
* @param command the query command
* @param database the database to query
*/
public Query(final String command, final String database) {
this(command, database, false);
}
/**
* @param command the query command
* @param database the database to query
* @param requiresPost true if the command requires a POST instead of GET to influxdb
*/
public Query(final String command, final String database, final boolean requiresPost) {
super();
this.command = command;
this.database = database;
this.requiresPost = requiresPost;
}
/**
* @return the command
*/
public String getCommand() {
return command;
}
/**
* @return url encoded command
*/
public String getCommandWithUrlEncoded() {
return encode(command);
}
/**
* @return the database
*/
public String getDatabase() {
return database;
}
public boolean requiresPost() {
return requiresPost;
}
@SuppressWarnings("checkstyle:avoidinlineconditionals")
@Override
public int hashCode() {
final int prime = 31;
int result = 1;
result = prime * result + ((command == null) ? 0 : command.hashCode());
result = prime * result
+ ((database == null) ? 0 : database.hashCode());
return result;
}
@SuppressWarnings("checkstyle:needbraces")
@Override
public boolean equals(final Object obj) {
if (this == obj)
return true;
if (obj == null)
return false;
if (getClass() != obj.getClass())
return false;
Query other = (Query) obj;
if (command == null) {
if (other.command != null)
return false;
} else if (!command.equals(other.command))
return false;
if (database == null) {
if (other.database != null)
return false;
} else if (!database.equals(other.database))
return false;
return true;
}
/**
* Encode a command into {@code x-www-form-urlencoded} format.
* @param command
* the command to be encoded.
* @return a encoded command.
*/
public static String encode(final String command) {
try {
return URLEncoder.encode(command, StandardCharsets.UTF_8.name());
} catch (UnsupportedEncodingException e) {
throw new IllegalStateException("Every JRE must support UTF-8", e);
}
}
}