Method run

basex-core/src/main/java/org/basex/core/jobs/QueryJob.java:188–271

()

  }

  @Override
  public void run() {
    try {
      result.init();

      final JobContext jc = jc();
      final String id = jc.id();
      final Context ctx = jc.context;
      final JobOptions opts = job.options;

      String log = opts.get(JobOptions.LOG);
      if(log != null && log.isEmpty()) log = null;
      if(log != null) ctx.log.write(LogType.REQUEST, log, null, "JOB:" + id, ctx);

      final Performance perf = new Performance();
      qp = new QueryProcessor(job.query, opts.get(JobOptions.BASE_URI), ctx, null);
      try {
        // parse, push and register query. order is important!
        for(final Entry<String, Value> binding : job.bindings.entrySet()) {
          final String key = binding.getKey();
          final Value value = binding.getValue();
          if(key.isEmpty()) qp.context(value);
          else qp.variable(key, value);
        }
        qp.parse();
        updating = qp.updating;
        result.time = perf.nanoRuntime();

        // register job
        pushJob(qp);
        register(ctx);
        // reset timer
        perf.nanoRuntime();
        if(remove) ctx.jobs.tasks.remove(id);

        // retrieve result; copy persistent database nodes
        result.value = qp.value().materialize(d -> d == null || d.inMemory(), null, qp.qc);
      } catch(final JobException ex) {
        // query was interrupted: remove cached result
        Util.debug(ex);
        ctx.jobs.results.remove(id);
      } catch(final QueryException ex) {
        result.exception = ex;
      } catch(final Throwable ex) {
        result.exception = XQUERY_UNEXPECTED_X.get(null, ex);
      } finally {
        // close and invalidate query after result has been assigned. order is important!
        if(Boolean.TRUE.equals(opts.get(JobOptions.CACHE))) {
          ctx.jobs.scheduleResult(this);
          state(JobState.CACHED);
        } else {
          state(JobState.SCHEDULED);
        }

        if(ctx.jobs.active.containsKey(id)) {
          qp.close();
          unregister(ctx);
          popJob();