Class AsyncDuckDB

An interface for the async DuckDB bindings

Implements

AsyncDuckDBBindings

Constructors

constructor

new AsyncDuckDB(logger, worker?): AsyncDuckDB
Parameters
- logger: Logger
- worker: null | Worker = null
Returns AsyncDuckDB
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:53

Accessors

logger

get logger(): Logger
Get the logger

Returns Logger
Implementation of AsyncDuckDBBindings.logger
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:62

Methods

cancelPendingQuery

cancelPendingQuery(conn): Promise<boolean>
Cancel a pending query
Parameters
- conn: number
Returns Promise<boolean>
Implementation of AsyncDuckDBBindings.cancelPendingQuery
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:436

closePrepared

closePrepared(conn, statement): Promise<void>
Close a prepared statement
Parameters
- conn: number
- statement: number
Returns Promise<void>
Implementation of AsyncDuckDBBindings.closePrepared
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:471

collectFileStatistics

collectFileStatistics(name, enable): Promise<void>
Enable file statistics
Parameters
- name: string
- enable: boolean
Returns Promise<void>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:570

connect

connect(): Promise<AsyncDuckDBConnection>
Connect to the database

Returns Promise<AsyncDuckDBConnection>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:391

connectInternal

connectInternal(): Promise<number>
Connect to the database

Returns Promise<number>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:385

copyFileToBuffer

copyFileToBuffer(name): Promise<Uint8Array>
Copy a file to a buffer.
Parameters
- name: string
Returns Promise<Uint8Array>
Implementation of AsyncDuckDBBindings.copyFileToBuffer
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:588

copyFileToPath

copyFileToPath(name, path): Promise<void>
Copy a file to a path.
Parameters
- name: string
- path: string
Returns Promise<void>
Implementation of AsyncDuckDBBindings.copyFileToPath
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:597

createPrepared

createPrepared(conn, text): Promise<number>
Prepare a statement and return its identifier
Parameters
- conn: number
- text: string
Returns Promise<number>
Implementation of AsyncDuckDBBindings.createPrepared
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:463

detach

detach(): void
Detach from worker

Returns void
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:80

disconnect

disconnect(conn): Promise<void>
Disconnect from the database
Parameters
- conn: number
Returns Promise<void>
Implementation of AsyncDuckDBBindings.disconnect
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:397

dropFile

dropFile(name): Promise<null>
Try to drop a file
Parameters
- name: string
Returns Promise<null>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:325

dropFiles

dropFiles(): Promise<null>
Try to drop files

Returns Promise<null>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:330

exportFileStatistics

exportFileStatistics(name): Promise<FileStatistics>
Export file statistics
Parameters
- name: string
Returns Promise<FileStatistics>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:579

fetchQueryResults

fetchQueryResults(conn): Promise<Uint8Array>
Fetch query results
Parameters
- conn: number
Returns Promise<Uint8Array>
Implementation of AsyncDuckDBBindings.fetchQueryResults
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:445

flushFiles

flushFiles(): Promise<null>
Flush all files

Returns Promise<null>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:335

getFeatureFlags

getFeatureFlags(): Promise<number>
Get the feature flags

Returns Promise<number>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:362

getTableNames

getTableNames(conn, text): Promise<string[]>
Get table names
Parameters
- conn: number
- text: string
Returns Promise<string[]>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:454

getVersion

getVersion(): Promise<string>
Get the version

Returns Promise<string>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:355

globFiles

globFiles(path): Promise<WebFile[]>
Glob file infos
Parameters
- path: string
Returns Promise<WebFile[]>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:495

insertArrowFromIPCStream

insertArrowFromIPCStream(conn, buffer, options?): Promise<void>
Insert arrow from an ipc stream
Parameters
- conn: number
- buffer: Uint8Array
- Optional options: ArrowInsertOptions
Returns Promise<void>
Implementation of AsyncDuckDBBindings.insertArrowFromIPCStream
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:606

insertCSVFromPath

insertCSVFromPath(conn, path, options): Promise<void>
Insert a csv file
Parameters
- conn: number
- path: string
- options: CSVInsertOptions
Returns Promise<void>
Implementation of AsyncDuckDBBindings.insertCSVFromPath
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:621

insertJSONFromPath

insertJSONFromPath(conn, path, options): Promise<void>
Insert a json file
Parameters
- conn: number
- path: string
- options: JSONInsertOptions
Returns Promise<void>
Implementation of AsyncDuckDBBindings.insertJSONFromPath
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:641

instantiate

instantiate(mainModuleURL, pthreadWorkerURL?, progress?): Promise<null>
Open the database
Parameters
- mainModuleURL: string
- pthreadWorkerURL: null | string = null
- progress: ((progress) => void) = ...
  - - (progress): void
    - Parameters
      progress: InstantiationProgress
      Returns void
Returns Promise<null>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:341

open

open(config): Promise<void>
Open a new database
Parameters
- config: DuckDBConfig
Returns Promise<void>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:372

ping

ping(): Promise<any>
Ping the worker thread

Returns Promise<any>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:320

pollPendingQuery

pollPendingQuery(conn): Promise<null | Uint8Array>
Poll a pending query
Parameters
- conn: number
Returns Promise<null | Uint8Array>
Implementation of AsyncDuckDBBindings.pollPendingQuery
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:428

registerEmptyFileBuffer

registerEmptyFileBuffer(name): Promise<void>
Register an empty file buffer.
Parameters
- name: string
Returns Promise<void>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:526

registerFileBuffer

registerFileBuffer(name, buffer): Promise<void>
Register a file buffer.
Parameters
- name: string
- buffer: Uint8Array
Returns Promise<void>
Implementation of AsyncDuckDBBindings.registerFileBuffer
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:537

registerFileHandle

registerFileHandle<HandleType>(name, handle, protocol, directIO): Promise<void>
Register a file handle.
Type Parameters
- HandleType
Parameters
- name: string
- handle: HandleType
- protocol: DuckDBDataProtocol
- directIO: boolean
Returns Promise<void>
Implementation of AsyncDuckDBBindings.registerFileHandle
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:546

registerFileText

registerFileText(name, text): Promise<void>
Register file text
Parameters
- name: string
- text: string
Returns Promise<void>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:503

registerFileURL

registerFileURL(name, url, proto, directIO): Promise<void>
Register a file path.
Parameters
- name: string
- url: string
- proto: DuckDBDataProtocol
- directIO: boolean
Returns Promise<void>
Implementation of AsyncDuckDBBindings.registerFileURL
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:508

registerOPFSFileName

registerOPFSFileName(name): Promise<void>
Enable file statistics
Parameters
- name: string
Returns Promise<void>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:561

reset

reset(): Promise<null>
Reset the duckdb

Returns Promise<null>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:314

runPrepared

runPrepared(conn, statement, params): Promise<Uint8Array>
Execute a prepared statement and return the full result
Parameters
- conn: number
- statement: number
- params: any[]
Returns Promise<Uint8Array>
Implementation of AsyncDuckDBBindings.runPrepared
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:479

runQuery

runQuery(conn, text): Promise<Uint8Array>
Run a query
Parameters
- conn: number
- text: string
Returns Promise<Uint8Array>
Implementation of AsyncDuckDBBindings.runQuery
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:406

sendPrepared

sendPrepared(conn, statement, params): Promise<Uint8Array>
Execute a prepared statement and stream the result
Parameters
- conn: number
- statement: number
- params: any[]
Returns Promise<Uint8Array>
Implementation of AsyncDuckDBBindings.sendPrepared
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:487

startPendingQuery

startPendingQuery(conn, text, allowStreamResult?): Promise<null | Uint8Array>
Start a pending query
Parameters
- conn: number
- text: string
- allowStreamResult: boolean = false
Returns Promise<null | Uint8Array>
Implementation of AsyncDuckDBBindings.startPendingQuery
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:415

terminate

terminate(): Promise<void>
Kill the worker

Returns Promise<void>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:92

tokenize

tokenize(text): Promise<ScriptTokens>
Tokenize a script text
Parameters
- text: string
Returns Promise<ScriptTokens>
- Defined in packages/duckdb-wasm/src/parallel/async_bindings.ts:378