Methods
cancelSent
- cancelSent(): boolean
Returns boolean
close
- close(): void
Returns void
createScalarFunction
- createScalarFunction(name, returns, func): void
Parameters
- name: string
- returns: DataType<Type, any>
- func: ((...args) => void)
- (...args): void
Returns void
Returns void
getTableNames
- getTableNames(query): string[]
Returns string[]
insertArrowFromIPCStream
- insertArrowFromIPCStream(buffer, options): void
Returns void
insertArrowTable
- insertArrowTable(table, options): void
Returns void
insertCSVFromPath
- insertCSVFromPath(path, options): void
Returns void
insertJSONFromPath
- insertJSONFromPath(path, options): void
Returns void
prepare
- prepare<T>(text): PreparedStatement<any>
Type Parameters
- T extends {
[key: string]: arrow.DataType;
} = any
query
- query<T>(text): Table<T>
Type Parameters
- T extends {
[key: string]: arrow.DataType;
} = any
Returns Table<T>
send
- send<T>(text, allowStreamResult?): Promise<RecordBatchStreamReader<T>>
Type Parameters
- T extends {
[key: string]: arrow.DataType;
} = any
Parameters
- text: string
- allowStreamResult: boolean = false
Returns Promise<RecordBatchStreamReader<T>>
useUnsafe
- useUnsafe<R>(callback): R
Parameters
- callback: ((bindings, conn) => R)
- (bindings, conn): R
Returns R
Returns R
A thin helper to bind the connection id and talk record batches