Connect to the database
-Export file statistics
-Insert arrow from an ipc stream
-Optional
options: ArrowInsertOptionsInsert a csv file
-Insert a json file
-Open the database
-Open a new database
-Register a file handle.
-Register a file path.
-Generated using TypeDoc
An interface for the async DuckDB bindings
+Connect to the database
+Export file statistics
+Insert arrow from an ipc stream
+Optional
options: ArrowInsertOptionsInsert a csv file
+Insert a json file
+Open the database
+Open a new database
+Register a file handle.
+Register a file path.
+Tokenize a script text
+A thin helper to memoize the connection id
-Access the database bindings
-Insert an arrow table from an ipc stream
-Insert an arrow table
-Insert csv file from path
-Insert json file from path
-Create a prepared statement
-Brave souls may use this function to consume the underlying connection id
-Generated using TypeDoc
A thin helper to memoize the connection id
+Access the database bindings
+Insert an arrow table from an ipc stream
+Insert an arrow table
+Insert csv file from path
+Insert json file from path
+Create a prepared statement
+Abstract
Send log entry to the main thread
-Process a request from the main thread
-Generated using TypeDoc
Abstract
Send log entry to the main thread
+Process a request from the main thread
+A thin helper to bind the prepared statement id
-Constructor
-Generated using TypeDoc
A thin helper to bind the prepared statement id
+Constructor
+An async result stream iterator
-Generated using TypeDoc
An async result stream iterator
+Generated using TypeDoc
Abstract
The proxy for either the browser- order node-based DuckDB API
-Get the instance
-Connect to database
-Create a scalar function
-Rest
...args: any[]Export file statistics
-Insert record batches from an arrow ipc stream
-Optional
options: ArrowInsertOptionsInsert csv from path
-Insert json from path
-Instantiate the database
-Open a database with a config
-Register a file object URL
-Register a file object URL
-Start a pending query asynchronously. +
Abstract
The proxy for either the browser- order node-based DuckDB API
+Get the instance
+Connect to database
+Export file statistics
+Insert record batches from an arrow ipc stream
+Optional
options: ArrowInsertOptionsInsert csv from path
+Insert json from path
+Instantiate the database
+Open a database with a config
+Register a file object URL
+Register a file object URL
+Start a pending query asynchronously.
This method returns either the arrow ipc schema or null.
On null, the query has to be executed using pollPendingQuery
until that returns != null.
Results can then be fetched using fetchQueryResults
Generated using TypeDoc
Tokenize a script
+A thin helper to bind the connection id and talk record batches
-Constructor
-Create a scalar function
-Rest
...args: any[]Insert an arrow table from an ipc stream
-Insert an arrow table
-Inesrt csv file from path
-Insert json file from path
-Create a prepared statement
-Brave souls may use this function to consume the underlying connection id
-Generated using TypeDoc
A thin helper to bind the connection id and talk record batches
+Constructor
+Insert an arrow table from an ipc stream
+Insert an arrow table
+Inesrt csv file from path
+Insert json file from path
+Create a prepared statement
+The file block statistics
-The blocks
-The blocks
-The file readaheads
-The cached file reads
-The cold file reads
-The file writes
-The page accesses
-The page loads
-The block stats
-Optional
out: FileBlockStatisticsGenerated using TypeDoc
The file block statistics
+The blocks
+The blocks
+The file readaheads
+The cached file reads
+The cold file reads
+The file writes
+The page accesses
+The page loads
+The block stats
+Optional
out: FileBlockStatisticsA thin helper to bind the prepared statement id
-Constructor
-Generated using TypeDoc
A thin helper to bind the prepared statement id
+Constructor
+A result stream iterator
-Reached end of stream?
-First chunk?
-Generated using TypeDoc
A result stream iterator
+Reached end of stream?
+First chunk?
+Generated using TypeDoc
Readonly
dataReadonly
typeGenerated using TypeDoc
Readonly
dataReadonly
typeGenerated using TypeDoc
Generated using TypeDoc
File flags for opening files
-Generated using TypeDoc
File flags for opening files
+Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Call a function with packed response buffer
-Generated using TypeDoc
Call a function with packed response buffer
+Copy a buffer
-Generated using TypeDoc
Copy a buffer
+Generated using TypeDoc
Generated using TypeDoc
Drop response buffers
-Generated using TypeDoc
Drop response buffers
+Copy a buffer
-Generated using TypeDoc
Copy a buffer
+Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Decode a string
-Generated using TypeDoc
Decode a string
+Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
An interface for the async DuckDB bindings
-Optional
options: CSVInsertOptionsGenerated using TypeDoc
An interface for the async DuckDB bindings
+Optional
options: CSVInsertOptionsOptional
columnsOptional
columnsOptional
createOptional
dateOptional
delimiterOptional
detectOptional
escapeOptional
headerOptional
quoteOptional
schemaOptional
skipOptional
timestampGenerated using TypeDoc
Optional
columnsOptional
columnsOptional
createOptional
dateOptional
delimiterOptional
detectOptional
escapeOptional
headerOptional
quoteOptional
schemaOptional
skipOptional
timestampRest
...args: any[]Optional
options: ArrowInsertOptionsGenerated using TypeDoc
Optional
options: ArrowInsertOptionsGenerated using TypeDoc
Optional
coiOptional
ehGenerated using TypeDoc
Bundles have different characteristics:
+Optional
coiOptional
ehOptional
filesystemThe filesystem config
-Optional
maximumThe maximum number of threads. +
Optional
accessThe access mode
+Optional
allowWhether to allow unsigned extensions
+Optional
customCustom user agent string
+Optional
filesystemThe filesystem config
+Optional
maximumThe maximum number of threads. Note that this will only work with cross-origin isolated sites since it requires SharedArrayBuffers.
-Optional
pathThe database path
-Optional
queryThe query config
-Generated using TypeDoc
Optional
pathThe database path
+Optional
queryThe query config
+An info for a file registered with DuckDB
-Optional
allowOptional
s3Generated using TypeDoc
An info for a file registered with DuckDB
+Optional
allowOptional
reliableOptional
s3Generated using TypeDoc
Generated using TypeDoc
Global info for all files registered with DuckDB
+Optional
allowOptional
reliableOptional
s3Optional
opts: CCallOptsGenerated using TypeDoc
Optional
castCast BigInt to Double?
-Optional
castCast Decimal to Double?
-Optional
castCast Timestamp to Date64?
-Optional
castCast Timestamp to Date64?
-Optional
queryThe polling interval for queries
-Generated using TypeDoc
Optional
castCast BigInt to Double?
+Optional
castCast Decimal to Double?
+Optional
castCast Timestamp to Date64?
+Optional
castCast Timestamp to Date64?
+Optional
queryThe polling interval for queries
+The duckdb runtime
-Optional
_filesGenerated using TypeDoc
The duckdb runtime
+Optional
_filesThe file reads aheads
-The file reads cached
-The file reads cold
-The file writes
-The page accesses
-The page loads
-Generated using TypeDoc
The file reads aheads
+The file reads cached
+The file reads cold
+The file writes
+The page accesses
+The page loads
+Generated using TypeDoc
An instantiation progress
+Optional
columnsOptional
columnsOptional
createOptional
schemaOptional
shapeGenerated using TypeDoc
Optional
columnsOptional
columnsOptional
createOptional
schemaOptional
shapeGenerated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Configuration for the AWS S3 Filesystem
-Optional
accessOptional
endpointOptional
regionOptional
secretOptional
sessionGenerated using TypeDoc
Configuration for the AWS S3 Filesystem
+Optional
accessOptional
endpointOptional
regionOptional
secretOptional
sessionOptional
allowOptional
collectOptional
dataOptional
dataOptional
fileOptional
fileOptional
reliableGenerated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
An instantiation progress handler
-Generated using TypeDoc
An instantiation progress handler
+Readonly
event: EReadonly
level: LogLevelReadonly
origin: OReadonly
timestamp: DateReadonly
topic: TReadonly
value: VGenerated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Readonly
data: PReadonly
messageReadonly
type: TGenerated using TypeDoc
Generated using TypeDoc
Readonly
data: PReadonly
messageReadonly
requestReadonly
type: TGenerated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Generated using TypeDoc
Const
Generated using TypeDoc
Const
Const
Generated using TypeDoc
Const
Const
Generated using TypeDoc
Const
Const
Generated using TypeDoc
Const
Const
Generated using TypeDoc
Const
Const
Generated using TypeDoc
Const
Const
Generated using TypeDoc
Const
Const
Generated using TypeDoc
Const
>>0],i[g]=255&c,i[g+1]=c>>8&255,i[g+2]=c>>16&255,i[g+3]=f?255:c>>24&255,m++,g+=4;else{var E=new Uint32Array(i.buffer);if(f&&SDL.defaults.opaqueFrontBuffer){p=E.length,E.set(GROWABLE_HEAP_I32().subarray(m>>>0,m+p>>>0));var h=new Uint8Array(i.buffer),v=3,S=v+4*p;if(p%8==0)for(;v>>0,m+E.length>>>0))}}r.ctx.putImageData(r.image,0,0)}}function _SDL_Flip(e){}function _SDL_UpdateRect(e,r,t,n,a){}function _SDL_UpdateRects(e,r,t){}_SDL_Quit.sig="v",_SDL_UnlockSurface.sig="vp",_SDL_Flip.sig="ip",_SDL_UpdateRect.sig="vpiiii",_SDL_UpdateRects.sig="vpip";var _SDL_Delay=e=>{ENVIRONMENT_IS_WORKER||abort("SDL_Delay called on the main thread! Potential infinite loop, quitting. (consider building with async support like ASYNCIFY)");for(var r=Date.now();Date.now()-r>>2]|=r[_]<>>2]|=a<>>2]|=(192|a>>>6)<>>2]|=(128|63&a)<=57344?(l[i>>>2]|=(224|a>>>12)<>>2]|=(128|a>>>6&63)<>>2]|=(128|63&a)<>>2]|=(240|a>>>18)<>>2]|=(128|a>>>12&63)<>>2]|=(128|a>>>6&63)<>>2]|=(128|63&a)<=64?(this.block=l[16],this.start=i-64,this.hash(),this.hashed=!0):this.start=i}return this.bytes>4294967295&&(this.hBytes+=this.bytes/4294967296<<0,this.bytes=this.bytes%4294967296),this}},S.prototype.finalize=function(){if(!this.finalized){this.finalized=!0;var e=this.blocks,r=this.lastByteIndex;e[16]=this.block,e[r>>>2]|=c[3&r],this.block=e[16],r>=56&&(this.hashed||this.hash(),e[0]=this.block,e[16]=e[1]=e[2]=e[3]=e[4]=e[5]=e[6]=e[7]=e[8]=e[9]=e[10]=e[11]=e[12]=e[13]=e[14]=e[15]=0),e[14]=this.hBytes<<3|this.bytes>>>29,e[15]=this.bytes<<3,this.hash()}},S.prototype.hash=function(){var e,r,t,n,a,i,_,s,o,l=this.h0,c=this.h1,u=this.h2,p=this.h3,m=this.h4,g=this.h5,f=this.h6,E=this.h7,h=this.blocks;for(e=16;e<64;++e)r=((a=h[e-15])>>>7|a<<25)^(a>>>18|a<<14)^a>>>3,t=((a=h[e-2])>>>17|a<<15)^(a>>>19|a<<13)^a>>>10,h[e]=h[e-16]+r+h[e-7]+t<<0;for(o=c&u,e=0;e<64;e+=4)this.first?(this.is224?(i=300032,E=(a=h[0]-1413257819)-150054599<<0,p=a+24177077<<0):(i=704751109,E=(a=h[0]-210244248)-1521486534<<0,p=a+143694565<<0),this.first=!1):(r=(l>>>2|l<<30)^(l>>>13|l<<19)^(l>>>22|l<<10),n=(i=l&c)^l&u^o,E=p+(a=E+(t=(m>>>6|m<<26)^(m>>>11|m<<21)^(m>>>25|m<<7))+(m&g^~m&f)+d[e]+h[e])<<0,p=a+(r+n)<<0),r=(p>>>2|p<<30)^(p>>>13|p<<19)^(p>>>22|p<<10),n=(_=p&l)^p&c^i,f=u+(a=f+(t=(E>>>6|E<<26)^(E>>>11|E<<21)^(E>>>25|E<<7))+(E&m^~E&g)+d[e+1]+h[e+1])<<0,r=((u=a+(r+n)<<0)>>>2|u<<30)^(u>>>13|u<<19)^(u>>>22|u<<10),n=(s=u&p)^u&l^_,g=c+(a=g+(t=(f>>>6|f<<26)^(f>>>11|f<<21)^(f>>>25|f<<7))+(f&E^~f&m)+d[e+2]+h[e+2])<<0,r=((c=a+(r+n)<<0)>>>2|c<<30)^(c>>>13|c<<19)^(c>>>22|c<<10),n=(o=c&u)^c&p^s,m=l+(a=m+(t=(g>>>6|g<<26)^(g>>>11|g<<21)^(g>>>25|g<<7))+(g&f^~g&E)+d[e+3]+h[e+3])<<0,l=a+(r+n)<<0,this.chromeBugWorkAround=!0;this.h0=this.h0+l<<0,this.h1=this.h1+c<<0,this.h2=this.h2+u<<0,this.h3=this.h3+p<<0,this.h4=this.h4+m<<0,this.h5=this.h5+g<<0,this.h6=this.h6+f<<0,this.h7=this.h7+E<<0},S.prototype.hex=function(){this.finalize();var e=this.h0,r=this.h1,t=this.h2,n=this.h3,a=this.h4,i=this.h5,_=this.h6,s=this.h7,o=l[e>>>28&15]+l[e>>>24&15]+l[e>>>20&15]+l[e>>>16&15]+l[e>>>12&15]+l[e>>>8&15]+l[e>>>4&15]+l[15&e]+l[r>>>28&15]+l[r>>>24&15]+l[r>>>20&15]+l[r>>>16&15]+l[r>>>12&15]+l[r>>>8&15]+l[r>>>4&15]+l[15&r]+l[t>>>28&15]+l[t>>>24&15]+l[t>>>20&15]+l[t>>>16&15]+l[t>>>12&15]+l[t>>>8&15]+l[t>>>4&15]+l[15&t]+l[n>>>28&15]+l[n>>>24&15]+l[n>>>20&15]+l[n>>>16&15]+l[n>>>12&15]+l[n>>>8&15]+l[n>>>4&15]+l[15&n]+l[a>>>28&15]+l[a>>>24&15]+l[a>>>20&15]+l[a>>>16&15]+l[a>>>12&15]+l[a>>>8&15]+l[a>>>4&15]+l[15&a]+l[i>>>28&15]+l[i>>>24&15]+l[i>>>20&15]+l[i>>>16&15]+l[i>>>12&15]+l[i>>>8&15]+l[i>>>4&15]+l[15&i]+l[_>>>28&15]+l[_>>>24&15]+l[_>>>20&15]+l[_>>>16&15]+l[_>>>12&15]+l[_>>>8&15]+l[_>>>4&15]+l[15&_];return this.is224||(o+=l[s>>>28&15]+l[s>>>24&15]+l[s>>>20&15]+l[s>>>16&15]+l[s>>>12&15]+l[s>>>8&15]+l[s>>>4&15]+l[15&s]),o},S.prototype.toString=S.prototype.hex,S.prototype.digest=function(){this.finalize();var e=this.h0,r=this.h1,t=this.h2,n=this.h3,a=this.h4,i=this.h5,_=this.h6,s=this.h7,o=[e>>>24&255,e>>>16&255,e>>>8&255,255&e,r>>>24&255,r>>>16&255,r>>>8&255,255&r,t>>>24&255,t>>>16&255,t>>>8&255,255&t,n>>>24&255,n>>>16&255,n>>>8&255,255&n,a>>>24&255,a>>>16&255,a>>>8&255,255&a,i>>>24&255,i>>>16&255,i>>>8&255,255&i,_>>>24&255,_>>>16&255,_>>>8&255,255&_];return this.is224||o.push(s>>>24&255,s>>>16&255,s>>>8&255,255&s),o},S.prototype.array=S.prototype.digest,S.prototype.arrayBuffer=function(){this.finalize();var e=new ArrayBuffer(this.is224?28:32),r=new DataView(e);return r.setUint32(0,this.h0),r.setUint32(4,this.h1),r.setUint32(8,this.h2),r.setUint32(12,this.h3),r.setUint32(16,this.h4),r.setUint32(20,this.h5),r.setUint32(24,this.h6),this.is224||r.setUint32(28,this.h7),e},A.prototype=new S,A.prototype.finalize=function(){if(S.prototype.finalize.call(this),this.inner){this.inner=!1;var e=this.array();S.call(this,this.is224,this.sharedMemory),this.update(this.oKeyPad),this.update(e),S.prototype.finalize.call(this)}};var b=f();b.sha256=b,b.sha224=f(!0),b.sha256.hmac=v(),b.sha224.hmac=v(!0),_?r.exports=b:(n.sha256=b.sha256,n.sha224=b.sha224,s&&define((function(){return b})))}()})),C={},we="object"==typeof process&&"object"==typeof process.versions&&"string"==typeof process.versions.node;we&&(ne=te(),ie=ne.parentPort,ie.on("message",(e=>oe({data:e}))),ae=Z(),ye=["vm"].map(J),Object.assign(global,{self:global,require:J,Module:C,location:{href:__filename},Worker:ne.Worker,importScripts:e=>ye.runInThisContext(ae.readFileSync(e,"utf8"),{filename:e}),postMessage:e=>ie.postMessage(e),performance:global.performance||{now:Date.now}}));var ne,ie,ae,ye,_e=!1;function Je(...e){var r=e.join(" ");we?ae.writeSync(2,r+"\n"):console.error(r)}function Qe(...e){var r=e.join(" ");postMessage({cmd:"alert",text:r,threadId:C._pthread_self()})}var Te=Je;function se(e){var r;try{if("load"===e.data.cmd){let r=[];self.onmessage=e=>r.push(e),self.startWorker=e=>{C=e,postMessage({cmd:"loaded"});for(let e of r)se(e);self.onmessage=se},C.wasmModule=e.data.wasmModule,C.sharedModules=e.data.sharedModules;for(let r of e.data.handlers)C[r]=(...e)=>{postMessage({cmd:"callHandler",handler:r,args:e})};if(C.wasmMemory=e.data.wasmMemory,C.buffer=C.wasmMemory.buffer,C.ENVIRONMENT_IS_PTHREAD=!0,"string"==typeof e.data.urlOrBlob)importScripts(e.data.urlOrBlob);else{var t=URL.createObjectURL(e.data.urlOrBlob);importScripts(t),URL.revokeObjectURL(t)}DuckDB(C)}else if("run"===e.data.cmd){C.__emscripten_thread_init(e.data.pthread_ptr,0,0,1),C.__emscripten_thread_mailbox_await(e.data.pthread_ptr),C.establishStackSpace(),C.PThread.receiveObjectTransfer(e.data),C.PThread.threadInitTLS(),_e||(C.__embind_initialize_bindings(),_e=!0);try{C.invokeEntryPoint(e.data.start_routine,e.data.arg)}catch(e){if("unwind"!=e)throw e}}else"cancel"===e.data.cmd?C._pthread_self()&&C.__emscripten_thread_exit(-1):"setimmediate"===e.data.target||("checkMailbox"===e.data.cmd?_e&&C.checkMailbox():e.data.cmd&&(Te("worker.js received unknown command ".concat(e.data.cmd)),Te(e.data)))}catch(e){throw null==(r=C.__emscripten_thread_crashed)||r.call(C),e}}self.alert=Qe,C.instantiateWasm=(e,r)=>{var t=C.wasmModule;return C.wasmModule=null,r(new WebAssembly.Instance(t,e),t)},self.onunhandledrejection=e=>{throw e.reason||e},self.onmessage=se;var oe=self.onmessage;function De(){return C}function xe(e){C=e}var Ue=be(Ie()),Q=be(Fe()),ke=function(e,r,t){var n;if(null!=(n=null==e?void 0:e.endpoint)&&n.startsWith("http")){let r="".concat(null==e?void 0:e.endpoint),t=r.indexOf("://")+3;return r.substring(t)}return null!=e&&e.endpoint?"".concat(t,".").concat(null==e?void 0:e.endpoint):"".concat(t,".s3.amazonaws.com")};function Ye(e,r,t){var n,a,i,_;let s=Oe(r),o=s.path;return Be(e)&&(o="/".concat(s.bucket).concat(o)),{url:o,query:"",host:ke(e,r,s.bucket),region:null!=(n=null==e?void 0:e.region)?n:"",service:"s3",method:t,accessKeyId:null!=(a=null==e?void 0:e.accessKeyId)?a:"",secretAccessKey:null!=(i=null==e?void 0:e.secretAccessKey)?i:"",sessionToken:null!=(_=null==e?void 0:e.sessionToken)?_:"",dateNow:(new Date).toISOString().replace(/-/g,"").split("T")[0],datetimeNow:(new Date).toISOString().replace(/-/g,"").replace(/:/g,"").split(".")[0]+"Z"}}function Ze(e,r=!1){let t="0123456789ABCDEF",n="";for(let a=0;a
An interface for the async DuckDB bindings
-