本文整理了Java中org.geoserver.monitor.Query
类的一些代码示例,展示了Query
类的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。Query
类的具体详情如下:
包路径:org.geoserver.monitor.Query
类名称:Query
暂无
代码示例来源:origin: org.geoserver.extension/monitor-hibernate
@Test
public void testGetRequestsFilterAnd() throws Exception {
assertEquals(1, dao.getRequests(new Query().filter("path", "/foo", Comparison.EQ)
.filter("widgets", "resources", Comparison.IN)).size());
}
代码示例来源:origin: org.geoserver.extension/monitor-hibernate
@Test
public void testGetRequestsJoinIN() throws Exception {
List<String> resources = Arrays.asList("widgets", "things");
List<RequestData> datas = dao.getRequests(new Query().properties("resource")
.aggregate("count()").filter("resource", resources, Comparison.IN)
.group("resource").sort("resource", SortOrder.ASC));
assertEquals(2, datas.size());
assertEquals("things", datas.get(0).getResources().get(0));
assertEquals("widgets", datas.get(1).getResources().get(0));
}
代码示例来源:origin: org.geoserver.extension/gs-monitor-core
@Test
public void testGetRequestsPaged() throws Exception {
List<RequestData> datas =
dao.getRequests(new Query().page(5l, 2l).sort("startTime", SortOrder.ASC));
assertCoveredInOrder(datas, 6, 7);
}
代码示例来源:origin: org.geoserver.community/gs-monitor-hibernate
public long getCount(Query q) {
q = q.clone();
q.getAggregates().clear();
q.getProperties().clear();
q.getGroupBy().clear();
q.setSortBy(null);
q.setSortOrder(null);
q.aggregate("count()");
org.hibernate.Query query = toQuery(q);
long count = ((Number) query.uniqueResult()).longValue();
// factor in offset, count
if (q.getOffset() != null) {
count = Math.max(0, count - q.getOffset());
}
if (q.getCount() != null) {
count = Math.min(count, q.getCount());
}
return count;
}
代码示例来源:origin: org.geoserver.extension/monitor-hibernate
@Test
public void testGetRequestsCount() throws Exception {
final List<Object> aggs = new ArrayList();
RequestDataVisitor v = new RequestDataVisitor() {
public void visit(RequestData data, Object... aggregates) {
aggs.addAll(Arrays.asList(aggregates));
}
};
dao.getRequests(new Query().aggregate("count()").filter("path","/foo", Comparison.EQ), v);
assertEquals(1, aggs.size());
assertEquals(4, ((Number)aggs.get(0)).intValue());
}
代码示例来源:origin: org.geoserver.extension/monitor-core
@Test
public void testGetRequestsSorted() throws Exception {
assertCoveredInOrder(dao.getRequests(new Query().filter("id", 11l, Comparison.LT)
.sort("path", SortOrder.ASC)), 8, 5, 4, 9, 1, 7, 6, 10, 3, 2);
}
代码示例来源:origin: org.geoserver.extension/gs-monitor-core
@Test
public void testGetRequestsBetween2() throws Exception {
// test that the query is inclusive, and test sorting
List<RequestData> datas =
dao.getRequests(
new Query()
.between(
toDate("2010-07-23T15:56:44"),
toDate("2010-07-23T16:16:44"))
.sort("startTime", SortOrder.ASC));
assertCoveredInOrder(datas, 4, 5, 6);
}
代码示例来源:origin: org.geoserver.extension/monitor-core
@Test
public void testToQueryString() throws Exception {
Date from = toDate("2010-07-23T15:56:44");
Date to = toDate("2010-07-23T16:16:44");
Query q = new Query().between(from, to);
q.filter("service", "WFS", Comparison.EQ).and("status", "RUNNING", Comparison.EQ)
.and("path", Arrays.asList("/foo", "/bar"), Comparison.IN);
String qs = RequestResource.toQueryString(q);
assertEquals('?', qs.charAt(0));
qs = qs.substring(1);
Map<String,String> kvp = new HashMap();
for (String s : qs.split("&")) {
kvp.put(s.split("=")[0], s.split("=")[1]);
}
assertEquals(from, RequestResource.DATE_FORMAT.parse(kvp.get("from")));
assertEquals(to, RequestResource.DATE_FORMAT.parse(kvp.get("to")));
assertEquals("service:EQ:WFS;status:EQ:RUNNING;path:IN:/foo,/bar", kvp.get("filter"));
}
}
代码示例来源:origin: org.geoserver.extension/monitor-hibernate
@Test
public void testGetRequestsFilterOr() throws Exception {
assertEquals(4, dao.getRequests(new Query().filter("path", "/seven", Comparison.EQ)
.or("widgets", "resources", Comparison.IN)).size());
}
代码示例来源:origin: org.geoserver.extension/gs-monitor-core
@Test
public void testGetRequestsBetween() throws Exception {
List<RequestData> datas =
dao.getRequests(
new Query()
.between(
toDate("2010-07-23T15:55:00"),
toDate("2010-07-23T16:17:00")));
assertCoveredInOrder(datas, 6, 5, 4);
}
代码示例来源:origin: org.geoserver.extension/monitor-core
public void testGetAllCSVQuery() throws Exception {
RequestResource.CSVFormat format = new RequestResource.CSVFormat(
new String[]{"id", "path", "startTime"}, monitor);
ByteArrayOutputStream out = new ByteArrayOutputStream();
format.toRepresentation(new Query()).write(out);
BufferedReader in = new BufferedReader(new InputStreamReader(
new ByteArrayInputStream(out.toByteArray())));
String line = in.readLine();
assertEquals("id,path,startTime", line);
Iterator<RequestData> it = monitor.getDAO().getRequests().iterator();
while((line = in.readLine()) != null) {
assertTrue(it.hasNext());
RequestData data = it.next();
String expected = data.getId() + "," + data.getPath() + "," +
DateUtil.serializeDateTime(data.getStartTime());
assertEquals(expected, line);
}
assertFalse(it.hasNext());
}
代码示例来源:origin: org.geoserver.extension/gs-monitor-core
@Test
public void testGetRequestsSorted() throws Exception {
assertCoveredInOrder(
dao.getRequests(
new Query().filter("id", 11l, Comparison.LT).sort("path", SortOrder.ASC)),
8,
5,
4,
9,
1,
7,
6,
10,
3,
2);
}
代码示例来源:origin: org.geoserver.extension/monitor-core
@Test
public void testGetRequestsBetween2() throws Exception {
//test that the query is inclusive, and test sorting
List<RequestData> datas = dao.getRequests(new Query().between(
toDate("2010-07-23T15:56:44"), toDate("2010-07-23T16:16:44"))
.sort("startTime", SortOrder.ASC));
assertCoveredInOrder(datas, 4, 5, 6);
}
代码示例来源:origin: org.geoserver.extension/monitor-core
@Test
public void testGetRequestsBetween() throws Exception {
List<RequestData> datas = dao.getRequests(new Query().between(
toDate("2010-07-23T15:55:00"), toDate("2010-07-23T16:17:00")));
assertCoveredInOrder(datas, 6, 5, 4);
}
代码示例来源:origin: org.geoserver.extension/gs-monitor-core
@Test
public void testGetRequestsFilterNull() throws Exception {
assertEquals(0, dao.getRequests(new Query().filter("path", null, Comparison.EQ)).size());
assertEquals(
testData.getData().size(),
dao.getRequests(new Query().filter("path", null, Comparison.NEQ)).size());
}
代码示例来源:origin: org.geoserver.extension/monitor-hibernate
@Test
public void testGetRequestsJoin2() throws Exception {
final List<RequestData> datas = new ArrayList();
final List<Object> aggs = new ArrayList();
dao.getRequests(new Query().properties("resource").aggregate("count()")
.filter("resource", null, Comparison.NEQ).group("resource"), new RequestDataVisitor() {
public void visit(RequestData data, Object... aggregates) {
datas.add(data);
aggs.add(aggregates[0]);
}
});
//assertEquals(3, datas.size());
for (RequestData data : datas) {
System.out.println(data.getResources());
}
}
代码示例来源:origin: org.geoserver.extension/monitor-core
@Test
public void testGetRequestsPaged() throws Exception {
List<RequestData> datas = dao.getRequests(
new Query().page(5l, 2l).sort("startTime", SortOrder.ASC));
assertCoveredInOrder(datas, 6, 7);
}
代码示例来源:origin: org.geoserver.extension/monitor-core
@Test
public void testGetRequestsFilterNull() throws Exception {
assertEquals(0, dao.getRequests(new Query().filter("path", null, Comparison.EQ)).size());
assertEquals(testData.getData().size(),
dao.getRequests(new Query().filter("path", null, Comparison.NEQ)).size());
}
代码示例来源:origin: org.geoserver.extension/monitor-hibernate
@Test
public void testGetRequestsJoin() throws Exception {
List<RequestData> datas = dao.getRequests(new Query().properties("path", "resource")
.filter("path","/foo", Comparison.EQ). group("path", "resource")
.sort("resource", SortOrder.ASC));
assertEquals(3, datas.size());
assertEquals("stuff", datas.get(0).getResources().get(0));
assertEquals("things", datas.get(1).getResources().get(0));
assertEquals("widgets", datas.get(2).getResources().get(0));
}
@Test
代码示例来源:origin: org.geoserver.extension/monitor-core
@Test
public void testGetCount() throws Exception {
assertEquals(4, dao.getCount(new Query().filter("path","/foo", Comparison.EQ)));
}
内容来源于网络,如有侵权,请联系作者删除!