Method execute

packages/orm/src/client/client-impl.ts:282–291

(tx: AnyKysely)

        options?: { isolationLevel?: TransactionIsolationLevel },
    ) {
        const execute = async (tx: AnyKysely) => {
            const txClient = new ClientImpl(this.schema, this.$options, this);
            txClient.kysely = tx;
            const result: any[] = [];
            for (const promise of arg) {
                const cb = this.getPromiseCallback(promise);
                result.push(await cb(txClient as unknown as ClientContract<SchemaDef>));
            }
            return result;
        };
        if (this.kysely.isTransaction) {
            // proceed directly if already in a transaction
            return execute(this.kysely);