Function updateMany

packages/core/fumadb/src/adapters/mongodb/query.ts:385–414

(table, v)

      return result.map((v) => mapResult(v, table));
    },
    async updateMany(table, v) {
      const where = v.where ? buildWhere(v.where) : {};
      const set: Record<string, unknown> = {};
      const unset: Record<string, unknown> = {};

      for (const k in v.set) {
        const col = table.columns[k];
        const value = v.set[k];
        if (!col || value === undefined) continue;

        const name = col.names.mongodb;

        if (value === null) {
          unset[name] = "";
        } else {
          set[name] = serialize(value);
        }
      }

      await db.collection(table.names.mongodb).updateMany(
        where,
        {
          $set: set,
          $unset: unset,
        },
        {
          session,
        }
      );
    },
    async create(table, values) {
      const collection = db.collection(table.names.mongodb);
      const { insertedId } = await collection.insertOne(