Skip to content

@sqlrooms/duckdb / BaseDuckDbConnectorImpl

Interface: BaseDuckDbConnectorImpl

Methods

initializeInternal()?

optional initializeInternal(): Promise<void>

Returns

Promise<void>


destroyInternal()?

optional destroyInternal(): Promise<void>

Returns

Promise<void>


executeQueryInternal()

executeQueryInternal<T>(query, signal, queryId?): Promise<Table<T>>

Type Parameters

Type ParameterDefault type
T extends TypeMapany

Parameters

ParameterType
querystring
signalAbortSignal
queryId?string

Returns

Promise<Table<T>>


cancelQueryInternal()?

optional cancelQueryInternal(queryId): Promise<void>

Parameters

ParameterType
queryIdstring

Returns

Promise<void>


loadArrowInternal()?

optional loadArrowInternal(file, tableName, opts?): Promise<void>

Parameters

ParameterType
fileTable<any> | Uint8Array<ArrayBufferLike>
tableNamestring
opts?{ schema: string; }
opts.schema?string

Returns

Promise<void>


loadObjectsInternal()?

optional loadObjectsInternal(file, tableName, opts?): Promise<void>

Parameters

ParameterType
fileRecord<string, unknown>[]
tableNamestring
opts?objectOutputType<{ schema: ZodOptional<ZodString>; select: ZodOptional<ZodArray<ZodString, "many">>; where: ZodOptional<ZodString>; view: ZodOptional<ZodBoolean>; temp: ZodOptional<ZodBoolean>; replace: ZodOptional<ZodBoolean>; }, ZodUnknown, "strip">

Returns

Promise<void>


loadFileInternal()?

optional loadFileInternal(file, tableName, opts?): Promise<void>

Parameters

ParameterType
filestring | File
tableNamestring
opts?objectOutputType<object & object, ZodUnknown, "strip"> | objectOutputType<object & object & object, ZodUnknown, "strip">

Returns

Promise<void>