Class AsyncDuckDBConnection
Methods
cancelSent
- cancelSent(): Promise<boolean>
Returns Promise<boolean>
close
- close(): Promise<void>
Returns Promise<void>
getTableNames
- getTableNames(query): Promise<string[]>
Returns Promise<string[]>
insertArrowFromIPCStream
- insertArrowFromIPCStream(buffer, options): Promise<void>
Returns Promise<void>
insertArrowTable
- insertArrowTable(table, options): Promise<void>
Returns Promise<void>
insertCSVFromPath
- insertCSVFromPath(text, options): Promise<void>
Returns Promise<void>
insertJSONFromPath
- insertJSONFromPath(text, options): Promise<void>
Returns Promise<void>
prepare
- prepare<T>(text): Promise<AsyncPreparedStatement<any>>
Type Parameters
- T extends {
[key: string]: arrow.DataType;
} = any
query
- query<T>(text): Promise<Table<T>>
Type Parameters
- T extends {
[key: string]: arrow.DataType;
} = any
Returns Promise<Table<T>>
send
- send<T>(text, allowStreamResult?): Promise<AsyncRecordBatchStreamReader<T>>
Type Parameters
- T extends {
[key: string]: arrow.DataType;
} = any
Parameters
- text: string
- allowStreamResult: boolean = false
Returns Promise<AsyncRecordBatchStreamReader<T>>
useUnsafe
- useUnsafe<R>(callback): R
Parameters
- callback: ((bindings, conn) => R)
- (bindings, conn): R
Returns R
Returns R
A thin helper to memoize the connection id