INNER CODE UNIT · JavaScript

mutateWithQuery

scalar-labs/scalardb · core/src/main/resources/cosmosdb_stored_procedure/mutate.js:30

  function mutateWithQuery(mutation, record, query) {
    return new Promise((resolve, reject) => {
      const isAccepted = __.queryDocuments(__.getSelfLink(), query,
        (error, reads, options) => {
          if (error) {
            reject(error);
            return;
          }

          const records = checkQueryResult(mutation, record, reads);
          if (!records.length) {
            reject(new Error(ERROR_CODE.PRECONDITION_FAILED, "no mutation"));
            return;
          }

          if (mutation == MUTATION.DELETE_IF) {
            for (let i = 0; i < records.length; i++) {
              const isMutationAccepted = __.deleteDocument(records[i]._self,

View source record →