SELECT * FROM X ONDE id IN (…) com Dapper ORM

Qual é a melhor maneira de escrever uma consulta com a cláusula IN usando o Dapper ORM quando a lista de valores da cláusula IN vem da lógica de negócios? Por exemplo, digamos que eu tenho uma consulta:

SELECT * 
  FROM SomeTable 
 WHERE id IN (commaSeparatedListOfIDs)

O commaSeparatedListOfIDsestá sendo transmitido da lógica de negócios e pode ser de qualquer tipo IEnumerable(of Integer). Como eu construiria uma consulta neste caso? Preciso fazer o que venho fazendo até agora, que é basicamente concatenação de strings ou existe algum tipo de técnica avançada de mapeamento de parâmetros que eu não conheço?

Dapper suporta isso diretamente. Por exemplo...

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

Diretamente da página inicial do projeto GitHub :

O Dapper permite que você passe IEnumerable e irá parametrizar automaticamente sua consulta.

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 });

Será traduzido para:

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

Se sua INcláusula for muito grande para o MSSQL manipular, você poderá usar um TableValueParameter com Dapper com bastante facilidade.

1. Crie seu tipo de TVP no MSSQL:

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

2. Crie um DataTablecom as mesmas colunas que o TVP e preencha-o com valores

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

3. Modifique sua consulta Dapper para fazer um INNER JOINna tabela TVP:

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

4. Passe o DataTable na sua chamada de consulta do Dapper

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

Isso também funciona de maneira fantástica quando você deseja fazer uma atualização em massa de várias colunas - basta criar um TVP e fazer uma UPDATEjunção interna ao TVP.

Esta é possivelmente a maneira mais rápida de consultar um grande número de linhas com o Dapper usando uma lista de IDs. Eu prometo a você que isso é mais rápido do que quase qualquer outra maneira em que você possa pensar (com a possível exceção de usar um TVP como dado em outra resposta, e que eu não testei, mas suspeito que possa ser mais lento porque você ainda precisa preencher TVP). É planetas mais rápido que o Dapper usando INsintaxe e universos mais rápido que o Entity Framework linha por linha. E é até continentes mais rápido do que passar em uma lista de VALUESou UNION ALL SELECTitens. Ele pode ser facilmente estendido para usar uma chave de várias colunas, basta adicionar as colunas extras às DataTable, tabela temporária e condições de junção.

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;
   }
}

Esteja ciente de que você precisa aprender um pouco sobre as inserções em massa. Existem opções sobre acionar acionadores (o padrão é não), respeitar restrições, bloquear a tabela, permitir inserções simultâneas e assim por diante.

Além disso, certifique-se de não colocar parênteses em torno da string de consulta da seguinte maneira:

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

Eu tive essa causa um erro de sintaxe SQL usando o Dapper 1.50.2, corrigido pela remoção de parênteses

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

Não é necessário adicionar ()a cláusula WHERE como fazemos em um SQL regular. Porque Dapper faz isso automaticamente para nós. Aqui está o syntax: -

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

var conditions = new { listOfIntegers };

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

Exemplo para postgres:

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

No meu caso, eu usei isso:

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

minha variável "ids" na segunda linha é um IEnumerable de strings, também podem ser números inteiros, eu acho.

Na minha experiência, a maneira mais amigável de lidar com isso é ter uma função que converta uma string em uma tabela de valores.

Existem muitas funções divisoras disponíveis na web; você encontrará facilmente uma para qualquer que seja o seu sabor de SQL.

Você pode fazer ...

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

Ou

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

(Ou similar)