实体框架避免延迟加载/已打开的数据读取器问题

本文关键字:数据 读取 问题 框架 延迟加载 实体 | 更新日期: 2023-09-27 18:36:05

使用连续运行多次的联合查询,如果起始字母存在Users,我会为每个字母UserlistSection对象。所以我得到这样的东西:

  • 用户列表部分"A"
    • 用户
    • 用户
  • 用户列表部分"H"
    • 用户
  • 用户列表部分"Y"
    • 用户
    • 用户
    • 用户

但查询引发以下异常

MySql.Data.MySqlClient.MySqlException: There is already an open DataReader associated with this Connection which must be closed first.

查询任务

public UserRepository(myDatabase database)
    {
        _database = database;
    }
public Task<ObservableCollection<User>> GetUserFriendsAsync(int id, string letter)
    {
        return Task.Factory.StartNew(() =>
        {
            try
            {
                var query1 = (from urs in _database.user_relationships
                              join u in _database.users on urs.relationship_user_from equals u.user_id
                              where urs.relationship_user_to == id
                                    && u.user_name.StartsWith(letter)
                                    && urs.relationship_status == 1
                              select new User
                              {
                                  Id = u.user_id,
                                  Username = u.user_name,
                                  AvatarByte = u.user_avatar,
                                  Gender = u.user_gender,
                                  GroupId = u.user_usergroup,
                                  LoginStatusId = u.user_loginstatus
                              });
                var query2 = (from urs in _database.user_relationships
                              join u in _database.users on urs.relationship_user_to equals u.user_id
                              where urs.relationship_user_from == id
                                    && u.user_name.StartsWith(letter)
                                    && urs.relationship_status == 1
                              select new User
                              {
                                  Id = u.user_id,
                                  Username = u.user_name,
                                  AvatarByte = u.user_avatar,
                                  Gender = u.user_gender,
                                  GroupId = u.user_usergroup,
                                  LoginStatusId = u.user_loginstatus
                              });
                // Union to get users via relationships (from - to and to - from)
                var queryUnion = query1.Union(query2).OrderBy(u => u.Username);
                return new ObservableCollection<User>(queryUnion);
            }
            catch (Exception ex)
            {
                Trace.WriteLine("UserRepository - GetUserFriendsAsync" + ex);
                return null;
            }
        });
    }

和我的对象/方法来创建集合

public class UserlistSection : ObservableObject
{
    #region Attributes
    private string _letter;
    private ObservableCollection<User> _users;
    #endregion Attributes
    public string Letter
    {
        get { return _letter; }
        set { Set(ref _letter, value); }
    }
    public ObservableCollection<User> Users
    {
        get { return _users; }
        set { Set(ref _users, value); }
    }
}
// -------------------------------------------------------------------------
 public async void UpdateFriendlistCollection()
    {
        IsLoading = true;
        Friendlist = new ObservableCollection<UserlistSection>();
        for (var c = 'A'; c <= 'Z'; c++)
        {
            try
            {
                var letter = c.ToString();
                var userCollection = await _userRepository.GetUserFriendsAsync(_userObj.Id, letter);
                if (userCollection.Count < 1) return;
                foreach (var friend in userCollection)
                {
                    friend.AvatarImage = friend.GetAvatarImgByPixel(200);
                }
                var section = new UserlistSection
                {
                    Letter = letter,
                    Users = userCollection
                };
                Friendlist.Add(section);
            }
            catch (Exception ex)
            {
                Trace.WriteLine("FriendlistViewModel - UpdateFriendlistCollection: " + ex.Message);
            }
        }
        IsLoading = false;
    }

可能有更好的方法来构建查询,但我还不知道如何。所以如果有人能看到我的错误以避免懒惰加载/解决异常,那就太好了。

如果我缺少一些解释,请告诉。

编辑

当我添加这样的MultipleActiveResultSets=True时,它告诉我不支持关键字?

<connectionStrings>
<add name="someDatabase"   connectionString="metadata=res://*/Repository.Database.SomeDatabase.csdl|res://*/Repository.Database.SomeDatabase.ssdl|res://*/Repository.Database.SomeDatabase.msl;provider=MySql.Data.MySqlClient;provider connection string=&quot;server=127.0.0.1;user id=someUser;persistsecurityinfo=True;password=somePassword;multipleactiveresultsets=True;database=someDatabase;&quot;" providerName="System.Data.EntityClient" />

System.ArgumentException: Keyword not supported.
Parametername: multipleactiveresultsets
bei MySql.Data.MySqlClient.MySqlConnectionStringBuilder.GetOption(String key)
bei MySql.Data.MySqlClient.MySqlConnectionStringBuilder.set_Item(String  keyword, Object value)

实体框架避免延迟加载/已打开的数据读取器问题

您应该在配置的连接字符串中启用 MARS。

"MultipleActiveResultSets=True"添加到连接字符串。

更多信息。

编辑

从 MSDN:

在 foreach (C#) 或 For Each 期间调用 Load 方法时 (Visual Basic)枚举,实体框架尝试打开一个新的 数据读取器。除非您启用了多个 通过在 连接字符串。有关详细信息,请参阅使用多个活动 MSDN 上的结果集 (MARS)。您还可以加载查询结果 到列表集合中,这将关闭数据读取器并使您能够 枚举集合以加载引用的实体

编辑

对于MySQL,我发现了这个。梅比它可以帮助你。

MySQL似乎不支持MARS。如果可以更改 MS SQL Server Express 的数据库。或者更改ORM,例如NHibernate。