Function upsert

packages/core/fumadb/src/adapters/kysely/query.ts:463–494

(table, { where, update, create })

      await query.execute();
    },
    async upsert(table, { where, update, create }) {
      if (provider === "mssql") {
        let query = kysely
          .updateTable(table.names.sql)
          .top(1)
          .set(encodeValues(update, table, false));

        if (where) query = query.where((b) => buildWhere(where, b, provider));
        const result = await query.executeTakeFirstOrThrow();

        if (result.numUpdatedRows === 0n)
          await this.createMany(table, [create]);
        return;
      }

      const idColumn = table.getIdColumn();
      let query = kysely
        .selectFrom(table.names.sql)
        .select([`${idColumn.names.sql} as id`]);
      if (where) query = query.where((b) => buildWhere(where, b, provider));
      const result = await query.limit(1).executeTakeFirst();

      if (result) {
        await kysely
          .updateTable(table.names.sql)
          .set(encodeValues(update, table, false))
          .where(idColumn.names.sql, "=", result.id)
          .execute();
      } else {
        await this.createMany(table, [create]);
      }
    },

    async createMany(table, values) {
      const encodedValues = values.map((v) => encodeValues(v, table, true));