From f1c494ef973f668bae6e9260a537e9baeb448f5d Mon Sep 17 00:00:00 2001
From: shenlong <139912620+shenlong-tanwen@users.noreply.github.com>
Date: Thu, 7 Aug 2025 03:27:33 +0530
Subject: [PATCH] fix: use create if not exists clause for indexes (#20728)

Co-authored-by: shenlong-tanwen <139912620+shalong-tanwen@users.noreply.github.com>
---
 .../drift_schemas/main/drift_schema_v7.json   | Bin 33538 -> 33821 bytes
 .../infrastructure/entities/exif.entity.dart  |   2 +-
 .../entities/exif.entity.drift.dart           | Bin 64600 -> 64614 bytes
 .../entities/local_asset.entity.dart          |   2 +-
 .../entities/local_asset.entity.drift.dart    | Bin 33143 -> 33157 bytes
 .../entities/remote_asset.entity.dart         |   6 ++++--
 .../entities/remote_asset.entity.drift.dart   | Bin 57561 -> 57589 bytes
 .../repositories/db.repository.dart           |   3 +++
 .../repositories/db.repository.steps.dart     | Bin 92113 -> 92169 bytes
 .../test/drift/main/generated/schema_v7.dart  | Bin 208747 -> 208803 bytes
 10 files changed, 9 insertions(+), 4 deletions(-)

diff --git a/mobile/drift_schemas/main/drift_schema_v7.json b/mobile/drift_schemas/main/drift_schema_v7.json
index 77f57c34d9d518d2bd9232ad6672e12a23ecd71c..bcd502bdc0d0276d62e84e69bc1d5fc36fd1c043 100644
GIT binary patch
delta 336
zcmZo_W18E+w86!2@&scJKTkgw*9ZkqHw8cc5Czu=&)|??h0K(S_?-OY#GLrV;^Nej
z_~eY#<m}?oTm^qW1!VEmypqh4N(Bv=yr$CRGfmQy<&3!|mm4O4j2FRX{NxRW^2|W9
zCV#9Fn|#qom=UgRv#8NRCXhY@Z2CaXDoV}GFG<C87sxCwOm}R4X>#8;M9DeG)iK0X
w0hggUi6!wldFdeULCsIC$V`iec@HR^SyGykssr?VUOJcw@hNL;ZEb8V006Lc0ssI2

delta 146
zcmbQ+!PL~ow86!YC9gCmXY$`>X)dMYjMU`p;?i8D$y*Jx;Nl8O`Q>@3Me&&_N;(K7
zv9+~2)k;7yD~rhojQuzNF$!dYYe6z<^8wSBzHkX?rJTf)%#zZSRG?Wo`FZIOHqfxx
FS^y2EI6VLW

diff --git a/mobile/lib/infrastructure/entities/exif.entity.dart b/mobile/lib/infrastructure/entities/exif.entity.dart
index 87c32461d..9c7f9e997 100644
--- a/mobile/lib/infrastructure/entities/exif.entity.dart
+++ b/mobile/lib/infrastructure/entities/exif.entity.dart
@@ -95,7 +95,7 @@ class ExifInfo {
   );
 }
 
-@TableIndex(name: 'idx_lat_lng', columns: {#latitude, #longitude})
+@TableIndex.sql('CREATE INDEX IF NOT EXISTS idx_lat_lng ON remote_exif_entity (latitude, longitude)')
 class RemoteExifEntity extends Table with DriftDefaultsMixin {
   const RemoteExifEntity();
 
diff --git a/mobile/lib/infrastructure/entities/exif.entity.drift.dart b/mobile/lib/infrastructure/entities/exif.entity.drift.dart
index c31050c321dd162a52aec8a90d892f009ff5805f..8695e2004be1dd8e760f2cc9a8a85629afe41ab2 100644
GIT binary patch
delta 28
kcmccdgZbGH<_%|)cs<<|{QN@{Tq8V#LxMM-N$Qyi0K9<=M*si-

delta 14
WcmaF%gZah}<_%|)Hs4O_o(TX$m<Xr<

diff --git a/mobile/lib/infrastructure/entities/local_asset.entity.dart b/mobile/lib/infrastructure/entities/local_asset.entity.dart
index e5519cfac..3130e41db 100644
--- a/mobile/lib/infrastructure/entities/local_asset.entity.dart
+++ b/mobile/lib/infrastructure/entities/local_asset.entity.dart
@@ -4,7 +4,7 @@ import 'package:immich_mobile/infrastructure/entities/local_asset.entity.drift.d
 import 'package:immich_mobile/infrastructure/utils/asset.mixin.dart';
 import 'package:immich_mobile/infrastructure/utils/drift_default.mixin.dart';
 
-@TableIndex(name: 'idx_local_asset_checksum', columns: {#checksum})
+@TableIndex.sql('CREATE INDEX IF NOT EXISTS idx_local_asset_checksum ON local_asset_entity (checksum)')
 class LocalAssetEntity extends Table with DriftDefaultsMixin, AssetEntityMixin {
   const LocalAssetEntity();
 
diff --git a/mobile/lib/infrastructure/entities/local_asset.entity.drift.dart b/mobile/lib/infrastructure/entities/local_asset.entity.drift.dart
index 329401d5db45639454f1e17d4dcb33407db48cfb..d0fe742463ad87c386954620e481fe51e29133d7 100644
GIT binary patch
delta 33
pcmey~#MIi%wBfcMpQoFGpMQvgYlLTTNU*}>4SEurKkKyw0RYhf3_t(?

delta 18
ZcmZo|X8PX5wBfei<PCZfn;G?6f&fiQ2Y~<p

diff --git a/mobile/lib/infrastructure/entities/remote_asset.entity.dart b/mobile/lib/infrastructure/entities/remote_asset.entity.dart
index ecc0aa3d7..442697441 100644
--- a/mobile/lib/infrastructure/entities/remote_asset.entity.dart
+++ b/mobile/lib/infrastructure/entities/remote_asset.entity.dart
@@ -5,7 +5,9 @@ import 'package:immich_mobile/infrastructure/entities/user.entity.dart';
 import 'package:immich_mobile/infrastructure/utils/asset.mixin.dart';
 import 'package:immich_mobile/infrastructure/utils/drift_default.mixin.dart';
 
-@TableIndex(name: 'idx_remote_asset_owner_checksum', columns: {#ownerId, #checksum})
+@TableIndex.sql(
+  'CREATE INDEX IF NOT EXISTS idx_remote_asset_owner_checksum ON remote_asset_entity (owner_id, checksum)',
+)
 @TableIndex.sql('''
 CREATE UNIQUE INDEX IF NOT EXISTS UQ_remote_assets_owner_checksum
 ON remote_asset_entity (owner_id, checksum)
@@ -16,7 +18,7 @@ CREATE UNIQUE INDEX IF NOT EXISTS UQ_remote_assets_owner_library_checksum
 ON remote_asset_entity (owner_id, library_id, checksum)
 WHERE (library_id IS NOT NULL);
 ''')
-@TableIndex(name: 'idx_remote_asset_checksum', columns: {#checksum})
+@TableIndex.sql('CREATE INDEX IF NOT EXISTS idx_remote_asset_checksum ON remote_asset_entity (checksum)')
 class RemoteAssetEntity extends Table with DriftDefaultsMixin, AssetEntityMixin {
   const RemoteAssetEntity();
 
diff --git a/mobile/lib/infrastructure/entities/remote_asset.entity.drift.dart b/mobile/lib/infrastructure/entities/remote_asset.entity.drift.dart
index 9681d1e75d8179a05e5bb21ce8071a39cf9782f4..eab7f95f642917deb80b6b5d42a445c58ee9619f 100644
GIT binary patch
delta 42
vcmcb4kooID<_(7<CNICwH+f=&{N!8rbT;!vcC~{Aavn$m1tce*dcY3=<#HBP

delta 18
acmex*koo38<_(7<HeZam+CF*914jU74+_En

diff --git a/mobile/lib/infrastructure/repositories/db.repository.dart b/mobile/lib/infrastructure/repositories/db.repository.dart
index 17cd590d7..c829b7c58 100644
--- a/mobile/lib/infrastructure/repositories/db.repository.dart
+++ b/mobile/lib/infrastructure/repositories/db.repository.dart
@@ -106,10 +106,13 @@ class Drift extends $Drift implements IDatabaseRepository {
           from5To6: (m, v6) async {
             // Drops the (checksum, ownerId) and adds it back as (ownerId, checksum)
             await customStatement('DROP INDEX IF EXISTS UQ_remote_asset_owner_checksum');
+            await m.drop(v6.idxRemoteAssetOwnerChecksum);
             await m.create(v6.idxRemoteAssetOwnerChecksum);
             // Adds libraryId to remote_asset_entity
             await m.addColumn(v6.remoteAssetEntity, v6.remoteAssetEntity.libraryId);
+            await m.drop(v6.uQRemoteAssetsOwnerChecksum);
             await m.create(v6.uQRemoteAssetsOwnerChecksum);
+            await m.drop(v6.uQRemoteAssetsOwnerLibraryChecksum);
             await m.create(v6.uQRemoteAssetsOwnerLibraryChecksum);
           },
           from6To7: (m, v7) async {
diff --git a/mobile/lib/infrastructure/repositories/db.repository.steps.dart b/mobile/lib/infrastructure/repositories/db.repository.steps.dart
index 9d6b02ab3262f8dbc83111a8f93628f317d1b072..a5e8c010c228a05c39b207e9663e29b8599d6dda 100644
GIT binary patch
delta 102
zcmcb3p0)D=Yr_`C8V_DiHw8cc5Czu=&)|^Y$$5)|r~i{-Ohgsl9w*CqiV0P0v;Og|
Xf|L8cicUWm%V>@&xBYu8<1J1A7E~iJ

delta 40
tcmeCYz<TjKYr_`C8jr~jmauH!Aj7C5I=Szw==9gIjOJh=lQ_n!oB(x>5n=!U

diff --git a/mobile/test/drift/main/generated/schema_v7.dart b/mobile/test/drift/main/generated/schema_v7.dart
index c91e1ac53adaccd02bdf5ff2da3e65f058de3630..276a0cdc74f8ef8c0cf42ff11bb235300cd03cee 100644
GIT binary patch
delta 116
zcmaETk7x0Ho`x327N#xChg5hy-4y)%Llj&iJcC1mryo>d-pq$0q%hq<m05mzjvBMh
k_Wi2N)lBHpJQ~cB)63MECAa5jFncqj8n}I%HuF|y0AJ4{YXATM

delta 38
wcmV+>0NMYe-wf;C41k0IgaWh!!X%f_Bm=UykR=1g0=Hx+1APOx?<)he14F70Q~&?~