FM / query-executor

/opt/canhelp/node_modules/kysely/dist/cjs/query-executor/

/opt/canhelp/node_modules/kysely/dist/cjs/query-executor

Name	Size	Mode	Actions
default-query-executor.d.ts	2229	0644	edit dl rm
default-query-executor.js	1641	0644	edit dl rm
noop-query-executor.d.ts	1888	0644	edit dl rm
noop-query-executor.js	1344	0644	edit dl rm
query-executor-base.d.ts	3001	0644	edit dl rm
query-executor-base.js	2566	0644	edit dl rm
query-executor-provider.d.ts	168	0644	edit dl rm
query-executor-provider.js	77	0644	edit dl rm
query-executor.d.ts	3005	0644	edit dl rm
query-executor.js	77	0644	edit dl rm

Edit: /opt/canhelp/node_modules/kysely/dist/cjs/query-executor/query-executor.d.ts (3005B)

import type { ConnectionProvider } from '../driver/connection-provider.js';
import type { QueryResult } from '../driver/database-connection.js';
import type { CompiledQuery } from '../query-compiler/compiled-query.js';
import type { RootOperationNode } from '../query-compiler/query-compiler.js';
import type { KyselyPlugin } from '../plugin/kysely-plugin.js';
import type { QueryId } from '../util/query-id.js';
import type { DialectAdapter } from '../dialect/dialect-adapter.js';
/**
 * This interface abstracts away the details of how to compile a query into SQL
 * and execute it. Instead of passing around all those details, {@link SelectQueryBuilder}
 * and other classes that execute queries can just pass around and instance of
 * `QueryExecutor`.
 */
export interface QueryExecutor extends ConnectionProvider {
    /**
     * Returns the adapter for the current dialect.
     */
    get adapter(): DialectAdapter;
    /**
     * Returns all installed plugins.
     */
    get plugins(): ReadonlyArray<KyselyPlugin>;
    /**
     * Given the query the user has built (expressed as an operation node tree)
     * this method runs it through all plugins' `transformQuery` methods and
     * returns the result.
     */
    transformQuery<T extends RootOperationNode>(node: T, queryId: QueryId): T;
    /**
     * Compiles the transformed query into SQL. You usually want to pass
     * the output of {@link transformQuery} into this method but you can
     * compile any query using this method.
     */
    compileQuery<R = unknown>(node: RootOperationNode, queryId: QueryId): CompiledQuery<R>;
    /**
     * Executes a compiled query and runs the result through all plugins'
     * `transformResult` method.
     */
    executeQuery<R>(compiledQuery: CompiledQuery<R>): Promise<QueryResult<R>>;
    /**
     * Executes a compiled query and runs the result through all plugins'
     * `transformResult` method. Results are streamead instead of loaded
     * at once.
     */
    stream<R>(compiledQuery: CompiledQuery<R>, 
    /**
     * How many rows should be pulled from the database at once. Supported
     * only by the postgres driver.
     */
    chunkSize: number): AsyncIterableIterator<QueryResult<R>>;
    /**
     * Returns a copy of this executor with a new connection provider.
     */
    withConnectionProvider(connectionProvider: ConnectionProvider): QueryExecutor;
    /**
     * Returns a copy of this executor with a plugin added as the
     * last plugin.
     */
    withPlugin(plugin: KyselyPlugin): QueryExecutor;
    /**
     * Returns a copy of this executor with a list of plugins added
     * as the last plugins.
     */
    withPlugins(plugin: ReadonlyArray<KyselyPlugin>): QueryExecutor;
    /**
     * Returns a copy of this executor with a plugin added as the
     * first plugin.
     */
    withPluginAtFront(plugin: KyselyPlugin): QueryExecutor;
    /**
     * Returns a copy of this executor without any plugins.
     */
    withoutPlugins(): QueryExecutor;
}

import type { ConnectionProvider } from '../driver/connection-provider.js'; import type { QueryResult } from '../driver/database-connection.js'; import type { CompiledQuery } from '../query-compiler/compiled-query.js'; import type { RootOperationNode } from '../query-compiler/query-compiler.js'; import type { KyselyPlugin } from '../plugin/kysely-plugin.js'; import type { QueryId } from '../util/query-id.js'; import type { DialectAdapter } from '../dialect/dialect-adapter.js'; /** * This interface abstracts away the details of how to compile a query into SQL * and execute it. Instead of passing around all those details, {@link SelectQueryBuilder} * and other classes that execute queries can just pass around and instance of * `QueryExecutor`. */ export interface QueryExecutor extends ConnectionProvider { /** * Returns the adapter for the current dialect. */ get adapter(): DialectAdapter; /** * Returns all installed plugins. */ get plugins(): ReadonlyArray; /** * Given the query the user has built (expressed as an operation node tree) * this method runs it through all plugins' `transformQuery` methods and * returns the result. */ transformQuery(node: T, queryId: QueryId): T; /** * Compiles the transformed query into SQL. You usually want to pass * the output of {@link transformQuery} into this method but you can * compile any query using this method. */ compileQuery(node: RootOperationNode, queryId: QueryId): CompiledQuery; /** * Executes a compiled query and runs the result through all plugins' * `transformResult` method. */ executeQuery(compiledQuery: CompiledQuery): Promise>; /** * Executes a compiled query and runs the result through all plugins' * `transformResult` method. Results are streamead instead of loaded * at once. */ stream(compiledQuery: CompiledQuery, /** * How many rows should be pulled from the database at once. Supported * only by the postgres driver. */ chunkSize: number): AsyncIterableIterator>; /** * Returns a copy of this executor with a new connection provider. */ withConnectionProvider(connectionProvider: ConnectionProvider): QueryExecutor; /** * Returns a copy of this executor with a plugin added as the * last plugin. */ withPlugin(plugin: KyselyPlugin): QueryExecutor; /** * Returns a copy of this executor with a list of plugins added * as the last plugins. */ withPlugins(plugin: ReadonlyArray): QueryExecutor; /** * Returns a copy of this executor with a plugin added as the * first plugin. */ withPluginAtFront(plugin: KyselyPlugin): QueryExecutor; /** * Returns a copy of this executor without any plugins. */ withoutPlugins(): QueryExecutor; }