首页 > 解决方案 > 将 DataReader 转换为 C# 对象

问题描述

我有一堂课

public class Person
{
 public string Name {get; set;}
 public List<string> Friends {get; set;}
}

我有一个数据读取器,它从数据库中获取这些值,我想使用 DataReader 填充上述类。

通常细节如下所示

Name    Friends
John    Caleb
John    Matthew
John    Simon
Andrew  Bolton
Andrew  Mark

我需要根据名称对其进行分组,并使用每个名称的朋友列表填充到类中。

有人可以帮忙吗。我无法获得分组的朋友列表。什么是实现这个逻辑的正确代码。谢谢

标签: c#datatabledata-access-layerdatamappersqldatareader

解决方案


我假设你的表像(姓名,朋友)

你必须在你的友谊表中阅读

那么你必须将它们分组为

var groupedTempList = tempList.GroupBy(a=>a.Name)

接着

List<Person> t = new List<Person>();

foreach(var Item in groupedTempList) 
{ 
    Person tP = new Person() {Name = Item.Key};
    foreach(YourTableEquivalentClass subitem in Item)
    {
        tP.Friends.Add(subitem.Friend);
    }
}

这里是 dbreader 的扩展:

    public static int? GetNullableInteger(this SqlDataReader dbReader, string name)
    {
        var tVal = dbReader[name];
        if (Convert.IsDBNull(tVal)) return null;
        return new int?(int.Parse(tVal.ToString()));
    }

    public static int GetInteger(this SqlDataReader dbReader, string name)
    {
        int? tVal = dbReader.GetNullableInteger(name);
        if (tVal == null) throw new ArgumentNullException("Der abgerufene int/int ist null/DbNull!");
        return (int)tVal;
    }


    public static string GetString(this SqlDataReader dbReader, string name)
    {
        var tVal = dbReader[name];
        if (Convert.IsDBNull(tVal)) return null;
        return tVal.ToString();
    }

和阅读的东西

                List<YourTableEquivalentClass> temp = new List<YourTableEquivalentClass>();
                string sqlComStr =
                      @"SELECT [Name]
                              ,[Friend]
                          FROM [YourDadabase].[dbo].[YourFriendshipTable]";
                using (SqlConnection con = new SqlConnection(YourConnectionString))
                {
                    con.Open();
                    using (SqlCommand sqlCom = new SqlCommand(sqlComStr, con))
                    {
                        using (SqlDataReader dbReader = sqlCom.ExecuteReader())
                        {
                            if (dbReader.HasRows)
                            {
                                while (dbReader.Read())
                                {
                                    temp.Add(new YourTableEquivalentClass()
                                    {
                                        Name = dbReader.GetString("Name"),
                                        Friend = dbReader.GetString("Friend")
                                    });
                                }
                            }
                        }
                    }
                }

推荐阅读