Commit8fe9847

authored

feat(sync-engine): add close() method to release database connections (#230)

1 parent9ddcea5 commit8fe9847Copy full SHA for 8fe9847

File tree

+16

-0

lines changed

+16

-0

lines changed

Lines changed: 8 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -139,3 +139,11 @@ await sync.syncBackfill({`
`139`	`139`
`140`	`140`	`>Note:`
`141`	`141`	>For large Stripe accounts (more than 10,000 objects), it is recommended to write a script that loops through each day and sets the`created` date filters to the start and end of day. This avoids timeouts and memory issues when syncing large datasets.
	`142`	`+`
	`143`	`+##Cleanup`
	`144`	`+`
	`145`	+Call`close()` to release database connections when shutting down:
	`146`	`+`
	`147`	+```ts
	`148`	`+awaitsync.close()`
	`149`	+```

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -229,4 +229,8 @@ export class PostgresClient {`
`229`	`229`	`})`
`230`	`230`	`returncleansed`
`231`	`231`	`}`
	`232`	`+`
	`233`	`+asyncclose():Promise<void>{`
	`234`	`+awaitthis.pool.end()`
	`235`	`+}`
`232`	`236`	`}`

Lines changed: 4 additions & 0 deletions

Original file line number	Diff line number	Diff line change
`@@ -1710,6 +1710,10 @@ export class StripeSync {`
`1710`	`1710`
`1711`	`1711`	`returnentities`
`1712`	`1712`	`}`
	`1713`	`+`
	`1714`	`+asyncclose():Promise<void>{`
	`1715`	`+awaitthis.postgresClient.close()`
	`1716`	`+}`
`1713`	`1717`	`}`
`1714`	`1718`
`1715`	`1719`	`functionchunkArray<T>(array:T[],chunkSize:number):T[][]{`

Comments

(0)