Function upsertMany

packages/core/fumadb/src/adapters/memory/index.ts:177–209

(table, v)

          await this.create(table, v.create);
        },
        async upsertMany(table, v) {
          if (v.target.length === 0) {
            // oxlint-disable-next-line executor/no-try-catch-or-throw, executor/no-error-constructor -- boundary: adapter rejects invalid upsert shape
            throw new Error("[FumaDB] upsertMany requires at least one target column.");
          }
          if (v.update.length === 0) {
            // oxlint-disable-next-line executor/no-try-catch-or-throw, executor/no-error-constructor -- boundary: adapter rejects invalid upsert shape
            throw new Error("[FumaDB] upsertMany requires at least one update column.");
          }
          for (const value of v.values) {
            // Mirror SQL `ON CONFLICT ... DO UPDATE ... WHERE`: the unique
            // target alone detects the conflict, and the predicate only
            // decides whether the conflicting row may be updated. A
            // policy-excluded conflict skips the row; it never inserts a
            // duplicate of the unique target.
            const conflicting = tableRows(db, table).find((row) =>
              v.target.every((column) => row[column.ormName] === value[column.ormName]),
            );
            if (conflicting) {
              if (!matchesCondition(conflicting, v.where)) continue;
              Object.assign(
                conflicting,
                cloneValue(
                  Object.fromEntries(
                    v.update.map((column) => [column.ormName, value[column.ormName]]),
                  ),
                ),
              );
              continue;
            }
            await this.create(table, value);
          }
        },
        async create(table, values) {
          const row = applyDefaults(table, values);
          tableRows(db, table).push(row);