csharp-jellyfin-sql-query-fix

This mapping has 1 multi-map group: several pairings are equally correct there. The code view shows one arbitrary valid pairing, not the only one.

A painting is a person's account of this edit as text, recorded independently of the node mapping - a rendering often has several equally defensible answers where the mapping has one. Deletions and insertions carry no position on the opposite side in a painting, so that panel draws no caret for them.

Before…lines 1–55 unchanged (55 lines)
      var dbContext = await _provider.CreateDbContextAsync(cancellationToken).ConfigureAwait(false);
      await using (dbContext.ConfigureAwait(false))
      {
          using var connection = new SqliteConnection($"Filename={libraryDbPath};Mode=ReadOnly");
          var queryResult = connection.Query(
61"""
  SELECT guid FROM TypedBaseItems
63
  WHERE IsFolder = true
65""");
          foreach (var entity in queryResult)
          {
              var id = entity.GetGuid(0);
              await dbContext.BaseItems.Where(e => e.Id == id).ExecuteUpdateAsync(e => e.SetProperty(f => f.IsFolder, true), cancellationToken).ConfigureAwait(false);
          }
      }
  }
73}
74

After…lines 1–55 unchanged (55 lines)
      var dbContext = await _provider.CreateDbContextAsync(cancellationToken).ConfigureAwait(false);
      await using (dbContext.ConfigureAwait(false))
      {
          using var connection = new SqliteConnection($"Filename={libraryDbPath};Mode=ReadOnly");
          var queryResult = connection.Query(
              """
                  SELECT guid FROM TypedBaseItems
                  WHERE IsFolder = true
              """)
                      .Select(entity => entity.GetGuid(0))
                      .ToList();
          _logger.LogInformation("Migrating the IsFolder flag for {Count} items.", queryResult.Count);
          foreach (var id in queryResult)
          {
              await dbContext.BaseItems.Where(e => e.Id == id).ExecuteUpdateAsync(e => e.SetProperty(f => f.IsFolder, true), cancellationToken).ConfigureAwait(false);
          }
      }
  }
74}
75

Before…lines 1–55 unchanged (55 lines)
      var dbContext = await _provider.CreateDbContextAsync(cancellationToken).ConfigureAwait(false);
      await using (dbContext.ConfigureAwait(false))
      {
          using var connection = new SqliteConnection($"Filename={libraryDbPath};Mode=ReadOnly");
          var queryResult = connection.Query(
61"""
  SELECT guid FROM TypedBaseItems
63
  WHERE IsFolder = true
65""");
          foreach (var entity in queryResult)
          {
              var id = entity.GetGuid(0);
              await dbContext.BaseItems.Where(e => e.Id == id).ExecuteUpdateAsync(e => e.SetProperty(f => f.IsFolder, true), cancellationToken).ConfigureAwait(false);
          }
      }
  }
73}
74

After…lines 1–55 unchanged (55 lines)
      var dbContext = await _provider.CreateDbContextAsync(cancellationToken).ConfigureAwait(false);
      await using (dbContext.ConfigureAwait(false))
      {
          using var connection = new SqliteConnection($"Filename={libraryDbPath};Mode=ReadOnly");
          var queryResult = connection.Query(
              """
                  SELECT guid FROM TypedBaseItems
                  WHERE IsFolder = true
              """)
                      .Select(entity => entity.GetGuid(0))
                      .ToList();
          _logger.LogInformation("Migrating the IsFolder flag for {Count} items.", queryResult.Count);
          foreach (var id in queryResult)
          {
              await dbContext.BaseItems.Where(e => e.Id == id).ExecuteUpdateAsync(e => e.SetProperty(f => f.IsFolder, true), cancellationToken).ConfigureAwait(false);
          }
      }
  }
74}
75

Before…lines 1–55 unchanged (55 lines)
      var dbContext = await _provider.CreateDbContextAsync(cancellationToken).ConfigureAwait(false);
      await using (dbContext.ConfigureAwait(false))
      {
          using var connection = new SqliteConnection($"Filename={libraryDbPath};Mode=ReadOnly");
          var queryResult = connection.Query(
61"""
  SELECT guid FROM TypedBaseItems
63
  WHERE IsFolder = true
65""");
          foreach (var entity in queryResult)
          {
              var id = entity.GetGuid(0);
              await dbContext.BaseItems.Where(e => e.Id == id).ExecuteUpdateAsync(e => e.SetProperty(f => f.IsFolder, true), cancellationToken).ConfigureAwait(false);
          }
      }
  }
73}
74

After…lines 1–55 unchanged (55 lines)
      var dbContext = await _provider.CreateDbContextAsync(cancellationToken).ConfigureAwait(false);
      await using (dbContext.ConfigureAwait(false))
      {
          using var connection = new SqliteConnection($"Filename={libraryDbPath};Mode=ReadOnly");
          var queryResult = connection.Query(
              """
                  SELECT guid FROM TypedBaseItems
                  WHERE IsFolder = true
              """)
                      .Select(entity => entity.GetGuid(0))
                      .ToList();
          _logger.LogInformation("Migrating the IsFolder flag for {Count} items.", queryResult.Count);
          foreach (var id in queryResult)
          {
              await dbContext.BaseItems.Where(e => e.Id == id).ExecuteUpdateAsync(e => e.SetProperty(f => f.IsFolder, true), cancellationToken).ConfigureAwait(false);
          }
      }
  }
74}
75

Before

compilation_unit

preproc_pragma

#pragma "#pragma"

warning "warning"

disable "disable"

identifier "RS0030"

comment "// Do not use banned APIs"

using_directive

using "using"

qualified_name

identifier "System"

. "."

identifier "IO"

; ";"

using_directive

using "using"

qualified_name

identifier "System"

. "."

identifier "Linq"

; ";"

using_directive

using "using"

qualified_name

identifier "System"

. "."

identifier "Threading"

; ";"

using_directive

using "using"

qualified_name

identifier "System"

. "."

identifier "Threading"

. "."

identifier "Tasks"

; ";"

using_directive

using "using"

qualified_name

identifier "Emby"

. "."

identifier "Server"

. "."

identifier "Implementations"

. "."

identifier "Data"

; ";"

using_directive

using "using"

qualified_name

identifier "Jellyfin"

. "."

identifier "Database"

. "."

identifier "Implementations"

; ";"

using_directive

using "using"

qualified_name

identifier "Jellyfin"

. "."

identifier "Server"

. "."

identifier "ServerSetupApp"

; ";"

using_directive

using "using"

qualified_name

identifier "MediaBrowser"

. "."

identifier "Controller"

; ";"

using_directive

using "using"

qualified_name

identifier "Microsoft"

. "."

identifier "Data"

. "."

identifier "Sqlite"

; ";"

using_directive

using "using"

qualified_name

identifier "Microsoft"

. "."

identifier "EntityFrameworkCore"

; ";"

using_directive

using "using"

qualified_name

identifier "Microsoft"

. "."

identifier "Extensions"

. "."

identifier "Logging"

; ";"

file_scoped_namespace_declaration

namespace "namespace"

qualified_name

identifier "Jellyfin"

. "."

identifier "Server"

. "."

identifier "Migrations"

. "."

identifier "Routines"

; ";"

class_declaration

attribute_list (+22 nodes collapsed)

attribute_list

[ "["

attribute

identifier "JellyfinMigrationBackup"

attribute_argument_list

( "("

attribute_argument

identifier "JellyfinDb"

= "="

boolean_literal

true "true"

) ")"

] "]"

modifier

internal "internal"

class "class"

identifier "ReseedFolderFlag"

base_list

: ":"

identifier "IAsyncMigrationRoutine"

declaration_list

{ "{"

field_declaration

modifier

private "private"

modifier

const "const"

variable_declaration

predefined_type "string"

variable_declarator

identifier "DbFilename"

= "="

string_literal

" "\""

string_literal_content "library.db.old"

" "\""

; ";"

field_declaration

modifier

private "private"

modifier

readonly "readonly"

variable_declaration

identifier "IStartupLogger"

variable_declarator

identifier "_logger"

; ";"

field_declaration

modifier

private "private"

modifier

readonly "readonly"

variable_declaration

identifier "IServerApplicationPaths"

variable_declarator

identifier "_paths"

; ";"

field_declaration

modifier

private "private"

modifier

readonly "readonly"

variable_declaration

generic_name

identifier "IDbContextFactory"

type_argument_list

< "<"

identifier "JellyfinDbContext"

> ">"

variable_declarator

identifier "_provider"

; ";"

constructor_declaration (+49 nodes collapsed)

property_declaration

modifier

internal "internal"

modifier

static "static"

predefined_type "bool"

identifier "RerunGuardFlag"

accessor_list

{ "{"

accessor_declaration

get "get"

; ";"

accessor_declaration

set "set"

; ";"

} "}"

= "="

boolean_literal

false "false"

; ";"

method_declaration

modifier

public "public"

modifier

async "async"

identifier "Task"

identifier "PerformAsync"

parameter_list

( "("

parameter

identifier "CancellationToken"

identifier "cancellationToken"

) ")"

block

{ "{"

if_statement (+26 nodes collapsed)

expression_statement

invocation_expression

member_access_expression

identifier "_logger"

. "."

identifier "LogInformation"

argument_list

( "("

argument

string_literal

" "\""

string_literal_content "Migrating the IsFolder flag from library.db.old may take a w"...

" "\""

) ")"

; ";"

local_declaration_statement

variable_declaration

implicit_type

var "var"

variable_declarator

identifier "dataPath"

= "="

member_access_expression

identifier "_paths"

. "."

identifier "DataPath"

; ";"

local_declaration_statement (+21 nodes collapsed)

if_statement (+40 nodes collapsed)

local_declaration_statement (+30 nodes collapsed)

using_statement

await "await"

using "using"

( "("

invocation_expression

member_access_expression

identifier "dbContext"

. "."

identifier "ConfigureAwait"

argument_list

( "("

argument

boolean_literal

false "false"

) ")"

block

{ "{"

local_declaration_statement (+26 nodes collapsed)

local_declaration_statement

variable_declaration

implicit_type

var "var"

variable_declarator

identifier "queryResult"

= "="

invocation_expression any 1:3

member_access_expression

identifier "connection"

. "."

identifier "Query"

argument_list

( "("

argument

raw_string_literal

raw_string_start "\"\"\""

raw_string_content "\n SELECT guid FROM TypedBaseItems\n\n WHERE IsFolder = t"...

raw_string_end "\"\"\""

) ")"

; ";"

foreach_statement

foreach "foreach"

( "("

implicit_type

var "var"

identifier "entity"

in "in"

identifier "queryResult"

) ")"

block

{ "{"

local_declaration_statement

variable_declaration

implicit_type

var "var"

variable_declarator

identifier "id"

= "="

invocation_expression

member_access_expression

identifier "entity"

. "."

identifier "GetGuid"

argument_list

( "("

argument

integer_literal "0"

) ")"

; ";"

expression_statement (+70 nodes collapsed)

} "}"

After

compilation_unit

preproc_pragma

#pragma "#pragma"

warning "warning"

disable "disable"

identifier "RS0030"

comment "// Do not use banned APIs"

using_directive

using "using"

qualified_name

identifier "System"

. "."

identifier "IO"

; ";"

using_directive

using "using"

qualified_name

identifier "System"

. "."

identifier "Linq"

; ";"

using_directive

using "using"

qualified_name

identifier "System"

. "."

identifier "Threading"

; ";"

using_directive

using "using"

qualified_name

identifier "System"

. "."

identifier "Threading"

. "."

identifier "Tasks"

; ";"

using_directive

using "using"

qualified_name

identifier "Emby"

. "."

identifier "Server"

. "."

identifier "Implementations"

. "."

identifier "Data"

; ";"

using_directive

using "using"

qualified_name

identifier "Jellyfin"

. "."

identifier "Database"

. "."

identifier "Implementations"

; ";"

using_directive

using "using"

qualified_name

identifier "Jellyfin"

. "."

identifier "Server"

. "."

identifier "ServerSetupApp"

; ";"

using_directive

using "using"

qualified_name

identifier "MediaBrowser"

. "."

identifier "Controller"

; ";"

using_directive

using "using"

qualified_name

identifier "Microsoft"

. "."

identifier "Data"

. "."

identifier "Sqlite"

; ";"

using_directive

using "using"

qualified_name

identifier "Microsoft"

. "."

identifier "EntityFrameworkCore"

; ";"

using_directive

using "using"

qualified_name

identifier "Microsoft"

. "."

identifier "Extensions"

. "."

identifier "Logging"

; ";"

file_scoped_namespace_declaration

namespace "namespace"

qualified_name

identifier "Jellyfin"

. "."

identifier "Server"

. "."

identifier "Migrations"

. "."

identifier "Routines"

; ";"

class_declaration

attribute_list (+22 nodes collapsed)

attribute_list

[ "["

attribute

identifier "JellyfinMigrationBackup"

attribute_argument_list

( "("

attribute_argument

identifier "JellyfinDb"

= "="

boolean_literal

true "true"

) ")"

] "]"

modifier

internal "internal"

class "class"

identifier "ReseedFolderFlag"

base_list

: ":"

identifier "IAsyncMigrationRoutine"

declaration_list

{ "{"

field_declaration

modifier

private "private"

modifier

const "const"

variable_declaration

predefined_type "string"

variable_declarator

identifier "DbFilename"

= "="

string_literal

" "\""

string_literal_content "library.db.old"

" "\""

; ";"

field_declaration

modifier

private "private"

modifier

readonly "readonly"

variable_declaration

identifier "IStartupLogger"

variable_declarator

identifier "_logger"

; ";"

field_declaration

modifier

private "private"

modifier

readonly "readonly"

variable_declaration

identifier "IServerApplicationPaths"

variable_declarator

identifier "_paths"

; ";"

field_declaration

modifier

private "private"

modifier

readonly "readonly"

variable_declaration

generic_name

identifier "IDbContextFactory"

type_argument_list

< "<"

identifier "JellyfinDbContext"

> ">"

variable_declarator

identifier "_provider"

; ";"

constructor_declaration (+49 nodes collapsed)

property_declaration

modifier

internal "internal"

modifier

static "static"

predefined_type "bool"

identifier "RerunGuardFlag"

accessor_list

{ "{"

accessor_declaration

get "get"

; ";"

accessor_declaration

set "set"

; ";"

} "}"

= "="

boolean_literal

false "false"

; ";"

method_declaration

modifier

public "public"

modifier

async "async"

identifier "Task"

identifier "PerformAsync"

parameter_list

( "("

parameter

identifier "CancellationToken"

identifier "cancellationToken"

) ")"

block

{ "{"

if_statement (+26 nodes collapsed)

expression_statement

invocation_expression

member_access_expression

identifier "_logger"

. "."

identifier "LogInformation"

argument_list

( "("

argument

string_literal

" "\""

string_literal_content "Migrating the IsFolder flag from library.db.old may take a w"...

" "\""

) ")"

; ";"

local_declaration_statement

variable_declaration

implicit_type

var "var"

variable_declarator

identifier "dataPath"

= "="

member_access_expression

identifier "_paths"

. "."

identifier "DataPath"

; ";"

local_declaration_statement (+21 nodes collapsed)

if_statement (+40 nodes collapsed)

local_declaration_statement (+30 nodes collapsed)

using_statement

await "await"

using "using"

( "("

invocation_expression

member_access_expression

identifier "dbContext"

. "."

identifier "ConfigureAwait"

argument_list

( "("

argument

boolean_literal

false "false"

) ")"

block

{ "{"

local_declaration_statement (+26 nodes collapsed)

local_declaration_statement

variable_declaration

implicit_type

var "var"

variable_declarator

identifier "queryResult"

= "="

invocation_expression any 1:3

member_access_expression

invocation_expression any 1:3

member_access_expression

invocation_expression any 1:3

member_access_expression

identifier "connection"

. "."

identifier "Query"

argument_list

( "("

argument

raw_string_literal

raw_string_start "\"\"\""

raw_string_content "\n SELECT guid FROM TypedBaseItems\n "...

raw_string_end "\"\"\""

) ")"

. "."

identifier "Select"

argument_list

( "("

argument

lambda_expression

implicit_parameter "entity"

=> "=>"

invocation_expression

member_access_expression

identifier "entity"

. "."

identifier "GetGuid"

argument_list

( "("

argument

integer_literal "0"

) ")"

. "."

identifier "ToList"

argument_list

( "("

) ")"

; ";"

expression_statement

invocation_expression

member_access_expression

identifier "_logger"

. "."

identifier "LogInformation"

argument_list

( "("

argument

string_literal

" "\""

string_literal_content "Migrating the IsFolder flag for {Count} items."

" "\""

, ","

argument

member_access_expression

identifier "queryResult"

. "."

identifier "Count"

) ")"

; ";"

foreach_statement

foreach "foreach"

( "("

implicit_type

var "var"

identifier "id"

in "in"

identifier "queryResult"

) ")"

block

{ "{"

expression_statement (+70 nodes collapsed)

} "}"