c# - framework - dapper.net core

Cómo insertar una colección IEnumerable<T> con dapper-dot-net

Question

Sí, aquí y here hay preguntas sobre cómo insertar registros con dapper-dot-net. Sin embargo, las respuestas, aunque informativas, no parecen apuntarme en la dirección correcta. Aquí está la situación: mover datos de SqlServer a MySql. Leer los registros en un IEnumerable<WTUser> es fácil, pero simplemente no IEnumerable<WTUser> algo en el inserto. Primero, el ''código de registros en movimiento'':

//  moving data
Dim session As New Session(DataProvider.MSSql, "server", _
                           "database")

Dim resources As List(Of WTUser) = session.QueryReader(Of WTUser)("select * from tbl_resource")


session = New Session(DataProvider.MySql, "server", "database", _
                      "user", "p@$$w0rd")

//    *edit* - corrected parameter notation with ''@''
Dim strInsert = "INSERT INTO tbl_resource (ResourceName, ResourceRate, ResourceTypeID, ActiveYN) " & _
                "VALUES (@ResourceName, @ResourceRate, @ResourceType, @ActiveYN)"

Dim recordCount = session.WriteData(Of WTUser)(strInsert, resources)

//  session Methods
    Public Function QueryReader(Of TEntity As {Class, New})(ByVal Command As String) _
                                                            As IEnumerable(Of TEntity)
        Dim list As IEnumerable(Of TEntity)

        Dim cnn As IDbConnection = dataAgent.NewConnection
        list = cnn.Query(Of TEntity)(Command, Nothing, Nothing, True, 0, CommandType.Text).ToList()

        Return list
    End Function

    Public Function WriteData(Of TEntity As {Class, New})(ByVal Command As String, ByVal Entities As IEnumerable(Of TEntity)) _
                                                          As Integer
        Dim cnn As IDbConnection = dataAgent.NewConnection

        //    *edit* if I do this I get the correct properties, but no data inserted
        //Return cnn.Execute(Command, New TEntity(), Nothing, 15, CommandType.Text)

        //    original Return statement
        Return cnn.Execute(Command, Entities, Nothing, 15, CommandType.Text)
    End Function

cnn.Query y cnn.Execute llaman a los métodos de extensión dapper. Ahora, la clase WTUser (nota: el nombre de la columna cambió de ''WindowsName'' en SqlServer a ''ResourceName'' en MySql, por lo tanto, las dos propiedades apuntan al mismo campo):

Public Class WTUser
    //    edited for brevity - assume the following all have public get/set methods
    Public ActiveYN As String
    Public ResourceID As Integer
    Public ResourceRate As Integer
    Public ResourceType As Integer
    Public WindowsName As String
    Public ResourceName As String

End Class

Estoy recibiendo una excepción de Dapper: "WTUser no es compatible con Dapper". Este método en DataMapper (dapper):

    private static Action<IDbCommand, object> CreateParamInfoGenerator(Type OwnerType)
    {
        string dmName = string.Format("ParamInfo{0}", Guid.NewGuid());
        Type[] objTypes = new[] { typeof(IDbCommand), typeof(object) };

        var dm = new DynamicMethod(dmName, null, objTypes, OwnerType, true); // << - here
        //    emit stuff

        //    dm is instanced, now ...
        foreach (var prop in OwnerType.GetProperties().OrderBy(p => p.Name))

En este punto OwnerType =

System.Collections.Generic.List`1 [[CRMBackEnd.WTUser, CRMBE, Version = 1.0.0.0, Culture = neutral, PublicKeyToken = null]], mscorlib, Version = 2.0.0.0, Culture = neutral, PublicKeyToken = b77a5c561934e089

Parece que OwnerType debe ser CRMBackEnd.WTUser ... no List<CRMBackEnd.WTUser> ... ??? porque lo que está sucediendo es que las propiedades de la colección se están iterando: recuento, capacidad, etc. ¿Qué me estoy perdiendo?

Actualizar

Si modifiqué session.WriteData como:

Public Function WriteData(Of TEntity As {Class, New})(ByVal Command As String, _
                                                      ByVal Entities As IEnumerable(Of TEntity)) _
                                                      As Integer
    Dim cnn As IDbConnection = dataAgent.NewConnection
    Dim records As Integer

    For Each entity As TEntity In Entities
        records += cnn.Execute(Command, entity, Nothing, 15, CommandType.Text)
    Next

    Return records
End Function

los registros se insertan muy bien ... pero no creo que esto sea necesario dado ejemplos como:

connection.Execute(@"insert MyTable(colA, colB) values (@a, @b)",
    new[] { new { a=1, b=1 }, new { a=2, b=2 }, new { a=3, b=3 } }
  ).IsEqualTo(3); // 3 rows inserted: "1,1", "2,2" and "3,3"  

... de dapper-dot-net

Answer 1

Acabo de agregar una prueba para esto:

class Student
{
    public string Name {get; set;}
    public int Age { get; set; }
}

public void TestExecuteMultipleCommandStrongType()
{
    connection.Execute("create table #t(Name nvarchar(max), Age int)");
    int tally = connection.Execute(@"insert #t (Name,Age) values(@Name, @Age)", new List<Student> 
    {
        new Student{Age = 1, Name = "sam"},
        new Student{Age = 2, Name = "bob"}
    });
    int sum = connection.Query<int>("select sum(Age) from #t drop table #t").First();
    tally.IsEqualTo(2);
    sum.IsEqualTo(3);
}

Funciona como se anuncia. Hice algunas enmiendas a la forma en que funciona el multi-exec (por lo que es un poco más rápido y soporta el objeto []).

Supongo que tenías problemas porque te faltaba una propiedad getter en todos tus campos en WTUser . Todos los parámetros deben tener propiedades de lector, no admitimos extraer esto de los campos, sería necesario un paso de análisis complejo para mantener la eficiencia.

Un punto adicional que causó un problema es pasar dapper a param con mapeo no soportado.

Por ejemplo, la siguiente clase no se admite como parámetro:

class Test
{
   public int Id { get; set; }
   public User User {get; set;}
}

cnn.Query("select * from Tests where Id = @Id", new Test{Id = 1}); // used to go boom 

El problema es que dapper no analizó el SQL, sino que asumió que todos los accesorios son configurables como parámetros, pero no pudo resolver el tipo de SQL para el User .

La última revolución resuelve esto