Elgato_dark/console
1
0
Fork 0
mirror of https://github.com/graphql-hive/console synced 2026-05-23 17:18:23 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Use sql.unnest for inserting large set or rows (#3595)

Browse source
This commit is contained in:
Kamil Kisiela 2023-12-13 09:35:59 +01:00 committed by GitHub
parent 4574221a71
commit 0c22a415d2
No known key found for this signature in database
GPG key ID: 4AEE18F83AFDEB23
2 changed files with 28 additions and 30 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
packages/libraries/client/src/version.ts
View file

@ -1 +1 @@
export const version = '0.26.0';
export const version = '0.27.0';

56
packages/services/storage/src/index.ts
View file

@ -3855,23 +3855,20 @@ export async function createStorage(connection: string, maximumPoolSize: number)
, "schema_change_id"
, "schema_change"
)
VALUES ${sql.join(
schemaCheck.breakingSchemaChanges.map(
change =>
sql`(
${schemaCheck.targetId}
, ${schemaCheck.contextId}
, ${change.id}
, ${sql.jsonb(
toSerializableSchemaChange({
...change,
// We enhance the approved schema changes with some metadata that can be displayed on the UI
approvalMetadata,
}),
)}
)`,
),
sql`,`,
SELECT * FROM ${sql.unnest(
schemaCheck.breakingSchemaChanges.map(change => [
schemaCheck.targetId,
schemaCheck.contextId ?? null,
change.id,
JSON.stringify(
toSerializableSchemaChange({
...change,
// We enhance the approved schema changes with some metadata that can be displayed on the UI
approvalMetadata,
}),
),
]),
['uuid', 'text', 'text', 'jsonb'],
)}
ON CONFLICT ("target_id", "context_id", "schema_change_id") DO NOTHING
`);
@ -4447,19 +4444,20 @@ async function insertSchemaVersionChanges(
"severity_level",
"meta",
"is_safe_based_on_usage"
) VALUES ${sql.join(
args.changes.map(
change =>
// Note: change.criticality.level is actually a computed value from meta
sql`(
${args.versionId},
${change.type},
${change.criticality},
${JSON.stringify(change.meta)}::jsonb,
${change.isSafeBasedOnUsage ?? false}
)`,
)
SELECT * FROM
${sql.unnest(
args.changes.map(change =>
// Note: change.criticality.level is actually a computed value from meta
[
args.versionId,
change.type,
change.criticality,
JSON.stringify(change.meta),
change.isSafeBasedOnUsage ?? false,
],
),
sql`\n,`,
['uuid', 'text', 'text', 'jsonb', 'bool'],
)}
`);
}