Commit baf5862

author

Connell, Joseph

committed

updated depricated duckDb library with new @duckdb/node-api package

1 parent c174d6b commit baf5862Copy full SHA for baf5862

File tree

3 files changed

+93

-527

lines changed

server/node-service
- package.json
- src/plugins/duckdb
  - index.ts
- yarn.lock

3 files changed

+93

-527

lines changed

`‎server/node-service/package.json`

Lines changed: 1 addition & 1 deletion

Original file line number	Diff line number	Diff line change
`@@ -37,6 +37,7 @@`
`37`	`37`	`"@aws-sdk/client-lambda": "^3.332.0",`
`38`	`38`	`"@aws-sdk/client-s3": "^3.332.0",`
`39`	`39`	`"@aws-sdk/s3-request-presigner": "^3.332.0",`
	`40`	`+ "@duckdb/node-api": "^1.3.0-alpha.21",`
`40`	`41`	`"@google-cloud/bigquery": "^6.1.0",`
`41`	`42`	`"@google-cloud/storage": "^6.10.1",`
`42`	`43`	`"@supabase/supabase-js": "^2.26.0",`
`@@ -52,7 +53,6 @@`
`52`	`53`	`"base64-arraybuffer": "^1.0.2",`
`53`	`54`	`"bluebird": "^3.7.2",`
`54`	`55`	`"cors": "^2.8.5",`
`55`		`- "duckdb-async": "^1.1.3",`
`56`	`56`	`"dynamodb-data-types": "^4.0.1",`
`57`	`57`	`"express": "^4.21.0",`
`58`	`58`	`"express-async-errors": "^3.1.1",`

`‎server/node-service/src/plugins/duckdb/index.ts`

Lines changed: 8 additions & 6 deletions

Original file line number	Diff line number	Diff line change
`@@ -1,7 +1,7 @@`
`1`	`1`	`import { DataSourcePlugin } from "lowcoder-sdk/dataSource";`
`2`	`2`	`import dataSourceConfig, { DataSourceDataType } from "./dataSourceConfig";`
`3`	`3`	`import queryConfig, { ActionDataType } from "./queryConfig";`
`4`		`-import { Database } from "duckdb-async";`
	`4`	`+import { DuckDBInstance } from "@duckdb/node-api";`
`5`	`5`	`import { ServiceError } from "../../common/error";`
`6`	`6`
`7`	`7`	`// Helper function to handle BigInt serialization`
`@@ -23,20 +23,22 @@ const duckdbPlugin: DataSourcePlugin<ActionDataType, DataSourceDataType> = {`
`23`	`23`	`run: async function (actionData, dataSourceConfig): Promise<any> {`
`24`	`24`	`const { databaseFile, options } = dataSourceConfig;`
`25`	`25`	`const parsedOptions = JSON.parse(options);`
`26`		`- const db = await Database.create(databaseFile, parsedOptions);`
	`26`	`+ const instance = await DuckDBInstance.create(databaseFile, parsedOptions);`
	`27`	`+ const db = await instance.connect();`
`27`	`28`
`28`	`29`	`if (actionData.actionName === "Query") {`
`29`	`30`	`try {`
`30`		`- const result = await db.all(actionData.queryString);`
	`31`	`+ const result = await db.runAndReadAll(actionData.queryString);`
	`32`	`+ const data = await result.getRows();`
`31`	`33`	`// Apply BigInt serialization to each row`
`32`		`- return result.map(serializeBigInts);`
	`34`	`+ return data.map(serializeBigInts);`
`33`	`35`	`} catch (error) {`
`34`	`36`	`throw new ServiceError((error as Error).message);`
`35`	`37`	`} finally {`
`36`		`- await db.close();`
	`38`	`+ await db.closeSync();`
`37`	`39`	`}`
`38`	`40`	`}`
`39`	`41`	`},`
`40`	`42`	`};`
`41`	`43`
`42`		`-export default duckdbPlugin;`
	`44`	`+export default duckdbPlugin;`

0 commit comments

Comments

(0)

Navigation Menu

Search code, repositories, users, issues, pull requests...

Provide feedback

Saved searches

Use saved searches to filter your results more quickly

Uh oh!

Commit baf5862

File tree

3 files changed

3 files changed

`‎server/node-service/package.json`

`‎server/node-service/src/plugins/duckdb/index.ts`

0 commit comments