com.evolveum.midpoint.repo.api.RepositoryService.getVersion()方法的使用及代码示例

x33g5p2x  于2022-01-29 转载在 其他  
字(10.1k)|赞(0)|评价(0)|浏览(58)

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

RepositoryService.getVersion介绍

暂无

代码示例

代码示例来源:origin: Evolveum/midpoint

private boolean hasValidSystemConfiguration(OperationResult result) throws ObjectNotFoundException, SchemaException {
  if (systemConfiguration == null) {
    return false;
  }
  if (systemConfiguration.getVersion() == null) {
    return false;
  }
  if (systemConfigurationCheckTimestamp == null) {
    return false;
  }
  if (System.currentTimeMillis() < systemConfigurationCheckTimestamp + getSystemConfigurationExpirationMillis()) {
    return true;
  }
  String repoVersion = cacheRepositoryService.getVersion(SystemConfigurationType.class, SystemObjectsType.SYSTEM_CONFIGURATION.value(),
      result);
  if (systemConfiguration.getVersion().equals(repoVersion)) {
    systemConfigurationCheckTimestamp = System.currentTimeMillis();
    return true;
  }
  return false;
}

代码示例来源:origin: Evolveum/midpoint

private boolean hasVersionChanged(CacheKey key, CacheObject object, OperationResult result)
    throws ObjectNotFoundException, SchemaException {
  try {
    String version = repositoryService.getVersion(object.getObjectType(), object.getObjectOid(), result);
    return !Objects.equals(version, object.getObjectVersion());
  } catch (ObjectNotFoundException | SchemaException ex) {
    removeObject(key.getType(), key.getOid());
    throw ex;
  }
}

代码示例来源:origin: Evolveum/midpoint

Long startTime = repoOpStart();
  try {
    return repositoryService.getVersion(type, oid, parentResult);
  } finally {
    repoOpEnd(startTime);
Long startTime = repoOpStart();
try {
  version = repositoryService.getVersion(type, oid, parentResult);
} finally {
  repoOpEnd(startTime);

代码示例来源:origin: Evolveum/midpoint

@Override
protected void rememberSteadyResources() {
  super.rememberSteadyResources();
  OperationResult result = new OperationResult("rememberSteadyResources");
  try {
    lastResourceVersion = repositoryService.getVersion(ResourceType.class, getResourceOid(), result);
  } catch (ObjectNotFoundException | SchemaException e) {
    throw new RuntimeException(e.getMessage(), e);
  }
}

代码示例来源:origin: Evolveum/midpoint

@Override
protected void assertSteadyResources() {
  super.assertSteadyResources();
  String currentResourceVersion;
  try {
    OperationResult result = new OperationResult("assertSteadyResources");
    currentResourceVersion = repositoryService.getVersion(ResourceType.class, getResourceOid(), result);
  } catch (ObjectNotFoundException | SchemaException e) {
    throw new RuntimeException(e.getMessage(), e);
  }
  assertEquals("Resource version mismatch", lastResourceVersion, currentResourceVersion);
}

代码示例来源:origin: Evolveum/midpoint

@Test(expectedExceptions = ObjectNotFoundException.class)
public void test090GetVersionNonExisting() throws Exception {
  OperationResult result = new OperationResult("get version");
  try {
    repositoryService.getVersion(SystemConfigurationType.class, "989", result);
    AssertJUnit.fail();
  } finally {
    result.recomputeStatus();
    AssertJUnit.assertTrue(!result.isUnknown());
  }
}

代码示例来源:origin: Evolveum/midpoint

@Test
public void test091GetVersion() throws Exception {
  OperationResult result = new OperationResult("get version");
  String version = repositoryService.getVersion(OrgType.class, ORG_OID, result);
  AssertJUnit.assertEquals("0", version);
  PrismObjectDefinition def = prismContext.getSchemaRegistry().findObjectDefinitionByCompileTimeClass(OrgType.class);
  Collection deltas = new ArrayList();
  deltas.add(prismContext.deltaFactory().property().createAddDelta(def, OrgType.F_ORG_TYPE, "asdf"));
  repositoryService.modifyObject(OrgType.class, ORG_OID, deltas, result);
  version = repositoryService.getVersion(OrgType.class, ORG_OID, result);
  AssertJUnit.assertEquals("1", version);
  result.recomputeStatus();
  AssertJUnit.assertTrue(result.isSuccess());
}

代码示例来源:origin: Evolveum/midpoint

@Test
public void test162ModifyWithPrecondition2() throws Exception {
  final String TEST_NAME = "test162ModifyWithPrecondition2";
  TestUtil.displayTestTitle(TEST_NAME);
  OperationResult result = new OperationResult(TEST_NAME);
  // GIVEN
  String versionBefore = repositoryService.getVersion(RoleType.class, roleOid, result);
  ModificationPrecondition<RoleType> precondition = o -> false;
  // WHEN
  List<ItemDelta<?, ?>> itemDeltas = prismContext.deltaFor(RoleType.class)
      .item(RoleType.F_DESCRIPTION).replace("123456")
      .asItemDeltas();
  try {
    repositoryService.modifyObject(RoleType.class, roleOid, itemDeltas, precondition, null, result);
    // THEN
    fail("unexpected success");
  } catch (PreconditionViolationException e) {
    // ok
    System.out.println("got expected exception: " + e.getMessage());
  }
  String versionAfter = repositoryService.getVersion(RoleType.class, roleOid, result);
  assertEquals("unexpected version change", versionBefore, versionAfter);
}

代码示例来源:origin: Evolveum/midpoint

@Test
public void test166ModifyWithVersionPreconditionTrue() throws Exception {
  final String TEST_NAME = "test166ModifyWithVersionPreconditionTrue";
  TestUtil.displayTestTitle(TEST_NAME);
  OperationResult result = new OperationResult(TEST_NAME);
  // GIVEN
  String versionBefore = repositoryService.getVersion(RoleType.class, roleOid, result);
  ModificationPrecondition<RoleType> precondition = new VersionPrecondition<>(versionBefore);
  // WHEN
  List<ItemDelta<?, ?>> itemDeltas = prismContext.deltaFor(RoleType.class)
      .item(RoleType.F_DESCRIPTION).replace("123456")
      .asItemDeltas();
  repositoryService.modifyObject(RoleType.class, roleOid, itemDeltas, precondition, null, result);
  String versionAfter = repositoryService.getVersion(RoleType.class, roleOid, result);
  assertEquals("unexpected version change", Integer.parseInt(versionBefore)+1, Integer.parseInt(versionAfter));
  String description = repositoryService.getObject(RoleType.class, roleOid, null, result).asObjectable().getDescription();
  assertEquals("description was not set", "123456", description);
}

代码示例来源:origin: Evolveum/midpoint

@Test
public void test164ModifyWithVersionPreconditionFalse() throws Exception {
  final String TEST_NAME = "test164ModifyWithVersionPreconditionFalse";
  TestUtil.displayTestTitle(TEST_NAME);
  OperationResult result = new OperationResult(TEST_NAME);
  // GIVEN
  String versionBefore = repositoryService.getVersion(RoleType.class, roleOid, result);
  ModificationPrecondition<RoleType> precondition = new VersionPrecondition<>("9999");
  // WHEN
  List<ItemDelta<?, ?>> itemDeltas = prismContext.deltaFor(RoleType.class)
      .item(RoleType.F_DESCRIPTION).replace("123456")
      .asItemDeltas();
  try {
    repositoryService.modifyObject(RoleType.class, roleOid, itemDeltas, precondition, null, result);
    // THEN
    fail("unexpected success");
  } catch (PreconditionViolationException e) {
    // ok
    System.out.println("got expected exception: " + e.getMessage());
  }
  String versionAfter = repositoryService.getVersion(RoleType.class, roleOid, result);
  assertEquals("unexpected version change", versionBefore, versionAfter);
}

代码示例来源:origin: Evolveum/midpoint

connectorTypeCache.put(connOid, connectorType);
} else {
  String currentConnectorVersion = repositoryService.getVersion(ConnectorType.class, connOid, result);
  if (!currentConnectorVersion.equals(connectorType.getVersion())) {
    Collection<SelectorOptions<GetOperationOptions>> options = SelectorOptions.createCollection(GetOperationOptions.createReadOnly());

代码示例来源:origin: Evolveum/midpoint

@Test
public void test160ModifyWithPrecondition() throws Exception {
  final String TEST_NAME = "test160ModifyWithPrecondition";
  TestUtil.displayTestTitle(TEST_NAME);
  OperationResult result = new OperationResult(TEST_NAME);
  // GIVEN
  String versionBefore = repositoryService.getVersion(RoleType.class, roleOid, result);
  ModificationPrecondition<RoleType> precondition = o -> { throw new PreconditionViolationException("hello"); };
  // WHEN
  List<ItemDelta<?, ?>> itemDeltas = prismContext.deltaFor(RoleType.class)
      .item(RoleType.F_DESCRIPTION).replace("123456")
      .asItemDeltas();
  try {
    repositoryService.modifyObject(RoleType.class, roleOid, itemDeltas, precondition, null, result);
    // THEN
    fail("unexpected success");
  } catch (PreconditionViolationException e) {
    assertEquals("Wrong exception message", "hello", e.getMessage());
  }
  String versionAfter = repositoryService.getVersion(RoleType.class, roleOid, result);
  assertEquals("unexpected version change", versionBefore, versionAfter);
}

代码示例来源:origin: Evolveum/midpoint

public PrismObject<ResourceType> getResource(String oid, GetOperationOptions options, Task task, OperationResult parentResult) throws ObjectNotFoundException, SchemaException, CommunicationException, ConfigurationException, ExpressionEvaluationException{
  InternalMonitor.getResourceCacheStats().recordRequest();
  
  String version = repositoryService.getVersion(ResourceType.class, oid, parentResult);
  PrismObject<ResourceType> cachedResource = resourceCache.get(oid, version, options);
  if (cachedResource != null) {
    InternalMonitor.getResourceCacheStats().recordHit();
    if (LOGGER.isTraceEnabled()){
      LOGGER.trace("Returning resource from cache:\n{}", cachedResource.debugDump());
    }
    return cachedResource;
  }
  
  if (LOGGER.isDebugEnabled()) {
    LOGGER.debug("Fetching resource {}, version {}, storing to cache (previously cached version {})", 
        oid, version, resourceCache.getVersion(oid));
  }
  
  Collection<SelectorOptions<GetOperationOptions>> repoOptions = null;
  if (GetOperationOptions.isReadOnly(options)) {
    repoOptions = SelectorOptions.createCollection(GetOperationOptions.createReadOnly());
  }
  PrismObject<ResourceType> repositoryObject = readResourceFromRepository(oid, repoOptions, parentResult);
  
  return loadAndCacheResource(repositoryObject, options, task, parentResult);
}

代码示例来源:origin: Evolveum/midpoint

String versionAfter = repositoryService.getVersion(ResourceType.class, RESOURCE_DUMMY_OID, result);
assertResourceVersionIncrement(versionAfter, 1);

代码示例来源:origin: Evolveum/midpoint

String versionAfter = repositoryService.getVersion(ResourceType.class, RESOURCE_DUMMY_OID, result);
assertResourceVersionIncrement(versionAfter, 1);

代码示例来源:origin: Evolveum/midpoint

OperationResult result = task.getResult();
String versionAfter = repositoryService.getVersion(ResourceType.class, RESOURCE_DUMMY_OID, result);
assertResourceVersionIncrement(versionAfter, 1);

相关文章

微信公众号

最新文章

更多