实体框架 长时间运行的任务上的等待操作超时

本文关键字:等待 操作 超时 任务 长时间 运行 实体 框架 | 更新日期: 2023-09-27 18:34:11

我正在使用EF5将一些数据从一个数据库迁移到另一个数据库。我通常会使用 SQL 来实现这样的事情,但是我需要其他功能(例如在MembershipProvider中创建用户),并希望在 EF 中完成所有这些操作。我正在迁移大约 100k 行并使用它来执行此操作:

        using (var connection = new SqlConnection(connectionString))
        { 
            using(var command = new SqlCommand(commandText, connection))
            {
                connection.Open();
                using (SqlDataReader reader = command.ExecuteReader())
                {
                    while (reader.Read())
                    {
                        var employer = new Employer();
                        employer.EAN = reader["EAN"].ToString();
                        employer.Name = GetString(reader["EmpName"]);
                        employer.TaxMailingAddress = new Address
                        {
                            StreetAddress = GetString(reader["Street"]),
                            City = GetString(reader["City"]),
                            State = GetString(reader["USState"]),
                            ZipCode = GetString(reader["Zip"])
                        };
                        employer.TaxMailingAddress.SaveOrUpdate();
                        employer.SaveOrUpdate(); // This is where the timeout happens
                        string dba = GetString(reader["DBA"]);
                        if (!string.IsNullOrWhiteSpace(dba))
                        {
                            employer.AddDBA(new EmployerDba 
                            {
                                Name = dba
                            });
                        }
                        string email = GetString(reader["Email"]);
                        if (!string.IsNullOrWhiteSpace(email))
                        {
                            var user = CreateNewUser(email);
                            if (user != null)
                            {
                                user.AddAuthorizedEmployer(employer);
                                user.AddRole(EmployerRole.Admin, employer, true);
                            }
                        }
                    }
                }
            }
        }

我的SaveOrUpdate方法非常简单:

    public void SaveOrUpdate()
    {
        using (var db = new MyContext())
        {
            if (db.Employers.FirstOrDefault(x => x.EAN == EAN && x.Id != Id) != null)
                throw new Exception("An employer with this EAN has already been registered.");
            var employer = new Employer();
            if (Id == 0)
            {
                db.Employers.Add(employer);
                employer.CreatedBy = Statics.GetCurrentUserName();
                employer.DateCreated = DateTime.Now;
            }
            else
            {
                employer = db.Employers.FirstOrDefault(x => x.Id == Id);
                employer.ModifiedBy = Statics.GetCurrentUserName();
                employer.DateModified = DateTime.Now;
            }
            employer.EAN = EAN;
            employer.Name = Name;
            if (TaxMailingAddress != null) employer.TaxMailingAddress = db.Addresses.FirstOrDefault(x => x.Id == TaxMailingAddress.Id);
            if (SingleSeparationStatementAddress != null) employer.SingleSeparationStatementAddress = db.Addresses
                                    .FirstOrDefault(x => x.Id == SingleSeparationStatementAddress.Id);
            db.SaveChanges();
            Id = employer.Id;
        }
    }

完成该任务大约需要 2.5 小时。但是,在运行数千行之后,有时是 80k,有时只有 7k,我得到了这个"The wait operation timed out"例外,总是在employer.SaveOrUpdate();上。会不会与它离employer.TaxMailingAddress.SaveOrUpdate();有多近有关?是否有"等待交易完成"的交易?也许确保连接有效,如果没有,请尝试重新创建它或其他东西?感谢您的任何帮助。

实体框架 长时间运行的任务上的等待操作超时

问题最终是我用于连接到另一个数据库(我从中获取要导入的数据)的初始数据库连接超时。所以我最终遍历了所有reader.Read()语句并将其放入数组中。然后,我遍历该数组以实际处理数据并将其保存到我的新数据库中。