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

Repository.upsertBatch介绍

暂无

代码示例

代码示例来源：origin: org.molgenis/molgenis-jobs

private void upsertScheduledJobTypes() {
 dataService
   .getRepository(SCHEDULED_JOB_TYPE, ScheduledJobType.class)
   .upsertBatch(scheduledJobTypes);
}

代码示例来源：origin: org.molgenis/molgenis-web

public void populate(ApplicationContext ctx) {
 Map<String, Plugin> newOrChangedPluginMap = getPlugins(ctx);
 List<Plugin> deletedPlugins = new ArrayList<>();
 Map<String, Plugin> existingPluginMap =
   dataService
     .findAll(PLUGIN, Plugin.class)
     .collect(toMap(Plugin::getId, Function.identity()));
 existingPluginMap.forEach(
   (pluginId, plugin) -> {
    if (newOrChangedPluginMap.get(pluginId) == null && !pluginId.startsWith(APP_PREFIX)) {
     deletedPlugins.add(plugin);
    }
   });
 if (!newOrChangedPluginMap.isEmpty()) {
  dataService
    .getRepository(PLUGIN, Plugin.class)
    .upsertBatch(newArrayList(newOrChangedPluginMap.values()));
 }
 if (!deletedPlugins.isEmpty()) {
  dataService.delete(PLUGIN, deletedPlugins.stream());
 }
}

代码示例来源：origin: org.molgenis/molgenis-data-mapper

private void processBatch(EntityMapping sourceMapping, Repository<Entity> targetRepo, Progress progress,
    AtomicLong counter, boolean canAdd, List<Entity> entities)
{
  List<Entity> mappedEntities = mapEntities(sourceMapping, targetRepo.getEntityType(), entities);
  if (canAdd)
  {
    targetRepo.add(mappedEntities.stream());
  }
  else
  {
    targetRepo.upsertBatch(mappedEntities);
  }
  progress.increment(1);
  counter.addAndGet(entities.size());
}

代码示例来源：origin: org.molgenis/molgenis-semantic-mapper

private void processBatch(
  EntityMapping sourceMapping,
  Repository<Entity> targetRepo,
  Progress progress,
  AtomicLong counter,
  boolean canAdd,
  List<Entity> entities,
  int depth) {
 List<Entity> mappedEntities =
   mapEntities(sourceMapping, targetRepo.getEntityType(), entities, depth);
 if (canAdd) {
  targetRepo.add(mappedEntities.stream());
 } else {
  targetRepo.upsertBatch(mappedEntities);
 }
 progress.increment(1);
 counter.addAndGet(entities.size());
}