Examples of com.opengamma.batch.domain.StatusEntry

      DbMapSqlParameterSource params = new DbMapSqlParameterSource();


      // this assumes that _searchKey2StatusEntry has already been populated
      // in getStatus()
      Pair<Long, Long> key = Pair.of(calcConfId, computationTargetId);
      StatusEntry statusEntry = statusCache.get(key);
      if (statusEntry != null) {
        statusEntry.setStatus(status);
        params.addValue("id", statusEntry.getId());
        params.addValue("run_id", runId);
        params.addValue("status", statusEntry.getStatus().ordinal());
        updates.add(params);
      } else {
        final long statusId = nextId(RSK_SEQUENCE_NAME);


        final DbMapSqlParameterSource insertArgs = new DbMapSqlParameterSource();
        insertArgs.addValue("ID", statusId);
        statusEntry = new StatusEntry();
        statusEntry.setId(statusId);
        statusEntry.setRunId(runId);
        statusEntry.setStatus(status);
        statusEntry.setCalculationConfigurationId(calcConfId);
        statusEntry.setComputationTargetId(computationTargetId);
        statusCache.put(key, statusEntry);


        params.addValue("id", statusId);
        params.addValue("run_id", runId);
        params.addValue("calculation_configuration_id", calcConfId);
        params.addValue("computation_target_id", computationTargetId);
        params.addValue("status", statusEntry.getStatus().ordinal());
        inserts.add(params);
      }


    }

    // first check to see if this status has already been queried for
    // and if the answer could therefore be found in the cache


    Pair<Long, Long> key = Pair.of(calcConfId, computationTargetId);
    if (statusCache.containsKey(key)) {
      StatusEntry existingStatusEntryInDb = statusCache.get(key);
      if (existingStatusEntryInDb != null) {
        // status entry in db.
        return existingStatusEntryInDb.getStatus();
      } else {
        // no status entry in db.
        return StatusEntry.Status.NOT_RUNNING;
      }
    }


    MapSqlParameterSource args = new MapSqlParameterSource();
    args.addValue("calculation_configuration_id", calcConfId);
    args.addValue("computation_target_id", computationTargetId);


    try {
      StatusEntry statusEntry = getJdbcTemplate().queryForObject(
        getElSqlBundle().getSql("SelectStatusEntry"),
        args,
        DbBatchUtils.ROW_MAPPER);


      // status entry in db found.
      statusCache.put(key, statusEntry);


      return statusEntry.getStatus();


    } catch (IncorrectResultSizeDataAccessException e) {
      // no status entry in the db. 
      statusCache.remove(key);
      return StatusEntry.Status.NOT_RUNNING;

Examples of com.opengamma.batch.domain.StatusEntry

Related Classes of com.opengamma.batch.domain.StatusEntry