Function create

packages/core/fumadb/src/adapters/kysely/query.ts:396–439

(table, values)

      return count;
    },
    async create(table, values) {
      const rawTable = table;
      const insertValues = encodeValues(values, rawTable, true);
      const insert = kysely.insertInto(rawTable.names.sql).values(insertValues);

      if (provider === "mssql") {
        return decodeResult(
          await insert
            .output(
              mapSelect(true, rawTable, { tableName: "inserted" }) as any[]
            )
            .executeTakeFirstOrThrow(),
          rawTable
        );
      }

      if (provider === "postgresql" || provider === "sqlite") {
        return decodeResult(
          await insert
            .returning(mapSelect(true, rawTable))
            .executeTakeFirstOrThrow(),
          rawTable
        );
      }

      const idColumn = rawTable.getIdColumn();
      const idValue = insertValues[idColumn.names.sql];

      if (idValue == null)
        throw new Error(
          "cannot find value of id column, which is required for `create()`."
        );

      await insert.execute();
      return decodeResult(
        await kysely
          .selectFrom(rawTable.names.sql)
          .select(mapSelect(true, rawTable))
          .where(idColumn.names.sql, "=", idValue)
          .limit(1)
          .executeTakeFirstOrThrow(),
        rawTable
      );
    },
    async findFirst(table, v) {
      const records = await this.findMany(table, {
        ...v,