Cutlery/immich
1
0
Fork 1
mirror of https://github.com/immich-app/immich.git synced 2025-08-11 09:16:31 -04:00
Code Issues Packages Projects Releases Wiki Activity

fix: use create if not exists clause for indexes (#20728)

Browse Source 
Co-authored-by: shenlong-tanwen <139912620+shalong-tanwen@users.noreply.github.com>
This commit is contained in:
shenlong 2025-08-07 03:27:33 +05:30 committed by GitHub
parent 9c8c52874a
commit f1c494ef97
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
10 changed files with 22 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
mobile/drift_schemas/main/drift_schema_v7.json generated
View File

File diff suppressed because one or more lines are too long

2
mobile/lib/infrastructure/entities/exif.entity.dart
View File

@ -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 { class RemoteExifEntity extends Table with DriftDefaultsMixin {
const RemoteExifEntity(); const RemoteExifEntity();

2
mobile/lib/infrastructure/entities/exif.entity.drift.dart generated
View File

@ -701,7 +701,7 @@ typedef $$RemoteExifEntityTableProcessedTableManager =
>; >;
i0.Index get idxLatLng => i0.Index( i0.Index get idxLatLng => i0.Index(
'idx_lat_lng', 'idx_lat_lng',
'CREATE INDEX idx_lat_lng ON remote_exif_entity (latitude, longitude)', 'CREATE INDEX IF NOT EXISTS idx_lat_lng ON remote_exif_entity (latitude, longitude)',
); );
class $RemoteExifEntityTable extends i2.RemoteExifEntity class $RemoteExifEntityTable extends i2.RemoteExifEntity

2
mobile/lib/infrastructure/entities/local_asset.entity.dart
View File

@ -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/asset.mixin.dart';
import 'package:immich_mobile/infrastructure/utils/drift_default.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 { class LocalAssetEntity extends Table with DriftDefaultsMixin, AssetEntityMixin {
const LocalAssetEntity(); const LocalAssetEntity();

2
mobile/lib/infrastructure/entities/local_asset.entity.drift.dart generated
View File

@ -338,7 +338,7 @@ typedef $$LocalAssetEntityTableProcessedTableManager =
>; >;
i0.Index get idxLocalAssetChecksum => i0.Index( i0.Index get idxLocalAssetChecksum => i0.Index(
'idx_local_asset_checksum', 'idx_local_asset_checksum',
'CREATE INDEX idx_local_asset_checksum ON local_asset_entity (checksum)', 'CREATE INDEX IF NOT EXISTS idx_local_asset_checksum ON local_asset_entity (checksum)',
); );
class $LocalAssetEntityTable extends i3.LocalAssetEntity class $LocalAssetEntityTable extends i3.LocalAssetEntity

6
mobile/lib/infrastructure/entities/remote_asset.entity.dart
View File

@ -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/asset.mixin.dart';
import 'package:immich_mobile/infrastructure/utils/drift_default.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(''' @TableIndex.sql('''
CREATE UNIQUE INDEX IF NOT EXISTS UQ_remote_assets_owner_checksum CREATE UNIQUE INDEX IF NOT EXISTS UQ_remote_assets_owner_checksum
ON remote_asset_entity (owner_id, 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) ON remote_asset_entity (owner_id, library_id, checksum)
WHERE (library_id IS NOT NULL); 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 { class RemoteAssetEntity extends Table with DriftDefaultsMixin, AssetEntityMixin {
const RemoteAssetEntity(); const RemoteAssetEntity();

4
mobile/lib/infrastructure/entities/remote_asset.entity.drift.dart generated
View File

@ -628,7 +628,7 @@ typedef $$RemoteAssetEntityTableProcessedTableManager =
>; >;
i0.Index get idxRemoteAssetOwnerChecksum => i0.Index( i0.Index get idxRemoteAssetOwnerChecksum => i0.Index(
'idx_remote_asset_owner_checksum', 'idx_remote_asset_owner_checksum',
'CREATE INDEX idx_remote_asset_owner_checksum ON remote_asset_entity (owner_id, checksum)', 'CREATE INDEX IF NOT EXISTS idx_remote_asset_owner_checksum ON remote_asset_entity (owner_id, checksum)',
); );
class $RemoteAssetEntityTable extends i3.RemoteAssetEntity class $RemoteAssetEntityTable extends i3.RemoteAssetEntity
@ -1641,5 +1641,5 @@ i0.Index get uQRemoteAssetsOwnerLibraryChecksum => i0.Index(
); );
i0.Index get idxRemoteAssetChecksum => i0.Index( i0.Index get idxRemoteAssetChecksum => i0.Index(
'idx_remote_asset_checksum', 'idx_remote_asset_checksum',
'CREATE INDEX idx_remote_asset_checksum ON remote_asset_entity (checksum)', 'CREATE INDEX IF NOT EXISTS idx_remote_asset_checksum ON remote_asset_entity (checksum)',
); );

3
mobile/lib/infrastructure/repositories/db.repository.dart
View File

@ -106,10 +106,13 @@ class Drift extends $Drift implements IDatabaseRepository {
from5To6: (m, v6) async { from5To6: (m, v6) async {
// Drops the (checksum, ownerId) and adds it back as (ownerId, checksum) // Drops the (checksum, ownerId) and adds it back as (ownerId, checksum)
await customStatement('DROP INDEX IF EXISTS UQ_remote_asset_owner_checksum'); await customStatement('DROP INDEX IF EXISTS UQ_remote_asset_owner_checksum');
await m.drop(v6.idxRemoteAssetOwnerChecksum);
await m.create(v6.idxRemoteAssetOwnerChecksum); await m.create(v6.idxRemoteAssetOwnerChecksum);
// Adds libraryId to remote_asset_entity // Adds libraryId to remote_asset_entity
await m.addColumn(v6.remoteAssetEntity, v6.remoteAssetEntity.libraryId); await m.addColumn(v6.remoteAssetEntity, v6.remoteAssetEntity.libraryId);
await m.drop(v6.uQRemoteAssetsOwnerChecksum);
await m.create(v6.uQRemoteAssetsOwnerChecksum); await m.create(v6.uQRemoteAssetsOwnerChecksum);
await m.drop(v6.uQRemoteAssetsOwnerLibraryChecksum);
await m.create(v6.uQRemoteAssetsOwnerLibraryChecksum); await m.create(v6.uQRemoteAssetsOwnerLibraryChecksum);
}, },
from6To7: (m, v7) async { from6To7: (m, v7) async {

8
mobile/lib/infrastructure/repositories/db.repository.steps.dart generated
View File

@ -2847,11 +2847,11 @@ final class Schema7 extends i0.VersionedSchema {
); );
final i1.Index idxLocalAssetChecksum = i1.Index( final i1.Index idxLocalAssetChecksum = i1.Index(
'idx_local_asset_checksum', 'idx_local_asset_checksum',
'CREATE INDEX idx_local_asset_checksum ON local_asset_entity (checksum)', 'CREATE INDEX IF NOT EXISTS idx_local_asset_checksum ON local_asset_entity (checksum)',
); );
final i1.Index idxRemoteAssetOwnerChecksum = i1.Index( final i1.Index idxRemoteAssetOwnerChecksum = i1.Index(
'idx_remote_asset_owner_checksum', 'idx_remote_asset_owner_checksum',
'CREATE INDEX idx_remote_asset_owner_checksum ON remote_asset_entity (owner_id, checksum)', 'CREATE INDEX IF NOT EXISTS idx_remote_asset_owner_checksum ON remote_asset_entity (owner_id, checksum)',
); );
final i1.Index uQRemoteAssetsOwnerChecksum = i1.Index( final i1.Index uQRemoteAssetsOwnerChecksum = i1.Index(
'UQ_remote_assets_owner_checksum', 'UQ_remote_assets_owner_checksum',
@ -2863,7 +2863,7 @@ final class Schema7 extends i0.VersionedSchema {
); );
final i1.Index idxRemoteAssetChecksum = i1.Index( final i1.Index idxRemoteAssetChecksum = i1.Index(
'idx_remote_asset_checksum', 'idx_remote_asset_checksum',
'CREATE INDEX idx_remote_asset_checksum ON remote_asset_entity (checksum)', 'CREATE INDEX IF NOT EXISTS idx_remote_asset_checksum ON remote_asset_entity (checksum)',
); );
late final Shape4 userMetadataEntity = Shape4( late final Shape4 userMetadataEntity = Shape4(
source: i0.VersionedTable( source: i0.VersionedTable(
@ -3045,7 +3045,7 @@ final class Schema7 extends i0.VersionedSchema {
); );
final i1.Index idxLatLng = i1.Index( final i1.Index idxLatLng = i1.Index(
'idx_lat_lng', 'idx_lat_lng',
'CREATE INDEX idx_lat_lng ON remote_exif_entity (latitude, longitude)', 'CREATE INDEX IF NOT EXISTS idx_lat_lng ON remote_exif_entity (latitude, longitude)',
); );
} }

8
mobile/test/drift/main/generated/schema_v7.dart generated
View File

@ -6383,11 +6383,11 @@ class DatabaseAtV7 extends GeneratedDatabase {
LocalAlbumAssetEntity(this); LocalAlbumAssetEntity(this);
late final Index idxLocalAssetChecksum = Index( late final Index idxLocalAssetChecksum = Index(
'idx_local_asset_checksum', 'idx_local_asset_checksum',
'CREATE INDEX idx_local_asset_checksum ON local_asset_entity (checksum)', 'CREATE INDEX IF NOT EXISTS idx_local_asset_checksum ON local_asset_entity (checksum)',
); );
late final Index idxRemoteAssetOwnerChecksum = Index( late final Index idxRemoteAssetOwnerChecksum = Index(
'idx_remote_asset_owner_checksum', 'idx_remote_asset_owner_checksum',
'CREATE INDEX idx_remote_asset_owner_checksum ON remote_asset_entity (owner_id, checksum)', 'CREATE INDEX IF NOT EXISTS idx_remote_asset_owner_checksum ON remote_asset_entity (owner_id, checksum)',
); );
late final Index uQRemoteAssetsOwnerChecksum = Index( late final Index uQRemoteAssetsOwnerChecksum = Index(
'UQ_remote_assets_owner_checksum', 'UQ_remote_assets_owner_checksum',
@ -6399,7 +6399,7 @@ class DatabaseAtV7 extends GeneratedDatabase {
); );
late final Index idxRemoteAssetChecksum = Index( late final Index idxRemoteAssetChecksum = Index(
'idx_remote_asset_checksum', 'idx_remote_asset_checksum',
'CREATE INDEX idx_remote_asset_checksum ON remote_asset_entity (checksum)', 'CREATE INDEX IF NOT EXISTS idx_remote_asset_checksum ON remote_asset_entity (checksum)',
); );
late final UserMetadataEntity userMetadataEntity = UserMetadataEntity(this); late final UserMetadataEntity userMetadataEntity = UserMetadataEntity(this);
late final PartnerEntity partnerEntity = PartnerEntity(this); late final PartnerEntity partnerEntity = PartnerEntity(this);
@ -6415,7 +6415,7 @@ class DatabaseAtV7 extends GeneratedDatabase {
late final AssetFaceEntity assetFaceEntity = AssetFaceEntity(this); late final AssetFaceEntity assetFaceEntity = AssetFaceEntity(this);
late final Index idxLatLng = Index( late final Index idxLatLng = Index(
'idx_lat_lng', 'idx_lat_lng',
'CREATE INDEX idx_lat_lng ON remote_exif_entity (latitude, longitude)', 'CREATE INDEX IF NOT EXISTS idx_lat_lng ON remote_exif_entity (latitude, longitude)',
); );
@override @override
Iterable<TableInfo<Table, Object?>> get allTables => Iterable<TableInfo<Table, Object?>> get allTables =>