SELECT * FROM X WHERE ID IN (…) mit Dapper ORM

Was ist der beste Weg, um eine Abfrage mit IN-Klausel mit Dapper ORM zu schreiben, wenn die Liste der Werte für die IN-Klausel aus der Geschäftslogik stammt? Angenommen, ich habe eine Abfrage:

SELECT * 
  FROM SomeTable 
 WHERE id IN (commaSeparatedListOfIDs)

Das commaSeparatedListOfIDswird von der Geschäftslogik übergeben und kann jede Art von sein IEnumerable(of Integer). Wie würde ich in diesem Fall eine Abfrage erstellen? Muss ich das tun, was ich bisher getan habe, was im Grunde eine Verkettung von Zeichenfolgen ist, oder gibt es eine Art fortgeschrittene Parameterzuordnungstechnik, die mir nicht bekannt ist?

Dapper unterstützt dies direkt. Beispielsweise...

string sql = "SELECT * FROM SomeTable WHERE id IN @ids"
var results = conn.Query(sql, new { ids = new[] { 1, 2, 3, 4, 5 }});

Direkt von der GitHub-Projekthomepage :

Mit Dapper können Sie IEnumerable übergeben und Ihre Abfrage automatisch parametrisieren.

connection.Query<int>(
    @"select * 
      from (select 1 as Id union all select 2 union all select 3) as X 
      where Id in @Ids", 
    new { Ids = new int[] { 1, 2, 3 });

Wird übersetzt in:

select * 
from (select 1 as Id union all select 2 union all select 3) as X 
where Id in (@Ids1, @Ids2, @Ids3)

// @Ids1 = 1 , @Ids2 = 2 , @Ids2 = 3

Wenn Ihre INKlausel für MSSQL zu groß ist, können Sie ganz einfach einen TableValueParameter mit Dapper verwenden.

1. Erstellen Sie Ihren TVP-Typ in MSSQL:

   CREATE TYPE [dbo].[MyTVP] AS TABLE([ProviderId] [int] NOT NULL)

2. Erstellen Sie eine DataTablemit denselben Spalten wie dem TVP und füllen Sie sie mit Werten

   var tvpTable = new DataTable();
   tvpTable.Columns.Add(new DataColumn("ProviderId", typeof(int)));
   // fill the data table however you wish

3. Ändern Sie Ihre Dapper-Abfrage, um eine INNER JOINin der TVP-Tabelle auszuführen:

   var query = @"SELECT * FROM Providers P
       INNER JOIN @tvp t ON p.ProviderId = t.ProviderId";

4. Übergeben Sie die DataTable in Ihrem Dapper-Abfrageaufruf

   sqlConn.Query(query, new {tvp = tvpTable.AsTableValuedParameter("dbo.MyTVP")});

Dies funktioniert auch fantastisch, wenn Sie eine Massenaktualisierung mehrerer Spalten durchführen möchten - erstellen Sie einfach einen TVP und führen Sie UPDATEeinen inneren Join mit dem TVP durch.

Hier ist möglicherweise der schnellste Weg, um eine große Anzahl von Zeilen mit Dapper mithilfe einer Liste von IDs abzufragen. Ich verspreche Ihnen, dass dies schneller ist als fast jede andere Art, die Sie sich vorstellen können (mit der möglichen Ausnahme, dass Sie einen TVP verwenden, wie in einer anderen Antwort angegeben, und den ich nicht getestet habe, aber ich vermute, dass er langsamer ist, weil Sie noch füllen müssen der TVP). Es ist Planeten schneller als Dapper mit INSyntax und Universen schneller als Entity Framework Zeile für Zeile. Und es ist sogar Kontinente schneller als das Übergeben einer Liste von VALUESoder UNION ALL SELECTGegenständen. Es kann leicht erweitert werden, um einen mehrspaltigen Schlüssel zu verwenden. Fügen Sie einfach die zusätzlichen Spalten zu den DataTableBedingungen, der temporären Tabelle und den Verknüpfungsbedingungen hinzu.

public IReadOnlyCollection<Item> GetItemsByItemIds(IEnumerable<int> items) {
   var itemList = new HashSet(items);
   if (itemList.Count == 0) { return Enumerable.Empty<Item>().ToList().AsReadOnly(); }

   var itemDataTable = new DataTable();
   itemDataTable.Columns.Add("ItemId", typeof(int));
   itemList.ForEach(itemid => itemDataTable.Rows.Add(itemid));

   using (SqlConnection conn = GetConnection()) // however you get a connection
   using (var transaction = conn.BeginTransaction()) {
      conn.Execute(
         "CREATE TABLE #Items (ItemId int NOT NULL PRIMARY KEY CLUSTERED);",
         transaction: transaction
      );

      new SqlBulkCopy(conn, SqlBulkCopyOptions.Default, transaction) {
         DestinationTableName = "#Items",
         BulkCopyTimeout = 3600 // ridiculously large
      }
         .WriteToServer(itemDataTable);
      var result = conn
         .Query<Item>(@"
            SELECT i.ItemId, i.ItemName
            FROM #Items x INNER JOIN dbo.Items i ON x.ItemId = i.ItemId
            DROP TABLE #Items;",
            transaction: transaction,
            commandTimeout: 3600
         )
         .ToList()
         .AsReadOnly();
      transaction.Rollback(); // Or commit if you like
      return result;
   }
}

Beachten Sie, dass Sie ein wenig über Bulk Inserts lernen müssen. Es gibt Optionen zum Auslösen von Triggern (die Standardeinstellung ist Nein), zum Beachten von Einschränkungen, zum Sperren der Tabelle, zum Zulassen gleichzeitiger Einfügungen usw.

Stellen Sie außerdem sicher, dass Sie Ihre Abfragezeichenfolge nicht wie folgt in Klammern setzen:

SELECT Name from [USER] WHERE [UserId] in (@ids)

Ich hatte diese Ursache einen SQL-Syntaxfehler mit Dapper 1.50.2, der durch Entfernen von Klammern behoben wurde

SELECT Name from [USER] WHERE [UserId] in @ids

Es ist nicht erforderlich , ()die WHERE-Klausel wie in einem normalen SQL hinzuzufügen . Weil Dapper das automatisch für uns erledigt. Hier ist das syntax: -

const string SQL = "SELECT IntegerColumn, StringColumn FROM SomeTable WHERE IntegerColumn IN @listOfIntegers";

var conditions = new { listOfIntegers };

var results = connection.Query(SQL, conditions);

Beispiel für Postgres:

string sql = "SELECT * FROM SomeTable WHERE id = ANY(@ids)"
var results = conn.Query(sql, new { ids = new[] { 1, 2, 3, 4, 5 }});

In meinem Fall habe ich Folgendes verwendet:

var query = "select * from table where Id IN @Ids";
var result = conn.Query<MyEntity>(query, new { Ids = ids });

Meine Variable "ids" in der zweiten Zeile ist eine IE-Zahl von Zeichenfolgen. Sie können auch Ganzzahlen sein, denke ich.

Nach meiner Erfahrung besteht die freundlichste Art, damit umzugehen, darin, eine Funktion zu haben, die eine Zeichenfolge in eine Wertetabelle konvertiert.

Es gibt viele Splitter-Funktionen im Web, Sie werden leicht eine für was auch immer finden, wenn Sie SQL-Geschmack haben.

Sie können dann tun ...

SELECT * FROM table WHERE id IN (SELECT id FROM split(@list_of_ids))

Oder

SELECT * FROM table INNER JOIN (SELECT id FROM split(@list_of_ids)) AS list ON list.id = table.id

(O.ä)