插入IEnumerable<;T>;具有Dapper错误的集合;Dapper不支持类&”;

本文关键字:Dapper 集合 错误 不支持 具有 IEnumerable lt gt 插入 | 更新日期: 2023-09-27 17:59:29

是的,这里和这里都有关于如何使用dapper dot net插入记录的问题。然而,这些答案虽然内容丰富,但似乎并没有给我指明正确的方向。情况如下:将数据从SqlServer移动到MySql。将记录读取到IEnumerable<WTUser>中很容易,但我只是在插入时没有得到什么。首先,"移动记录代码":

//  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和cnn.Query。执行调用dapper扩展方法。现在,WTUser类(注意:列名从SqlServer中的"WindowsName"更改为MySql中的"ResourceName",因此两个属性指向同一字段):

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

我收到来自dapper的异常:"dapper不支持WTUser。"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))

此时OwnerType=

System.Collections.Generic.List`1[[CRMBackEnd.WTUser,CRMBE,版本=1.0.0.0,文化=中性,PublicKeyToken=null]],mscorlib,版本=2.0.0.0,文化=中性,PublicKeyToken=b77a5c561934e089

似乎OwnerType应该是CRMBackEnd.WTUser。。。不是List<CRMBackEnd.WTUser>???因为正在迭代集合属性:Count、Capacity等。我缺少什么

更新

如果我修改了会话。将数据写入为:

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

记录插入得很好。。。但我不认为这是必要的,例如:

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"  

来自dapper点网

插入IEnumerable<;T>;具有Dapper错误的集合;Dapper不支持类&”;

我刚刚添加了一个测试:

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

正如广告中所说的那样。我对multi-exec的工作方式做了一些修改(所以它稍微快一点,并且支持object[])。

我的猜测是您遇到了问题,因为您在WTUser上的所有字段上都缺少getter属性。所有param都必须具有读取器属性,我们不支持从字段中提取此属性,这需要复杂的解析步骤才能保持高效。


导致问题的另一点是向dapper传递不支持映射的参数。

例如,以下类不支持作为参数:

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 

问题是dapper没有解析SQL,它假设所有道具都可以设置为params,但无法解析User的SQL类型。

最新版本解决了此