2
0

JellyfinDb.cs 7.5 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182183184185186187188189190191192193194195196197198199200201202203204205206207208209210211212213214215216217218219220221222223224225
  1. #nullable disable
  2. #pragma warning disable CS1591
  3. using System;
  4. using System.Linq;
  5. using Jellyfin.Data.Entities;
  6. using Jellyfin.Data.Interfaces;
  7. using Microsoft.EntityFrameworkCore;
  8. namespace Jellyfin.Server.Implementations
  9. {
  10. /// <inheritdoc/>
  11. public class JellyfinDb : DbContext
  12. {
  13. /// <summary>
  14. /// Initializes a new instance of the <see cref="JellyfinDb"/> class.
  15. /// </summary>
  16. /// <param name="options">The database context options.</param>
  17. public JellyfinDb(DbContextOptions<JellyfinDb> options) : base(options)
  18. {
  19. }
  20. /// <summary>
  21. /// Gets or sets the default connection string.
  22. /// </summary>
  23. public static string ConnectionString { get; set; } = @"Data Source=jellyfin.db";
  24. public virtual DbSet<AccessSchedule> AccessSchedules { get; set; }
  25. public virtual DbSet<ActivityLog> ActivityLogs { get; set; }
  26. public virtual DbSet<DisplayPreferences> DisplayPreferences { get; set; }
  27. public virtual DbSet<ImageInfo> ImageInfos { get; set; }
  28. public virtual DbSet<ItemDisplayPreferences> ItemDisplayPreferences { get; set; }
  29. public virtual DbSet<CustomItemDisplayPreferences> CustomItemDisplayPreferences { get; set; }
  30. public virtual DbSet<Permission> Permissions { get; set; }
  31. public virtual DbSet<Preference> Preferences { get; set; }
  32. public virtual DbSet<User> Users { get; set; }
  33. /*public virtual DbSet<Artwork> Artwork { get; set; }
  34. public virtual DbSet<Book> Books { get; set; }
  35. public virtual DbSet<BookMetadata> BookMetadata { get; set; }
  36. public virtual DbSet<Chapter> Chapters { get; set; }
  37. public virtual DbSet<Collection> Collections { get; set; }
  38. public virtual DbSet<CollectionItem> CollectionItems { get; set; }
  39. public virtual DbSet<Company> Companies { get; set; }
  40. public virtual DbSet<CompanyMetadata> CompanyMetadata { get; set; }
  41. public virtual DbSet<CustomItem> CustomItems { get; set; }
  42. public virtual DbSet<CustomItemMetadata> CustomItemMetadata { get; set; }
  43. public virtual DbSet<Episode> Episodes { get; set; }
  44. public virtual DbSet<EpisodeMetadata> EpisodeMetadata { get; set; }
  45. public virtual DbSet<Genre> Genres { get; set; }
  46. public virtual DbSet<Group> Groups { get; set; }
  47. public virtual DbSet<Library> Libraries { get; set; }
  48. public virtual DbSet<LibraryItem> LibraryItems { get; set; }
  49. public virtual DbSet<LibraryRoot> LibraryRoot { get; set; }
  50. public virtual DbSet<MediaFile> MediaFiles { get; set; }
  51. public virtual DbSet<MediaFileStream> MediaFileStream { get; set; }
  52. public virtual DbSet<Metadata> Metadata { get; set; }
  53. public virtual DbSet<MetadataProvider> MetadataProviders { get; set; }
  54. public virtual DbSet<MetadataProviderId> MetadataProviderIds { get; set; }
  55. public virtual DbSet<Movie> Movies { get; set; }
  56. public virtual DbSet<MovieMetadata> MovieMetadata { get; set; }
  57. public virtual DbSet<MusicAlbum> MusicAlbums { get; set; }
  58. public virtual DbSet<MusicAlbumMetadata> MusicAlbumMetadata { get; set; }
  59. public virtual DbSet<Person> People { get; set; }
  60. public virtual DbSet<PersonRole> PersonRoles { get; set; }
  61. public virtual DbSet<Photo> Photo { get; set; }
  62. public virtual DbSet<PhotoMetadata> PhotoMetadata { get; set; }
  63. public virtual DbSet<ProviderMapping> ProviderMappings { get; set; }
  64. public virtual DbSet<Rating> Ratings { get; set; }
  65. /// <summary>
  66. /// Repository for global::Jellyfin.Data.Entities.RatingSource - This is the entity to
  67. /// store review ratings, not age ratings.
  68. /// </summary>
  69. public virtual DbSet<RatingSource> RatingSources { get; set; }
  70. public virtual DbSet<Release> Releases { get; set; }
  71. public virtual DbSet<Season> Seasons { get; set; }
  72. public virtual DbSet<SeasonMetadata> SeasonMetadata { get; set; }
  73. public virtual DbSet<Series> Series { get; set; }
  74. public virtual DbSet<SeriesMetadata> SeriesMetadata { get; set; }
  75. public virtual DbSet<Track> Tracks { get; set; }
  76. public virtual DbSet<TrackMetadata> TrackMetadata { get; set; }*/
  77. /// <inheritdoc/>
  78. public override int SaveChanges()
  79. {
  80. foreach (var saveEntity in ChangeTracker.Entries()
  81. .Where(e => e.State == EntityState.Modified)
  82. .Select(entry => entry.Entity)
  83. .OfType<IHasConcurrencyToken>())
  84. {
  85. saveEntity.OnSavingChanges();
  86. }
  87. return base.SaveChanges();
  88. }
  89. /// <inheritdoc />
  90. protected override void OnModelCreating(ModelBuilder modelBuilder)
  91. {
  92. modelBuilder.SetDefaultDateTimeKind(DateTimeKind.Utc);
  93. base.OnModelCreating(modelBuilder);
  94. modelBuilder.HasDefaultSchema("jellyfin");
  95. // Collations
  96. modelBuilder.Entity<User>()
  97. .Property(user => user.Username)
  98. .UseCollation("NOCASE");
  99. // Delete behavior
  100. modelBuilder.Entity<User>()
  101. .HasOne(u => u.ProfileImage)
  102. .WithOne()
  103. .OnDelete(DeleteBehavior.Cascade);
  104. modelBuilder.Entity<User>()
  105. .HasMany(u => u.Permissions)
  106. .WithOne()
  107. .HasForeignKey(p => p.UserId)
  108. .OnDelete(DeleteBehavior.Cascade);
  109. modelBuilder.Entity<User>()
  110. .HasMany(u => u.Preferences)
  111. .WithOne()
  112. .HasForeignKey(p => p.UserId)
  113. .OnDelete(DeleteBehavior.Cascade);
  114. modelBuilder.Entity<User>()
  115. .HasMany(u => u.AccessSchedules)
  116. .WithOne()
  117. .OnDelete(DeleteBehavior.Cascade);
  118. modelBuilder.Entity<User>()
  119. .HasMany(u => u.DisplayPreferences)
  120. .WithOne()
  121. .OnDelete(DeleteBehavior.Cascade);
  122. modelBuilder.Entity<User>()
  123. .HasMany(u => u.ItemDisplayPreferences)
  124. .WithOne()
  125. .OnDelete(DeleteBehavior.Cascade);
  126. modelBuilder.Entity<DisplayPreferences>()
  127. .HasMany(d => d.HomeSections)
  128. .WithOne()
  129. .OnDelete(DeleteBehavior.Cascade);
  130. // Indexes
  131. modelBuilder.Entity<User>()
  132. .HasIndex(entity => entity.Username)
  133. .IsUnique();
  134. modelBuilder.Entity<DisplayPreferences>()
  135. .HasIndex(entity => new { entity.UserId, entity.ItemId, entity.Client })
  136. .IsUnique();
  137. modelBuilder.Entity<CustomItemDisplayPreferences>()
  138. .HasIndex(entity => new { entity.UserId, entity.ItemId, entity.Client, entity.Key })
  139. .IsUnique();
  140. // Used to get a user's permissions or a specific permission for a user.
  141. // Also prevents multiple values being created for a user.
  142. // Filtered over non-null user ids for when other entities (groups, API keys) get permissions
  143. modelBuilder.Entity<Permission>()
  144. .HasIndex(p => new { p.UserId, p.Kind })
  145. .HasFilter("[UserId] IS NOT NULL")
  146. .IsUnique();
  147. modelBuilder.Entity<Preference>()
  148. .HasIndex(p => new { p.UserId, p.Kind })
  149. .HasFilter("[UserId] IS NOT NULL")
  150. .IsUnique();
  151. }
  152. }
  153. }