gitea-mirror/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich.git synced 2026-01-19 16:20:38 -08:00
Code Issues Packages Projects Releases Wiki Activity

alias tables

Browse Source
This commit is contained in:
mertalev
2026-01-18 04:05:27 -05:00
committed by bwees
parent 6b24349f2d
commit 8549e88ae5
3 changed files with 12 additions and 12 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
server/src/schema/functions.ts
View File

@@ -264,8 +264,8 @@ export const asset_edit_insert = registerFunction({
BEGIN
UPDATE asset
SET "isEdited" = true
FROM new
WHERE asset.id = new."assetId" AND NOT asset."isEdited";
FROM inserted_edit
WHERE asset.id = inserted_edit."assetId" AND NOT asset."isEdited";
RETURN NULL;
END
`,
@@ -279,8 +279,8 @@ export const asset_edit_delete = registerFunction({
BEGIN
UPDATE asset
SET "isEdited" = false
FROM old
WHERE asset.id = old."assetId" AND asset."isEdited"
FROM deleted_edit
WHERE asset.id = deleted_edit."assetId" AND asset."isEdited"
AND NOT EXISTS (SELECT FROM asset_edit edit WHERE edit."assetId" = asset.id);
RETURN NULL;
END

12
server/src/schema/migrations/1768626427850-SwitchToIsEdited.ts
View File

@@ -8,8 +8,8 @@ export async function up(db: Kysely<any>): Promise<void> {
BEGIN
UPDATE asset
SET "isEdited" = true
FROM new
WHERE asset.id = new."assetId" AND NOT asset."isEdited";
FROM inserted_edit
WHERE asset.id = inserted_edit."assetId" AND NOT asset."isEdited";
RETURN NULL;
END
$$;`.execute(db);
@@ -20,8 +20,8 @@ export async function up(db: Kysely<any>): Promise<void> {
BEGIN
UPDATE asset
SET "isEdited" = false
FROM old
WHERE asset.id = old."assetId" AND asset."isEdited"
FROM deleted_edit
WHERE asset.id = deleted_edit."assetId" AND asset."isEdited"
AND NOT EXISTS (SELECT FROM asset_edit edit WHERE edit."assetId" = asset.id);
RETURN NULL;
END
@@ -29,13 +29,13 @@ export async function up(db: Kysely<any>): Promise<void> {
await sql`ALTER TABLE "asset" ADD "isEdited" boolean NOT NULL DEFAULT false;`.execute(db);
await sql`CREATE OR REPLACE TRIGGER "asset_edit_delete"
AFTER DELETE ON "asset_edit"
REFERENCING OLD TABLE AS "old"
REFERENCING OLD TABLE AS "deleted_edit"
FOR EACH STATEMENT
WHEN (pg_trigger_depth() = 0)
EXECUTE FUNCTION asset_edit_delete();`.execute(db);
await sql`CREATE OR REPLACE TRIGGER "asset_edit_insert"
AFTER INSERT ON "asset_edit"
REFERENCING NEW TABLE AS "new"
REFERENCING NEW TABLE AS "inserted_edit"
FOR EACH STATEMENT
EXECUTE FUNCTION asset_edit_insert();`.execute(db);
await sql`ALTER TABLE "asset" DROP COLUMN "editCount";`.execute(db);

4
server/src/schema/tables/asset-edit.table.ts
View File

@@ -12,11 +12,11 @@ import {
} from 'src/sql-tools';
@Table('asset_edit')
@AfterInsertTrigger({ scope: 'statement', function: asset_edit_insert, referencingNewTableAs: 'new' })
@AfterInsertTrigger({ scope: 'statement', function: asset_edit_insert, referencingNewTableAs: 'inserted_edit' })
@AfterDeleteTrigger({
scope: 'statement',
function: asset_edit_delete,
referencingOldTableAs: 'old',
referencingOldTableAs: 'deleted_edit',
when: 'pg_trigger_depth() = 0',
})
export class AssetEditTable<T extends AssetEditAction = AssetEditAction> {