helpy4/immich
1
0
Fork 0
mirror of https://github.com/immich-app/immich synced 2025-11-14 17:36:12 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions

readd sql

Browse source
This commit is contained in:
mertalev 2025-10-15 15:51:49 -04:00
parent d7cc9acf84
commit b656d2bfd2
No known key found for this signature in database
GPG key ID: DF6ABC77AAD98C95
1 changed files with 22 additions and 3 deletions
Download patch file Download diff file Expand all files Collapse all files

25
server/src/repositories/ocr.repository.ts
View file

@ -26,6 +26,27 @@ export class OcrRepository {
}); });
} }
@GenerateSql({
params: [
DummyValue.UUID,
[
{
assetId: DummyValue.UUID,
x1: DummyValue.NUMBER,
y1: DummyValue.NUMBER,
x2: DummyValue.NUMBER,
y2: DummyValue.NUMBER,
x3: DummyValue.NUMBER,
y3: DummyValue.NUMBER,
x4: DummyValue.NUMBER,
y4: DummyValue.NUMBER,
text: DummyValue.STRING,
boxScore: DummyValue.NUMBER,
textScore: DummyValue.NUMBER,
},
],
],
})
upsert(assetId: string, ocrDataList: Insertable<AssetOcrTable>[]) { upsert(assetId: string, ocrDataList: Insertable<AssetOcrTable>[]) {
let query = this.db.with('deleted_ocr', (db) => db.deleteFrom('asset_ocr').where('assetId', '=', assetId)); let query = this.db.with('deleted_ocr', (db) => db.deleteFrom('asset_ocr').where('assetId', '=', assetId));
if (ocrDataList.length > 0) { if (ocrDataList.length > 0) {
@ -39,9 +60,7 @@ export class OcrRepository {
.onConflict((oc) => oc.column('assetId').doUpdateSet((eb) => ({ text: eb.ref('excluded.text') }))), .onConflict((oc) => oc.column('assetId').doUpdateSet((eb) => ({ text: eb.ref('excluded.text') }))),
); );
} else { } else {
(query as any) = query.with('deleted_search', (db) => (query as any) = query.with('deleted_search', (db) => db.deleteFrom('ocr_search').where('assetId', '=', assetId));
db.deleteFrom('ocr_search').where('assetId', '=', assetId),
);
} }
return query.selectNoFrom(sql`1`.as('dummy')).execute(); return query.selectNoFrom(sql`1`.as('dummy')).execute();