Function upsertMany

packages/core/fumadb/src/query/orm/index.ts:448–551

(name, { target, update, values })

      });
    },
    async upsertMany(name, { target, update, values }) {
      const table = toTable(name);
      if (values.length === 0) return;
      if (target.length === 0) {
        // oxlint-disable-next-line executor/no-try-catch-or-throw, executor/no-error-constructor -- boundary: public query rejects invalid upsert shape
        throw new Error("[FumaDB] upsertMany requires at least one target column.");
      }
      if (update.length === 0) {
        // oxlint-disable-next-line executor/no-try-catch-or-throw, executor/no-error-constructor -- boundary: public query rejects invalid upsert shape
        throw new Error("[FumaDB] upsertMany requires at least one update column.");
      }

      const targetColumns = target.map((columnName) => {
        const column = table.columns[columnName as string];
        if (!column) throw new Error(`[FumaDB] unknown column name ${String(columnName)}.`);
        return column;
      });
      const updateColumns = update.map((columnName) => {
        const column = table.columns[columnName as string];
        if (!column) throw new Error(`[FumaDB] unknown column name ${String(columnName)}.`);
        return column;
      });

      const builder = createBuilder(table.columns);
      const permittedRows: {
        readonly value: Record<string, unknown>;
        readonly where: Condition | undefined;
      }[] = [];
      for (const value of values) {
        const updateValues = Object.fromEntries(
          updateColumns.map((column) => [column.ormName, value[column.ormName]]),
        );
        const constrainedWhere = await applyUpdatePolicies(
          table,
          undefined,
          updateValues,
          context,
          "upsert",
          value,
        );
        if (constrainedWhere === false) continue;
        await runCreatePolicies(table, value, context);
        permittedRows.push({ value, where: constrainedWhere });
      }
      if (permittedRows.length === 0) return;

      if (internal.upsertMany) {
        const groups: {
          readonly where: Condition | undefined;
          readonly values: Record<string, unknown>[];
        }[] = [];
        for (const row of permittedRows) {
          const group = groups.find((candidate) => conditionsEqual(candidate.where, row.where));
          if (group) {
            group.values.push(row.value);
          } else {
            groups.push({ where: row.where, values: [row.value] });
          }