com.vmware.admiral.common.util.QueryUtil.addTenantAndGroupClause()方法的使用及代码示例

x33g5p2x  于2022-01-28 转载在 其他  
字(5.4k)|赞(0)|评价(0)|浏览(84)

本文整理了Java中com.vmware.admiral.common.util.QueryUtil.addTenantAndGroupClause方法的一些代码示例,展示了QueryUtil.addTenantAndGroupClause的具体用法。这些代码示例主要来源于Github/Stackoverflow/Maven等平台,是从一些精选项目中提取出来的代码,具有较强的参考意义,能在一定程度帮忙到你。QueryUtil.addTenantAndGroupClause方法的具体详情如下:
包路径:com.vmware.admiral.common.util.QueryUtil
类名称:QueryUtil
方法名:addTenantAndGroupClause

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);

相关文章