Merge pull request #435 from openaddresses/switch-duckdb-library

Switch DuckDB node bindings
openaddresses · Feb 25, 2025 · e903183 · e903183
2 parents fc6e1ef + dfa6bd9
commit e903183
Show file tree

Hide file tree

Showing 3 changed files with 141 additions and 551 deletions.
diff --git a/task/collect.js b/task/collect.js
@@ -14,7 +14,7 @@ import { mkdirp } from 'mkdirp';
 import S3 from '@aws-sdk/client-s3';
 import { Upload } from '@aws-sdk/lib-storage';
 import archiver from 'archiver';
-import duckdb from 'duckdb';
+import { DuckDBInstance } from '@duckdb/node-api';
 import minimist from 'minimist';
 import { Transform } from 'node:stream';
 import wkx from 'wkx';
@@ -319,7 +319,7 @@ function zip_datas(tmp, datas, name) {
 
 async function parquet_datas(tmp, datas, name) {
     const dbFilePath = path.resolve(tmp, `${name}.duckdb`);
-    const db = new duckdb.Database(dbFilePath);
+    const db = await DuckDBInstance.create(dbFilePath);
     const connection = db.connect();
 
     const createTableQuery = `