org.locationtech.geogig.repository.Repository.close()方法的使用及代码示例

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

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

Repository.close介绍

[英]Closes the repository.
[中]关闭存储库。

代码示例

代码示例来源:origin: locationtech/geogig

@Override
public void close() {
  if (remoteRepository != null) {
    try {
      remoteRepository.close();
    } finally {
      remoteRepository = null;
    }
  }
}

代码示例来源:origin: locationtech/geogig

@Override
public void close() {
  if (remoteRepo != null) {
    remoteRepo.close();
    remoteRepo = null;
  }
}

代码示例来源:origin: org.locationtech.geogig/geogig-remoting

@Override
public void close() {
  if (remoteRepository != null) {
    try {
      remoteRepository.close();
    } finally {
      remoteRepository = null;
    }
  }
}

代码示例来源:origin: locationtech/geogig

/**
 * Closes the current repository.
 */
public void close() {
  if (repository != null) {
    repository.close();
    repository = null;
  }
  context = null;
}

代码示例来源:origin: org.locationtech.geogig/geogig-core

/**
 * Closes the current repository.
 */
public void close() {
  if (repository != null) {
    repository.close();
    repository = null;
  }
  context = null;
}

代码示例来源:origin: org.locationtech.geogig/geogig-remoting

@Override
public void close() {
  if (remoteRepo != null) {
    remoteRepo.close();
    remoteRepo = null;
  }
}

代码示例来源:origin: locationtech/geogig

public void tearDown() throws IOException {
  if (repo != null) {
    repo.close();
  }
  repo = null;
  injector = null;
}

代码示例来源:origin: org.locationtech.geogig/geogig-remoting

public void tearDown() throws IOException {
  if (repo != null) {
    repo.close();
  }
  repo = null;
  injector = null;
}

代码示例来源:origin: locationtech/geogig

@Override
public void dispose() {
  super.dispose();
  if (closeOnDispose) {
    repository.close();
  }
}

代码示例来源:origin: org.locationtech.geogig/geogig-web-api

@Override
public void delete(String repoName) {
  Preconditions.checkState(repo != null, "No repository to delete.");
  Optional<URI> repoUri = repo.command(ResolveGeogigURI.class).call();
  Preconditions.checkState(repoUri.isPresent(), "No repository to delete.");
  repo.close();
  try {
    GeoGIG.delete(repoUri.get());
    this.repo = null;
  } catch (Exception e) {
    Throwables.propagate(e);
  }
}

代码示例来源:origin: org.locationtech.geogig/geogig-web-app

@Override
public void delete(String repoName) {
  Optional<Repository> geogig = getGeogig(repoName);
  Preconditions.checkState(geogig.isPresent(), "No repository to delete.");
  Repository ggig = geogig.get();
  Optional<URI> repoUri = ggig.command(ResolveGeogigURI.class).call();
  Preconditions.checkState(repoUri.isPresent(), "No repository to delete.");
  ggig.close();
  try {
    GeoGIG.delete(repoUri.get());
    this.repositories.invalidate(repoName);
  } catch (Exception e) {
    Throwables.propagate(e);
  }
}

代码示例来源:origin: org.locationtech.geogig/geogig-web-app

@Override
public void onRemoval(RemovalNotification<String, Repository> notification) {
  final RemovalCause cause = notification.getCause();
  final String repositoryName = notification.getKey();
  final Repository repo = notification.getValue();
  LOG.info("Disposing repository {}. Cause: " + cause(cause));
  try {
    if (repo != null && repo.isOpen()) {
      repo.close();
    }
  } catch (RuntimeException e) {
    LOG.warn("Error closing repository {}", repositoryName, e);
  }
}

代码示例来源:origin: org.geoserver.community/gs-geogig

@Override
public void delete(String repoName) {
  Optional<Repository> geogig = getGeogig(repoName);
  Preconditions.checkState(geogig.isPresent(), "No repository to delete.");
  final String repoId = getRepoIdForName(repoName);
  Repository ggig = geogig.get();
  Optional<URI> repoUri = ggig.command(ResolveGeogigURI.class).call();
  Preconditions.checkState(repoUri.isPresent(), "No repository to delete.");
  ggig.close();
  try {
    GeoGIG.delete(repoUri.get());
    RepositoryManager manager = RepositoryManager.get();
    manager.delete(repoId);
  } catch (Exception e) {
    Throwables.propagate(e);
  }
}

代码示例来源:origin: locationtech/geogig

public @Override void after() {
  repos.values().forEach(r -> r.getRepo().close());
  tmp.delete();
}

代码示例来源:origin: locationtech/geogig

private RepoInfo toRepoInfo(RepositoryResolver resolver, URI rootRepoURI, String repoName) {
  URI repoURI = resolver.buildRepoURI(rootRepoURI, repoName);
  Repository repo;
  try {
    repo = resolver.open(repoURI);
  } catch (RepositoryConnectionException e) {
    throw new CommandFailedException(e);
  }
  try {
    return toRepoInfo(repoName, repo);
  } finally {
    repo.close();
  }
}

代码示例来源:origin: org.locationtech.geogig/geogig-core

@After
public final void tearDown() throws Exception {
  setup = false;
  tearDownInternal();
  if (repo != null) {
    repo.close();
  }
  repo = null;
  injector = null;
}

代码示例来源:origin: locationtech/geogig

@After
public final void tearDown() throws Exception {
  setup = false;
  tearDownInternal();
  if (repo != null) {
    repo.close();
  }
  repo = null;
  injector = null;
}

代码示例来源:origin: org.locationtech.geogig/geogig-web-api-functional-tests

@Given("^There is an empty repository named ([^\"]*)$")
public void setUpEmptyRepo(String name) throws Throwable {
  context.createRepo(name).init("webuser", "webuser@test.com").getRepo().close();
  openedRepos.add(name);
}

代码示例来源:origin: org.locationtech.geogig/geogig-web-api-functional-tests

@Given("I have \"([^\"]*)\" that is not managed$")
public void setupExtraUnMangedRepo(String repoName) throws Exception {
  context.createUnmanagedRepo(repoName)
      .init("geogigUser", "repo1_Owner@geogig.org")
      .loadDefaultData()
      .getRepo().close();
  openedRepos.add(repoName);
}

代码示例来源:origin: org.locationtech.geogig/geogig-web-api-functional-tests

@cucumber.api.java.After
public void after() {
  // Restore available resolvers
  RepositoryResolverTestUtil.clearDisabledResolverList();
  // try to close any repositories used while executing a Scenario
  for (String repoName : openedRepos) {
    Repository repo = context.getRepo(repoName);
    if (repo != null) {
      repo.close();
    }
  }
  context.after();
}

相关文章