- c - 在位数组中找到第一个零
- linux - Unix 显示有关匹配两种模式之一的文件的信息
- 正则表达式替换多个文件
- linux - 隐藏来自 xtrace 的命令
这几天我一直在努力解决这个问题,有很多关于工作单元和 TransactionScope 的教程,但我找不到任何一起讨论这两者的内容。非常感谢任何帮助!
我正在使用具有工作单元模式的 Entity Framework 和每个类型的存储库。根据下面的简单代码,我有一个 Member 和 MembershipDefinition 实体。我想创建一个链接两者的成员资格实体,但是当我创建成员资格对象时,我想根据某些业务逻辑查询数据库中的最大值。因此,我需要使用某种数据库事务来防止另一个线程在我的线程将成员资格对象写回数据库之前递增数据库中的值。
如果我使用的是存储过程,这将非常简单,但我不知道如何使用纯 C# 来实现...
下面的代码在数据库中创建了 100 个具有重复 MembershipNumbers 的 Membership 实体。我需要使用事务来确保在 c# 代码中生成的所有成员(member)编号都是唯一的。
class Program
{
static void Main(string[] args)
{
var p = new Program();
p.Go();;
}
public void Go()
{
long memberId;
long membershipDefId;
using(var unitOfWork = new UnitOfWork())
{
// Setup - create test club and member entities
var testUsername = ("TestUserName" + Guid.NewGuid()).Substring(0, 29);
var member = new Member()
{
UserName = testUsername
};
var testmemebrshpDefName = ("TestMembershipDef" + Guid.NewGuid()).Substring(0, 29);
var membershipDefinition = new ClubMembershipDefinition()
{
ClubId = 1,
Name = testmemebrshpDefName
};
unitOfWork.MemberRepository.Add(member);
unitOfWork.MembershipDefinitionRepository.Add(membershipDefinition);
unitOfWork.Save();
memberId = member.Id;
membershipDefId = membershipDefinition.Id;
}
Task[] tasks = new Task[100];
// Now try to add a membership to the Member object, linking it to the test Club's single Club Definition
for (int i = 0; i < 100; i++)
{
var task = new Task(() => CreateMembership(memberId, membershipDefId));
tasks[i] = task;
task.Start();
}
Task.WaitAll(tasks);
}
private void CreateMembership(long memberId, long membershipDefId)
{
using (var unitOfWork = new UnitOfWork())
{
var member = unitOfWork.MemberRepository.GetById(memberId);
var membershipDef = unitOfWork.MembershipDefinitionRepository.GetById(membershipDefId);
var membership = new ClubMembership()
{
ClubMembershipDefinition = membershipDef
};
membership.MembershipNumber = (unitOfWork.MembershipRepository.GetMaxMembershipNumberForClub(membershipDef.ClubId) ?? 0) + 1;
member.ClubMemberships.Add(membership);
unitOfWork.Save();
}
}
}
public class UnitOfWork : IUnitOfWork, IDisposable
{
internal ClubSpotEntities _dbContext = new ClubSpotEntities();
internal MemberRepository _memberRepository;
internal MembershipRepository _membershipRepository;
internal MembershipDefinitionRepository _membershiDefinitionpRepository;
public MemberRepository MemberRepository
{
get
{
if (_memberRepository == null)
_memberRepository = new MemberRepository(_dbContext);
return _memberRepository; ;
}
}
public MembershipRepository MembershipRepository
{
get
{
if (_membershipRepository == null)
_membershipRepository = new MembershipRepository(_dbContext);
return _membershipRepository; ;
}
}
public MembershipDefinitionRepository MembershipDefinitionRepository
{
get
{
if (_membershiDefinitionpRepository == null)
_membershiDefinitionpRepository = new MembershipDefinitionRepository(_dbContext);
return _membershiDefinitionpRepository; ;
}
}
public virtual int Save()
{
return _dbContext.SaveChanges();
}
private bool _disposed = false;
protected virtual void Dispose(bool disposing)
{
if (!this._disposed)
{
if (disposing)
{
_dbContext.Dispose();
}
}
this._disposed = true;
}
public void Dispose()
{
Dispose(true);
GC.SuppressFinalize(this);
}
}
public class MembershipRepository
{
ClubSpotEntities _dbContext = new ClubSpotEntities();
public MembershipRepository(){}
public MembershipRepository(ClubSpotEntities dbContext)
{
_dbContext = dbContext;
}
public IEnumerable<ClubMembership> GetAll()
{
return _dbContext.Set<ClubMembership>().ToList<ClubMembership>();
}
public ClubMembership GetById(long id)
{
return _dbContext.ClubMemberships.First(x => x.Id == id);
}
public long? GetMaxMembershipNumberForClub(long clubId)
{
return _dbContext.ClubMemberships.Where(x => x.ClubMembershipDefinition.ClubId == clubId).Max(x => x.MembershipNumber);
}
public ClubMembership Add(ClubMembership entity)
{
return _dbContext.Set<ClubMembership>().Add(entity);
}
public void Delete(ClubMembership membership)
{
_dbContext.Set<ClubMembership>().Remove(membership);
}
public void Save()
{
_dbContext.SaveChanges();
}
}
public partial class ClubMembership
{
public long Id { get; set; }
public long MembershipDefId { get; set; }
public Nullable<long> MemberId { get; set; }
public Nullable<long> MembershipNumber { get; set; }
public virtual ClubMembershipDefinition ClubMembershipDefinition { get; set; }
public virtual Member Member { get; set; }
}
public partial class ClubMembershipDefinition
{
public ClubMembershipDefinition()
{
this.ClubMemberships = new HashSet<ClubMembership>();
}
public long Id { get; set; }
public long ClubId { get; set; }
public string Name { get; set; }
public virtual ICollection<ClubMembership> ClubMemberships { get; set; }
}
public partial class Member
{
public Member()
{
this.ClubMemberships = new HashSet<ClubMembership>();
}
public long Id { get; set; }
public string UserName { get; set; }
public virtual ICollection<ClubMembership> ClubMemberships { get; set; }
}
最佳答案
您可以在实例化新的 UnitOfWork 时创建事务范围,并在完成时提交。这不是完整的例子:
class UnitOfWork
{
ClubSpotEntities _dbContext;
TransactionScope _transaction;
public UnitOfWork()
{
_dbContext = new ClubSpotEntities();
_transaction = new TransactionScope();
}
public void Complete()
{
_dbContext.SaveChanges();
_transaction.Complete();
}
...
}
更新:正如史蒂文所说,这不是您问题的解决方案。 UnitOfWork 帮不了你,TransactionScope 在这种情况下也不是解决方案。 EF 不支持您想使用的悲观锁,但您可以试试这个 solution .
关于c# - 具有数据库事务的工作单元模式,我们在Stack Overflow上找到一个类似的问题: https://stackoverflow.com/questions/11982828/
我试图要求 test/unit 的新版本(即不是与 ruby 捆绑的版本) .根据 instructions我用 gem i test-unit 安装它.但是现在当我需要 test/unit我似乎
简短版本是: 我有一个 systemd 单元,我想在调用时检查脚本的返回代码: systemctl status service.service 长版本:我有一个 lsb init 脚本正是这样做的,
我正在使用反射动态创建一个类的实例,这工作正常,除非尝试通过单元测试执行此操作 - 我使用的是 MS 测试框架。 我收到熟悉的错误:“无法加载文件或程序集‘Assy’或其依赖项之一。系统找不到指定的文
我想知道测试网站“界面功能”的最佳实践是什么。 我对哪些方法可用于测试界面和动态生成的内容感兴趣。特别是,我很难弄清楚是否可以为需要用户交互的操作创建自动化测试,或者这是否只是浪费时间,我应该让一些
我有一个简单的 Python 服务,其中有一个无限执行某些操作的循环。在各种信号上,sys.exit(0) 被调用,这导致 SystemExit 被引发,然后如果可以的话应该进行一些清理。 在测试中,
我正在使用 OpenCV 2.4.2 这是 OpenCV 文档中的引文 C++: void HoughLinesP(InputArray image, OutputArray lines, doubl
忙于 C# 中的自动化测试用例,我们需要在每次测试后恢复数据库快照。问题是,当运行多个测试时它会失败,因为“其他用户正在使用数据库时无法更改数据库状态。” 我们使用 SqlConnection.Cle
我阅读了 C# 规范并用谷歌搜索了它,但一无所获。 我 99% 肯定 C# 中没有像单元命名空间指令这样的功能,但问题是:为什么?是否有惯用或技术原因? 这很方便,尤其是当我们的大部分文件都由单个命名
我目前正在尝试向我的应用程序(一个非常老的项目......评论说 iOS 2.0)添加单元测试(精确的应用程序测试)并且总是偶然发现 undefined symbols for architectur
我正在使用Delphi 7,并且有一个新单元要在我的项目中使用。我已经编译了新的。当我尝试通过将其添加到uses子句在项目中使用此单元时,出现错误,提示未找到.dcu文件。我还尝试将文件的完整路径放在
场景:我需要编写一个复杂的nHibernate查询,该查询将返回预计的DTO,但是我想使用TDD方法。该方法如下所示: public PrintDTO GetUsersForPrinting(int
您可以通过运行以下命令在事件 html 设置中显示 Jupyter 笔记本: $ jupyter nbconvert untitled.ipynb --to slides --post serve 有
如何在一个网站上拥有多个 AdSense 单元? Google 提供的唯一代码是按单位计算的。 (adsbygoogle = window.adsbygoogle || []).push({})
我刚刚开始为大量代码编写测试。有很多类依赖于文件系统,即读取 CSV 文件、读/写配置文件等。 当前测试文件存储在项目(这是一个 Maven2 项目)的 test 目录中,但由于多种原因该目录并不总是
我对 TDD 还很陌生,在单元测试方面也不是很老练,所以才有这个问题。我有这个用 PHP 编写的遗留函数 function foo(){ x = bar(); y = baz();
我创建了一个程序,在 Swing 窗口的一侧显示结果过滤选项,但默认情况下它们水平相邻显示,这浪费了我在 BorderLayout 的西侧分配的空间。我可以在构造函数或添加语句中传递任何内容来将它们堆
标题不好的借口:如果有人能更好地描述它,请做。 我有一个 WeakList类,它“基本上”是一个 List> (虽然不是字面意义上的派生自列表,但它应该对用户完全透明)。 现在的基本思想是“如果引用的
我正在尝试在 UITableView 上添加两个原型(prototype)单元。但是,我不知道如何验证是否能够为每个原型(prototype)“返回”正确的单元格。你们能帮我一下吗? func ta
我正在使用 CloudKit 作为数据库创建一个简单的待办事项列表应用程序。目前我可以添加和删除对象,但对编辑对象感到困惑。 编辑项目 Controller protocol EditItemCont
我正在针对以下任务训练 RNN:给定一个包含 30 个单词的序列,然后将该序列分类为二进制类。 在我的网络中拥有超过 30 个单元(LSTM、GRU 或普通 RNN)有好处吗?我在网上看到过很多例子,
我是一名优秀的程序员,十分优秀!