groot/automatisch
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix(postgresql): close connections when done

Browse Source
This commit is contained in:
AnimatedSwine37
2023-06-27 10:31:09 +10:00
committed by Ali BARIN
parent 110c2dbac8
commit 8e9896ec2e
5 changed files with 8 additions and 0 deletions
Download Patch File Download Diff File Expand all files Collapse all files

2
packages/backend/src/apps/postgresql/actions/delete/index.ts
View File

@@ -102,6 +102,8 @@ export default defineAction({
}) })
.del() as IJSONArray; .del() as IJSONArray;
client.destroy();
$.setActionItem({ $.setActionItem({
raw: { raw: {
rows: response rows: response

2
packages/backend/src/apps/postgresql/actions/insert/index.ts
View File

@@ -88,6 +88,8 @@ export default defineAction({
.returning('*') .returning('*')
.insert(data) as IJSONObject; .insert(data) as IJSONObject;
client.destroy();
$.setActionItem({ raw: response[0] as IJSONObject }); $.setActionItem({ raw: response[0] as IJSONObject });
}, },
}); });

1
packages/backend/src/apps/postgresql/actions/sql-query/index.ts
View File

@@ -46,6 +46,7 @@ export default defineAction({
const queryStatemnt = $.step.parameters.queryStatement; const queryStatemnt = $.step.parameters.queryStatement;
const { rows } = await client.raw(queryStatemnt); const { rows } = await client.raw(queryStatemnt);
client.destroy();
$.setActionItem({ $.setActionItem({
raw: { raw: {

2
packages/backend/src/apps/postgresql/actions/update/index.ts
View File

@@ -132,6 +132,8 @@ export default defineAction({
}) })
.update(data) as IJSONArray; .update(data) as IJSONArray;
client.destroy();
$.setActionItem({ $.setActionItem({
raw: { raw: {
rows: response rows: response

1
packages/backend/src/apps/postgresql/auth/verify-credentials.ts
View File

@@ -5,6 +5,7 @@ import getClient from '../common/postgres-client';
const verifyCredentials = async ($: IGlobalVariable) => { const verifyCredentials = async ($: IGlobalVariable) => {
const client = getClient($); const client = getClient($);
const checkConnection = await client.raw('SELECT 1'); const checkConnection = await client.raw('SELECT 1');
client.destroy();
logger.debug(checkConnection); logger.debug(checkConnection);