本文整理了Java中com.vmware.admiral.common.util.QueryUtil.addTenantAndGroupClause
方法的一些代码示例,展示了QueryUtil.addTenantAndGroupClause
的具体用法。这些代码示例主要来源于Github
/Stackoverflow
/Maven
等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryUtil.addTenantAndGroupClause
方法的具体详情如下:
包路径:com.vmware.admiral.common.util.QueryUtil
类名称:QueryUtil
方法名:addTenantAndGroupClause
暂无
代码示例来源:origin: vmware/admiral
public static QueryTask createQueryTaskForProjectAssociatedWithPlacement(ResourceState project,
Query query) {
QueryTask queryTask = null;
if (query != null) {
queryTask = QueryTask.Builder.createDirectTask().setQuery(query).build();
} else if (project != null && project.documentSelfLink != null) {
queryTask = QueryUtil.buildQuery(GroupResourcePlacementState.class, true,
QueryUtil.addTenantAndGroupClause(Arrays.asList(project.documentSelfLink)));
}
if (queryTask != null) {
QueryUtil.addCountOption(queryTask);
}
return queryTask;
}
代码示例来源:origin: vmware/admiral
@Test
public void testAddTenantAndGroupClauseWhenTenantAndSubTenantAreSet() {
List<String> tenantLinks = Arrays.asList(TENANT_ID, GROUP_ID);
Query query = QueryUtil.addTenantAndGroupClause(tenantLinks);
Query tenantQuery = query.booleanClauses.stream()
.filter(l -> l.term.matchValue.contains(TENANT_ID)).findFirst().get();
Query subTenantQuery = query.booleanClauses.stream()
.filter(l -> l.term.matchValue.contains(GROUP_ID)).findFirst().get();
assertNotNull(tenantQuery);
assertNotNull(subTenantQuery);
assertEquals(tenantQuery.occurance, Occurance.MUST_OCCUR);
assertEquals(subTenantQuery.occurance, Occurance.MUST_OCCUR);
}
代码示例来源:origin: vmware/admiral
@Test
public void testAddTenantAndGroupClauseWhenTenantAndSubtenantAndUserAreSet() {
List<String> tenantLinks = Arrays.asList(TENANT_ID, GROUP_ID, USER_ID);
Query query = QueryUtil.addTenantAndGroupClause(tenantLinks);
Query tenantQuery = query.booleanClauses.stream()
.filter(l -> l.term.matchValue.contains(TENANT_ID)).findFirst().get();
Query subTenantQuery = query.booleanClauses.stream()
.filter(l -> l.term.matchValue.contains(GROUP_ID)).findFirst().get();
Optional<Query> userOptional = query.booleanClauses.stream()
.filter(l -> l.term.matchValue.contains(USER_ID)).findFirst();
assertNotNull(tenantQuery);
assertNotNull(subTenantQuery);
assertEquals(Optional.empty(), userOptional);
assertEquals(tenantQuery.occurance, Occurance.MUST_OCCUR);
assertEquals(subTenantQuery.occurance, Occurance.MUST_OCCUR);
}
代码示例来源:origin: vmware/admiral
@Test
public void testAddTenantAndGroupClauseWhenTenantAndUserAreSet() {
List<String> tenantLinks = Arrays.asList(TENANT_ID, USER_ID);
Query query = QueryUtil.addTenantAndGroupClause(tenantLinks);
assertNull("assumtion failed for query being single", query.booleanClauses);
assertTrue(query.term.matchValue.contains(TENANT_ID));
}
代码示例来源:origin: vmware/admiral
private void handleQueryServices(ServiceDocumentDeleteTaskState task) {
QueryTask query = QueryUtil.buildQuery(task.deleteDocumentKind, false);
query.querySpec.options = EnumSet.of(QueryOption.TOP_RESULTS);
query.querySpec.resultLimit = 50;
query.documentExpirationTimeMicros = Utils.fromNowMicrosUtc(
TimeUnit.HOURS.toMicros(5));
if (task.tenantLinks != null) {
// Delete documents only in current tenant and group
query.querySpec.query.addBooleanClause(QueryUtil.addTenantAndGroupClause(task.tenantLinks));
}
List<String> documents = new ArrayList<String>();
new ServiceDocumentQuery<ServiceDocument>(getHost(), ServiceDocument.class)
.query(query, (r) -> {
if (r.hasException()) {
logWarning("Query failed, task will not finish: %s",
r.getException().getMessage());
failTask(String.format("Could not get %s, task failed",
task.deleteDocumentKind), r.getException());
return;
} else if (r.hasResult() && documents.size() < r.getCount()) {
documents.add(r.getDocumentSelfLink());
} else {
handleDeleteServices(task, documents);
}
});
}
代码示例来源:origin: vmware/admiral
@Test
public void testAddTenantAndGroupClauseWhenOnlyTenantIsSet() {
List<String> tenantLinks = Arrays.asList(TENANT_ID);
Query query = QueryUtil.addTenantAndGroupClause(tenantLinks);
assertNotNull(query);
assertEquals(query.occurance, Occurance.MUST_OCCUR);
assertEquals(query.term.matchValue, TENANT_ID);
}
代码示例来源:origin: vmware/admiral
@Test
public void testAddGroupTagWhenOnlyTenantIsSet() {
String groupTag = "group-tag1";
List<String> tenantLinks = Arrays.asList(groupTag);
Query query = QueryUtil.addTenantAndGroupClause(tenantLinks);
assertNotNull(query);
assertEquals(query.occurance, Occurance.MUST_OCCUR);
assertEquals(query.term.matchValue, groupTag);
}
代码示例来源:origin: vmware/admiral
@Test
public void testAddTenantAndGroupClauseWhenTenantLinksIsNull() {
List<String> tenantLinks = null;
Query query = QueryUtil.addTenantAndGroupClause(tenantLinks);
assertNotNull(query);
assertEquals(query.occurance, Occurance.MUST_NOT_OCCUR);
assertEquals(query.term.matchValue, UriUtils.URI_WILDCARD_CHAR);
assertEquals(query.term.matchType, MatchType.WILDCARD);
}
代码示例来源:origin: vmware/admiral
+ " count: [%s]..", state.resourceDescriptionLink, state.resourceCount);
Query tenantLinksQuery = QueryUtil.addTenantAndGroupClause(null);
q.querySpec.query.addBooleanClause(tenantLinksQuery);
} else {
state.tenantLinks, state.resourceDescriptionLink, state.resourceCount);
Query tenantLinksQuery = QueryUtil.addTenantAndGroupClause(state.tenantLinks);
q.querySpec.query.addBooleanClause(tenantLinksQuery);
代码示例来源:origin: vmware/admiral
Query tenantLinksQuery = QueryUtil.addTenantAndGroupClause(null);
q.querySpec.query.addBooleanClause(tenantLinksQuery);
内容来源于网络,如有侵权,请联系作者删除!